src/Hitso/Bundle/CommonBundle/Repository/VisitLogRepository.php line 29

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Hitso\Bundle\CommonBundle\Repository;
  7. use Hitso\Bundle\CommonBundle\Doctrine\Repository\EntityRepository;
  8. use Hitso\Bundle\CommonBundle\Entity\VisitLog;
  9. use Symfony\Bridge\Doctrine\RegistryInterface;
  10. use Webmozart\Assert\Assert;
  12. class VisitLogRepository extends EntityRepository
  13. {
  14.     public function __construct(RegistryInterface $registry, string $className = VisitLog::class)
  15.     {
  16.         parent::__construct($registry, $className);
  17.     }
  19.     public function logVisit(string $visitor): void
  20.     {
  21.         Assert::true(
  22.             in_array($visitor, [VisitLog::TYPE_GOOGLE, VisitLog::TYPE_MONITOR, VisitLog::TYPE_HITSO_MONITORING]),
  23.             'Invalid visitor'
  24.         );
  26.         $log = new VisitLog();
  27.         $log->setVisitor($visitor);
  29.         $this->_em->persist($log);
  30.         $this->_em->flush();
  32.         $this->deleteLogs(new \DateTime('-3 days'));
  33.     }
  35.     /**
  36.      * @param $visitor
  37.      *
  38.      * @return bool|\DateTime
  39.      */
  40.     public function getLastTime($visitor)
  41.     {
  42.         /** @var VisitLog $entity */
  43.         $entity = $this->findOneBy(['visitor' => $visitor], ['createdAt' => 'DESC']);
  45.         return $entity ? $entity->getCreatedAt() : false;
  46.     }
  48.     /**
  49.      * @param     $visitor
  50.      * @param int $days
  51.      * @param int $samples
  52.      *
  53.      * @return array
  54.      */
  55.     public function getChartData($visitor, $days = 3, $samples = 4)
  56.     {
  57.         $sampleSize = 86400 / $samples;
  58.         $midnight   = strtotime('midnight');
  60.         $todaySamples = (int) floor((time() - $midnight) / $sampleSize);
  61.         $endOfLast    = $todaySamples * $sampleSize + $midnight;
  62.         $startOfFirst = $endOfLast - ($days * 86400);
  64.         $qb = $this->createQueryBuilder('v');
  65.         $qb->select()
  66.             ->where($qb->expr()->eq('v.visitor', $qb->expr()->literal($visitor)))
  67.             ->andWhere($qb->expr()->gte('v.createdAt', ':start'))
  68.             ->andWhere($qb->expr()->lte('v.createdAt', ':end'))
  69.             ->orderBy('v.createdAt', 'ASC');
  71.         $startDate = new \DateTime('@' . $startOfFirst);
  72.         $endDate   = new \DateTime('@' . $endOfLast);
  74.         $tz = new \DateTimeZone(date_default_timezone_get());
  75.         $startDate->setTimezone($tz);
  76.         $endDate->setTimezone($tz);
  78.         /** @var VisitLog[] $logs */
  79.         $logs = $qb->getQuery()->execute(
  80.             [
  81.                 'start' => $startDate,
  82.                 'end'   => $endDate,
  83.             ]
  84.         );
  86.         $start = $startOfFirst;
  87.         $end   = $startOfFirst + $sampleSize;
  89.         $keys = range($startOfFirst, $endOfLast - 1, $sampleSize);
  90.         $data = array_combine($keys, array_fill(0, count($keys), 0));
  92.         foreach ($logs as $log) {
  93.             $stamp = $log->getCreatedAt()->getTimestamp();
  95.             while ($stamp > $end) {
  96.                 $start += $sampleSize;
  97.                 $end   += $sampleSize;
  98.             }
  100.             ++$data[$start];
  101.         }
  103.         $results = [];
  105.         foreach ($data as $start => $count) {
  106.             $label           = sprintf('%s-%s', date('Y-m-d H:i', $start), date('H:i', $start + $sampleSize - 1));
  107.             $results[$label] = $count;
  108.         }
  110.         return $results;
  111.     }
  113.     private function deleteLogs(\DateTime $before): void
  114.     {
  115.         if (random_int(1, 10) > 3) {
  116.             return;
  117.         }
  119.         $qb = $this->createQueryBuilder('v');
  120.         $qb->delete()
  121.             ->andWhere('v.createdAt < :limit')
  122.             ->setParameter('limit', $before)
  123.             ->getQuery()
  124.             ->execute();
  125.     }
  126. }