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

  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\Contract\ProducerFactoryInterface;
  11. use Aqarmap\Bundle\UserBundle\Entity\User;
  12. use Aqarmap\Bundle\UserBundle\Services\UserInterestManager;
  13. use Aqarmap\Bundle\UserBundle\Services\UserManager;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  16. use Symfony\Component\HttpFoundation\Cookie;
  17. use Symfony\Component\HttpFoundation\RequestStack;
  18. use Symfony\Component\HttpFoundation\Response;
  20. class InteractionService
  21. {
  22. /** @var RequestStack */
  23. private $request;
  25. /** @var ListingManager */
  26. private $listingManager;
  28. /**
  29. * @var EventDispatcherInterface
  30. */
  31. protected $dispatcher;
  33. /**
  34. * @var Storage
  35. */
  36. protected $tokenStorage;
  38. /**
  39. * @var ProducerFactoryInterface
  40. */
  41. protected $buyerAlertProducer;
  43. /**
  44. * @var UserInterestManager
  45. */
  46. protected $interestManager;
  48. /** @var InteractionRepository */
  49. protected $interactionRepository;
  51. /** @var ListingContactRateService */
  52. protected $listingContactRateService;
  54. public function __construct(
  55. private readonly EntityManagerInterface $em,
  56. RequestStack $request,
  57. EventDispatcherInterface $dispatcher,
  58. ProducerFactoryInterface $pokeProducerFactory,
  59. UserInterestManager $interestManager,
  60. protected UserManager $userManager,
  61. InteractionRepository $interactionRepository,
  62. ListingContactRateService $listingContactRateService,
  63. ) {
  64. $this->request = $request->getCurrentRequest();
  65. $this->dispatcher = $dispatcher;
  66. $this->interestManager = $interestManager;
  67. $this->interactionRepository = $interactionRepository;
  68. $this->listingContactRateService = $listingContactRateService;
  69. }
  71. /**
  72. * @param int $type
  73. * @param User $user
  74. * @param string|null $source
  75. * @param bool $flush
  76. */
  77. public function addInteraction($type, Listing $listing, $user = null, $source = null, $flush = true, $campaign = null): ?Interaction
  78. {
  79. $isValid = true;
  80. $interaction = new Interaction();
  81. $interaction
  82. ->setUser($user)
  83. ->setListing($listing)
  84. ->setType($type)
  85. ->setUserIp($this->request->getClientIp())
  86. ->setSource($source)
  87. ->setCampaign($campaign)
  88. ;
  90. // Check if the campaign exists in the cookie add it to listing
  91. $cookies = $this->request->cookies;
  92. if ($cookies->has('campaign')) {
  93. $interaction->setCampaign($cookies->get('campaign'));
  94. }
  96. if (\in_array($type, [InteractionTypes::LISTING_VIEWS])) {
  97. $isValid = $this->validateInteractionsDuplications($interaction);
  98. }
  100. if (true == $isValid) {
  101. $this->em->persist($interaction);
  102. if ($flush) {
  103. $this->em->flush([$interaction]);
  104. }
  106. $this->listingManager->incrementViewsCounters($listing);
  108. return $interaction;
  109. }
  111. return null;
  112. }
  114. /**
  115. * @return bool
  116. */
  117. private function validateInteractionsDuplications(Interaction $interaction)
  118. {
  119. $duplicates = $this->interactionRepository->checkDuplicateInteraction($interaction);
  121. return $duplicates ? false : true;
  122. }
  124. /**
  125. * @param User $user
  126. */
  127. public function increaseViews(Listing $listing, $user = null): void
  128. {
  129. $response = new Response();
  130. $views = [];
  131. if ($this->request->cookies->has('viewed_listings')) {
  132. $views = unserialize($this->request->cookies->get('viewed_listings'));
  133. if (\count($views) > 100) {
  134. array_pop($views);
  135. }
  136. }
  138. if (!\in_array($listing->getId(), $views)) {
  139. $views[] = $listing->getId();
  140. $response->headers->setCookie(Cookie::create('viewed_listings', serialize($views), time() + (86400 * 7)));
  141. $response->sendHeaders();
  142. $this->addInteraction(InteractionTypes::LISTING_VIEWS, $listing, $user, 'interaction-service');
  143. }
  144. }
  146. #[\Symfony\Contracts\Service\Attribute\Required]
  147. public function setListingManager(ListingManager $listingManager): void
  148. {
  149. $this->listingManager = $listingManager;
  150. }
  151. }