src/Aqarmap/Bundle/ListingBundle/Service/InteractionService.php line 138

Open in your IDE?
  1. <?php
  3. namespace Aqarmap\Bundle\ListingBundle\Service;
  5. use Aqarmap\Bundle\ListingBundle\Constant\Campaign;
  6. use Aqarmap\Bundle\ListingBundle\Constant\InteractionTypes;
  7. use Aqarmap\Bundle\ListingBundle\Entity\Interaction;
  8. use Aqarmap\Bundle\ListingBundle\Entity\Listing;
  9. use Aqarmap\Bundle\ListingBundle\Repository\InteractionRepository;
  10. use Aqarmap\Bundle\MainBundle\Constant\ProducerQueues;
  11. use Aqarmap\Bundle\MainBundle\Contract\ProducerFactoryInterface;
  12. use Aqarmap\Bundle\UserBundle\Entity\User;
  13. use Aqarmap\Bundle\UserBundle\Services\UserInterestManager;
  14. use Aqarmap\Bundle\UserBundle\Services\UserManager;
  15. use Doctrine\ORM\EntityManagerInterface;
  16. use Symfony\Component\DependencyInjection\ContainerInterface;
  17. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  18. use Symfony\Component\HttpFoundation\Cookie;
  19. use Symfony\Component\HttpFoundation\RequestStack;
  20. use Symfony\Component\HttpFoundation\Response;
  22. class InteractionService
  23. {
  24.     private $em;
  26.     /** @var RequestStack */
  27.     private $request;
  29.     /** @var ListingManager */
  30.     private $listingManager;
  32.     /**
  33.      * @var EventDispatcherInterface
  34.      */
  35.     protected $dispatcher;
  37.     /**
  38.      * @var Storage
  39.      */
  40.     protected $tokenStorage;
  42.     /**
  43.      * @var ProducerFactoryInterface
  44.      */
  45.     protected $buyerAlertProducer;
  47.     /**
  48.      * @var UserInterestManager
  49.      */
  50.     protected $interestManager;
  52.     protected UserManager $userManager;
  54.     /** @var InteractionRepository */
  55.     protected $interactionRepository;
  57.     /** @var ListingContactRateService */
  58.     protected $listingContactRateService;
  60.     public function __construct(
  61.         ContainerInterface $container,
  62.         EntityManagerInterface $em,
  63.         RequestStack $request,
  64.         EventDispatcherInterface $dispatcher,
  65.         ProducerFactoryInterface $pokeProducerFactory,
  66.         UserInterestManager $interestManager,
  67.         UserManager $userManager,
  68.         InteractionRepository $interactionRepository,
  69.         ListingContactRateService $listingContactRateService
  70.     ) {
  71.         $this->em = $em;
  72.         $this->request = $request->getCurrentRequest();
  73.         $this->dispatcher = $dispatcher;
  74.         $this->pokeProducerFactory = $pokeProducerFactory->create(ProducerQueues::POKE_CLICKED_LISTING);
  75.         $this->interestManager = $interestManager;
  76.         $this->userManager = $userManager;
  77.         $this->interactionRepository = $interactionRepository;
  78.         $this->listingContactRateService = $listingContactRateService;
  79.     }
  81.     /**
  82.      * @param int $type
  83.      * @param User $user
  84.      * @param string|null $source
  85.      * @param bool $flush
  86.      * @param null $campaign
  87.      */
  88.     public function addInteraction($type, Listing $listing, $user = null, $source = null, $flush = true, $campaign = null): ?Interaction
  89.     {
  90.         $isValid = true;
  91.         $interaction = new Interaction();
  92.         $interaction
  93.             ->setUser($user)
  94.             ->setListing($listing)
  95.             ->setType($type)
  96.             ->setUserIp($this->request->getClientIp())
  97.             ->setSource($source)
  98.             ->setCampaign($campaign)
  99.         ;
  101.         // Check if the campaign exists in the cookie  add it to listing
  102.         $cookies = $this->request->cookies;
  103.         if ($cookies->has('campaign')) {
  104.             $interaction->setCampaign($cookies->get('campaign'));
  105.         }
  107.         if (\in_array($type, [InteractionTypes::LISTING_VIEWS])) {
  108.             $isValid = $this->validateInteractionsDuplications($interaction);
  109.         }
  111.         if (true == $isValid) {
  112.             $this->em->persist($interaction);
  113.             if ($flush) {
  114.                 $this->em->flush([$interaction]);
  115.             }
  117.             $this->listingManager->incrementViewsCounters($listing);
  119.             return $interaction;
  120.         }
  122.         return null;
  123.     }
  125.     /**
  126.      * @return bool
  127.      */
  128.     private function validateInteractionsDuplications(Interaction $interaction)
  129.     {
  130.         $duplicates = $this->interactionRepository->checkDuplicateInteraction($interaction);
  132.         return $duplicates ? false : true;
  133.     }
  135.     /**
  136.      * @param User $user
  137.      */
  138.     public function increaseViews(Listing $listing, $user = null): void
  139.     {
  140.         $response = new Response();
  141.         $views = [];
  142.         if ($this->request->cookies->has('viewed_listings')) {
  143.             $views = unserialize($this->request->cookies->get('viewed_listings'));
  144.             if (\count($views) > 100) {
  145.                 array_pop($views);
  146.             }
  147.         }
  149.         if (!\in_array($listing->getId(), $views)) {
  150.             $views[] = $listing->getId();
  151.             $response->headers->setCookie(new Cookie('viewed_listings', serialize($views), time() + (86400 * 7)));
  152.             $response->sendHeaders();
  153.             $this->addInteraction(InteractionTypes::LISTING_VIEWS, $listing, $user, 'interaction-service');
  154.         }
  155.     }
  157.     /**
  158.      * @required
  159.      */
  160.     public function setListingManager(ListingManager $listingManager): void
  161.     {
  162.         $this->listingManager = $listingManager;
  163.     }
  164. }