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;
  19. use Symfony\Component\Security\Core\User\UserInterface;
  20. use Symfony\Contracts\Service\Attribute\Required;
  22. class InteractionService
  23. {
  24. /** @var RequestStack */
  25. private $request;
  27. /** @var ListingManager */
  28. private $listingManager;
  30. /**
  31. * @var EventDispatcherInterface
  32. */
  33. protected $dispatcher;
  35. /**
  36. * @var Storage
  37. */
  38. protected $tokenStorage;
  40. /**
  41. * @var ProducerFactoryInterface
  42. */
  43. protected $buyerAlertProducer;
  45. /**
  46. * @var UserInterestManager
  47. */
  48. protected $interestManager;
  50. /** @var InteractionRepository */
  51. protected $interactionRepository;
  53. /** @var ListingContactRateService */
  54. protected $listingContactRateService;
  56. public function __construct(
  57. private readonly EntityManagerInterface $em,
  58. RequestStack $request,
  59. EventDispatcherInterface $dispatcher,
  60. ProducerFactoryInterface $pokeProducerFactory,
  61. UserInterestManager $interestManager,
  62. protected UserManager $userManager,
  63. InteractionRepository $interactionRepository,
  64. ListingContactRateService $listingContactRateService,
  65. ) {
  66. $this->request = $request->getCurrentRequest();
  67. $this->dispatcher = $dispatcher;
  68. $this->interestManager = $interestManager;
  69. $this->interactionRepository = $interactionRepository;
  70. $this->listingContactRateService = $listingContactRateService;
  71. }
  73. /**
  74. * @param int $type
  75. * @param User $user
  76. * @param string|null $source
  77. * @param bool $flush
  78. */
  79. public function addInteraction($type, Listing $listing, $user = null, $source = null, $flush = true, $campaign = null): ?Interaction
  80. {
  81. $isValid = true;
  82. $interaction = new Interaction();
  83. $interaction
  84. ->setUser($user)
  85. ->setListing($listing)
  86. ->setType($type)
  87. ->setUserIp($this->request->getClientIp())
  88. ->setSource($source)
  89. ->setCampaign($campaign)
  90. ;
  92. // Check if the campaign exists in the cookie add it to listing
  93. $cookies = $this->request->cookies;
  94. if ($cookies->has('campaign')) {
  95. $interaction->setCampaign($cookies->get('campaign'));
  96. }
  98. if (\in_array($type, [InteractionTypes::LISTING_VIEWS])) {
  99. $isValid = $this->validateInteractionsDuplications($interaction);
  100. }
  102. if (true == $isValid) {
  103. $this->em->persist($interaction);
  104. if ($flush) {
  105. $this->em->flush([$interaction]);
  106. }
  108. $this->listingManager->incrementViewsCounters($listing);
  110. return $interaction;
  111. }
  113. return null;
  114. }
  116. /**
  117. * @return bool
  118. */
  119. private function validateInteractionsDuplications(Interaction $interaction)
  120. {
  121. $duplicates = $this->interactionRepository->checkDuplicateInteraction($interaction);
  123. return $duplicates ? false : true;
  124. }
  126. public function increaseViews(Listing $listing, ?UserInterface $user = null): void
  127. {
  128. if (
  129. $user instanceof User
  130. && $listing->getUser()->getId() === $user->getId()
  131. ) {
  132. return;
  133. }
  135. $response = new Response();
  136. $views = [];
  137. if ($this->request->cookies->has('viewed_listings')) {
  138. $views = unserialize($this->request->cookies->get('viewed_listings'));
  139. if (\count($views) > 100) {
  140. array_pop($views);
  141. }
  142. }
  144. if (!\in_array($listing->getId(), $views)) {
  145. $views[] = $listing->getId();
  146. $response->headers->setCookie(Cookie::create('viewed_listings', serialize($views), time() + (86400 * 7)));
  147. $response->sendHeaders();
  149. $user = $user instanceof User ? $user : null;
  150. $this->addInteraction(InteractionTypes::LISTING_VIEWS, $listing, $user, 'interaction-service');
  151. }
  152. }
  154. #[Required]
  155. public function setListingManager(ListingManager $listingManager): void
  156. {
  157. $this->listingManager = $listingManager;
  158. }
  159. }