src/Aqarmap/Bundle/CustomerProfilingBundle/EventListener/CustomerProfilingListener.php line 49

Open in your IDE?
  1. <?php
  3. namespace Aqarmap\Bundle\CustomerProfilingBundle\EventListener;
  5. use Aqarmap\Bundle\CustomerProfilingBundle\Entity\CustomerProfilingQuestionQueue;
  6. use Aqarmap\Bundle\CustomerProfilingBundle\Services\CustomerProfilingService;
  7. use Aqarmap\Bundle\MainBundle\Service\CacheManager;
  8. use Aqarmap\Bundle\UserBundle\Entity\User;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use FOS\UserBundle\Event\UserEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Contracts\Translation\TranslatorInterface;
  14. /**
  15.  * Class CustomerProfilingListener.
  16.  */
  17. class CustomerProfilingListener implements EventSubscriberInterface
  18. {
  19.     public const CACHE_KEY_PREFIX = 'customer_profiling';
  20.     /**
  21.      * @var EntityManagerInterface
  22.      */
  23.     protected $em;
  25.     protected $twig;
  27.     protected $translator;
  29.     /** @var CustomerProfilingService */
  30.     protected $profilingService;
  32.     public function __construct(
  33.         EntityManagerInterface $em,
  34.         \Twig_Environment $twig_Environment,
  35.         TranslatorInterface $translator,
  36.         CustomerProfilingService $profilingService,
  37.         CacheManager $cacheManager
  38.     ) {
  39.         $this->em = $em;
  40.         $this->twig = $twig_Environment;
  41.         $this->translator = $translator;
  42.         $this->profilingService = $profilingService;
  43.         $this->cacheManager = $cacheManager;
  44.     }
  46.     /**
  47.      * @throws \Exception
  48.      */
  49.     public function onSearch(UserEvent $event): void
  50.     {
  51.         $user = $event->getUser();
  52.         /** @var CustomerProfilingQuestionQueue $currentSet */
  53.         $currentSet = $this->em
  54.             ->getRepository('AqarmapCustomerProfilingBundle:CustomerProfilingQuestionQueue')
  55.             ->getCurrentCustomerSet($user);
  57.         if ($currentSet && $this->canDisplaySet($currentSet, $user)) {
  58.             $questions = $this->profilingService->processQueueSet($currentSet);
  59.             $this->twig->addGlobal('customerProfilingSet', $questions);
  60.             $this->twig->addGlobal('currentSurveySet', $currentSet);
  61.             $currentDisplayDate = new \DateTime();
  62.             $currentSet->setLastDisplayTime($currentDisplayDate);
  63.             $this->em->persist($currentSet);
  64.             $this->em->flush($currentSet);
  66.             if (0 == $currentSet->getSkipNumber()) {
  67.                 $this->cacheManager->set($this->getCacheKey($user->getId()), serialize([
  68.                     'set_id' => $currentSet->getId(),
  69.                     'last_display_time' => $currentDisplayDate->getTimestamp(),
  70.                 ]));
  71.             }
  72.         }
  73.     }
  75.     /**
  76.      * @return bool
  77.      */
  78.     private function canDisplaySet(CustomerProfilingQuestionQueue $currentSet, User $user)
  79.     {
  80.         $oneWeek = new \DateTime('-1 week');
  81.         $threeDays = new \DateTime('-3 days');
  83.         $cacheKey = $this->getCacheKey($user->getId());
  84.         if (null == $currentSet->getLastDisplayTime() && 0 == $currentSet->getSkipNumber() && !$this->cacheManager->has($cacheKey)) {
  85.             return true;
  86.         } elseif ($this->cacheManager->has($cacheKey)) {
  87.             $userSetData = $this->cacheManager->get($cacheKey);
  88.             $userSetData = unserialize($userSetData);
  90.             if ($userSetData['set_id'] == $currentSet->getId()) {
  91.                 if (0 == $currentSet->getSkipNumber()) {
  92.                     return true;
  93.                 } elseif ($currentSet->getSkipNumber() > 0
  94.                     && $userSetData['last_display_time'] <= $oneWeek->getTimestamp()
  95.                 ) {
  96.                     return true;
  97.                 }
  98.             } elseif ($userSetData['set_id'] != $currentSet->getId()
  99.             ) {
  100.                 if ($userSetData['last_display_time'] < $threeDays->getTimestamp()) {
  101.                     return true;
  102.                 }
  103.             }
  104.         }
  106.         return false;
  107.     }
  109.     /**
  110.      * @return string
  111.      */
  112.     private function getCacheKey(int $userId)
  113.     {
  114.         return sprintf('%s_%s', self::CACHE_KEY_PREFIX, $userId);
  115.     }
  117.     public static function getSubscribedEvents()
  118.     {
  119.         return [
  120.             'aqarmap.listing.user.search' => 'onSearch',
  121.         ];
  122.     }
  123. }