src/EventListener/UserStatsListener.php line 85

  1. <?php
  3. namespace App\EventListener;
  5. use App\Entity\User;
  6. use App\Entity\UserStats;
  7. use App\Event\BookingCompleteEvent;
  8. use App\Event\OrderCompleteEvent;
  9. use App\Services\IPGeolocator;
  10. use Doctrine\Common\Persistence\ObjectManager;
  11. use Doctrine\ORM\EntityManager;
  12. use Psr\Log\LoggerInterface;
  13. use Ramsey\Uuid\Uuid;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Symfony\Component\HttpFoundation\Request;
  16. use Symfony\Component\HttpFoundation\Session\Session;
  17. use Symfony\Component\HttpKernel\Event\KernelEvent;
  18. // use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorage;
  19. use Symfony\Component\Security\Core\Authentication\Token\Storage\UsageTrackingTokenStorage;
  20. use Symfony\Component\Security\Core\Authentication\Token\TokenInterface;
  22. class UserStatsListener
  23. {
  24.     /**
  25.      * @var EntityManager $em
  26.      */
  27.     protected $em;
  29.     /**
  30.      * @var Session $session
  31.      */
  32.     protected $session;
  34.     /**
  35.      * @var IPGeolocator $locator
  36.      */
  37.     protected $locator;
  39.     /**
  40.      * @var User $user
  41.      */
  42.     protected $user;
  44.     /**
  45.      * @var LoggerInterface
  46.      */
  47.     protected $logger;
  49.     /**
  50.      * UserStatsListener constructor.
  51.      * @param Session $session
  52.      * @param ObjectManager $em
  53.      * @param IPGeolocator $locator
  54.      * @param TokenStorage $storage
  55.      * @param LoggerInterface $logger
  56.      */
  57.     public function __construct(Session $session, EntityManagerInterface $em, IPGeolocator $locator, UsageTrackingTokenStorage $storage, LoggerInterface $logger)
  58.     {
  59.         $this->em = $em;
  60.         $this->session = $session;
  61.         $this->locator = $locator;
  62.         $this->user = null;
  63.         $this->logger = $logger;
  64.         if (!is_null($token = $storage->getToken())) {
  65.             $this->user = $storage->getToken()->getUser();
  66.         }
  68.     }
  70.     /**
  71.      * @param Request $request
  72.      * @return mixed
  73.      */
  74.     protected function getPage(Request $request)
  75.     {
  76.         return str_replace('app_dev.php', '', $request->getRequestUri());
  77.     }
  80.     /**
  81.      * @param $sessionId
  82.      * @param $uuid
  83.      * @return UserStats|null
  84.      */
  85.     protected function findUserStats($sessionId, $uuid)
  86.     {
  87.         return $this->em->getRepository(UserStats::class)->findOneBySessionIdOrUuid($sessionId, $uuid);
  88.     }
  90.     /**
  91.      * @param Request $request
  92.      * @param string $sessionId
  93.      * @param string $uuid
  94.      * @return UserStats
  95.      */
  96.     protected function createUserStats(Request $request, $sessionId, $uuid)
  97.     {
  98.         $userStats = new UserStats();
  99.         $userStats->setSessionId($sessionId);
  100.         $userStats->setIp($request->getClientIp());
  101.         $userStats->setDevice($request->headers->get('USER-AGENT'));
  102.         $userStats->setReferer($request->headers->get('referer'));
  103.         $userStats->setUuid($uuid);
  104.         /**
  105.          * GeoLocation
  106.          */
  107.         $location = $this->locator->geoLocate($request->getClientIp());
  108.         if (is_array($location)) {
  109.             $userStats->setLocation($location);
  110.         }
  111.         return $userStats;
  112.     }
  115.     /**
  116.      * @return string
  117.      */
  118.     protected function getSessionUuid()
  119.     {
  120.         if (!$this->session->has('uuid')) {
  121.             $this->session->set('uuid', Uuid::uuid4());
  122.         }
  123.         return $this->session->get('uuid');
  124.     }
  127.     /**
  128.      * Should we track the request?
  129.      * @param KernelEvent $event
  130.      * @return bool
  131.      */
  132.     protected function isValidRequest(KernelEvent $event)
  133.     {
  134.         $request = $event->getRequest();
  135.         /**
  136.          * List of not traceable requests
  137.          */
  138.         if (!$event->isMainRequest() || //SubRequest
  139.             $request->isXmlHttpRequest() || //Ajax
  140.             strpos($request->attributes->get('_route'), 'assetic') !== false || //Assetic
  141.             strpos('/_', $request->getRequestUri()) !== false //Hidden url
  142.         ) {
  143.             return false;
  144.         }
  145.         return true;
  146.     }
  148.     /**
  149.      * @param KernelEvent $event
  150.      * @return bool
  151.      */
  152.     public function onKernelRequest(KernelEvent $event)
  153.     {
  154.         try {
  155.             if ($this->isValidRequest($event)) {
  156.                 $request = $event->getRequest();
  158.                 if ($sessionId = $this->session->getId()) {
  159.                     $uuid = $this->getSessionUuid();
  160.                     if (!$userStats = $this->findUserStats($sessionId, $uuid)) {
  161.                         $userStats = $this->createUserStats($request, $sessionId, $uuid);
  162.                     }
  163.                     $userStats->setLastUpdate(new \DateTime());
  164.                     $userStats->addVisitedPage($this->getPage($request));
  165.                     $userStats->setUser($this->user);
  166.                     $userStats->setLocale($request->getLocale());
  167.                     $this->em->persist($userStats);
  168.                     $this->em->flush();
  169.                 }
  170.                 return true;
  171.             }
  172.             return false;
  173.         } catch (\Exception $e) {
  174.             $this->logger->error('ERROR TRAKING STATS FROM THE USER : ' . $e->getMessage() . "[{$e->getTraceAsString()}]");
  175.         }
  176.         return false;
  177.     }
  180.     /**
  181.      * @param OrderCompleteEvent $event
  182.      */
  183.     public function onOrderComplete(OrderCompleteEvent $event)
  184.     {
  185.         $order = $event->getOrder();
  186.         $request = $event->getRequest();
  188.         if ($sessionId = $this->session->getId()) {
  189.             $uuid = $this->getSessionUuid();
  190.             if (!$userStats = $this->findUserStats($sessionId, $uuid)) {
  191.                 $this->createUserStats($request, $sessionId, $uuid);
  192.             }
  193.             $userStats->addOrderConversion($order);
  194.             $this->em->persist($userStats);
  195.             $this->em->flush();
  196.         }
  198.     }
  201.     /**
  202.      * @param BookingCompleteEvent $event
  203.      */
  204.     public function onBookingComplete(BookingCompleteEvent $event)
  205.     {
  206.         $booking = $event->getBooking();
  207.         $request = $event->getRequest();
  209.         if ($sessionId = $this->session->getId()) {
  210.             $uuid = $this->getSessionUuid();
  211.             if (!$userStats = $this->findUserStats($sessionId, $uuid)) {
  212.                 $this->createUserStats($request, $sessionId, $uuid);
  213.             }
  214.             $userStats->addBookingConversion($booking);
  215.             $this->em->persist($userStats);
  216.             $this->em->flush();
  217.         }
  218.     }
  220. }