VideoGamesRecords\DwhBundle\Service\Dwh\DwhPlayerHandler

Complexity

Total Complexity

7

Size/Duplication

Total Lines	53
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	purge()	0	9	1
A	process()	0	25	5
A	__construct()	0	4	1

<?php
namespace VideoGamesRecords\DwhBundle\Service\Dwh;

use DateInterval;
use DateTime;
use Doctrine\ORM\EntityManager;
use Exception;
use VideoGamesRecords\CoreBundle\Service\Dwh\DwhPlayerProvider;

The type VideoGamesRecords\CoreBundle\Service\Dwh\DwhPlayerProvider was not found. Maybe you did not declare it correctly or list all dependencies?

use VideoGamesRecords\DwhBundle\Entity\Player as DwhPlayer;
use VideoGamesRecords\DwhBundle\Interface\DwhTableInterface;

class DwhPlayerHandler implements DwhTableInterface
{
    private EntityManager $dwhEntityManager;
    private DwhPlayerProvider $dwhPlayerProvider;

    public function __construct(EntityManager $dwhEntityManager,DwhPlayerProvider $dwhPlayerProvider)
    {
        $this->dwhEntityManager = $dwhEntityManager;
        $this->dwhPlayerProvider = $dwhPlayerProvider;
    }

    /**
     * @throws Exception
     */
    public function process(): void
    {
        $date1 = new DateTime();
        $date1->sub(new DateInterval('P1D'));
        $date2 = new DateTime();

        $data1 = $this->dwhPlayerProvider->getNbPostDay($date1, $date2);
        $data2 = $this->dwhPlayerProvider->getDataRank();
        $list = $this->dwhPlayerProvider->getDataForDwh();

        foreach ($list as $row) {
            $idPlayer = $row['id'];
            $dwhPlayer = new DwhPlayer();
            $dwhPlayer->setDate($date1->format('Y-m-d'));
            $dwhPlayer->setFromArray($row);
            $dwhPlayer->setNbPostDay((isset($data1[$idPlayer])) ? $data1[$idPlayer] : 0);
            if (isset($data2[$idPlayer])) {
                foreach ($data2[$idPlayer] as $key => $value) {
                    $dwhPlayer->setChartRank($key, $value);
                }
            }
            $this->dwhEntityManager->persist($dwhPlayer);
        }

        $this->dwhEntityManager->flush();
    }

    /**
     * @throws Exception
     */
    public function purge(): void
    {
        $date = new DateTime();
        $date = $date->sub(DateInterval::createFromDateString('3 years'));

        //----- delete
        $query = $this->dwhEntityManager->createQuery('DELETE VideoGamesRecords\DwhBundle\Entity\Player p WHERE p.date < :date');
        $query->setParameter('date', $date->format('Y-m-d'));
        $query->execute();
    }
}