src/Aqarmap/Bundle/UserBundle/EventListener/UserInterestSubscribeListener.php line 100

  1. <?php
  3. namespace Aqarmap\Bundle\UserBundle\EventListener;
  5. use Aqarmap\Bundle\BuyerAlertsBundle\Service\BuyerAlertsManager;
  6. use Aqarmap\Bundle\FeatureToggleBundle\Service\FeatureToggleManager;
  7. use Aqarmap\Bundle\ListingBundle\Event\LeadEvent;
  8. use Aqarmap\Bundle\ListingBundle\Service\LeadService;
  9. use Aqarmap\Bundle\UserBundle\Event\userInterestEvent;
  10. use Aqarmap\Bundle\UserBundle\Services\Contracts\UserInterestBuilderInterface;
  11. use Aqarmap\Bundle\UserBundle\Services\UserInterestManager;
  12. use Doctrine\ORM\EntityManagerInterface;
  13. use Psr\Log\LoggerInterface;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class UserInterestSubscribeListener implements EventSubscriberInterface
  17. {
  18. /**
  19. * @var EntityManagerInterface
  20. */
  21. protected $em;
  23. /**
  24. * @var FeatureToggleManager
  25. */
  26. protected $featureToggleManager;
  28. /**
  29. * @var LeadService
  30. */
  31. protected $leadService;
  33. /**
  34. * @var UserInterestManager
  35. */
  36. protected $userInterestManager;
  38. /**
  39. * @var UserInterestBuilderInterface
  40. */
  41. protected $userInterestBuilder;
  43. /**
  44. * @var LoggerInterface
  45. */
  46. protected $logger;
  48. public function __construct(
  49. EntityManagerInterface $em,
  50. UserInterestManager $userInterestManager,
  51. FeatureToggleManager $featureToggleManager,
  52. LeadService $leadService,
  53. UserInterestBuilderInterface $userInterestBuilder,
  54. LoggerInterface $logger,
  55. private readonly BuyerAlertsManager $buyerAlertsManager,
  56. ) {
  57. $this->em = $em;
  58. $this->userInterestManager = $userInterestManager;
  59. $this->featureToggleManager = $featureToggleManager;
  60. $this->leadService = $leadService;
  61. $this->userInterestBuilder = $userInterestBuilder;
  62. $this->logger = $logger;
  63. }
  65. public function onAddInteraction(userInterestEvent $event): void
  66. {
  67. $userInterest = $event->getUserInterest();
  68. $this->em->persist($userInterest);
  69. $this->em->flush($userInterest);
  70. }
  72. public function onAddLead(LeadEvent $event): void
  73. {
  74. $listing = $event->getListing();
  76. if ($this->featureToggleManager->isEnabled('web.client.served.count')) {
  77. $this->leadService->publishUpdatingClientServedCount($listing->getUser()->getId());
  78. }
  80. try {
  81. $this->buyerAlertsManager->addNewRecentSearch(
  82. $event->getUser(),
  83. $listing->getLocation(),
  84. $listing->getSection(),
  85. $listing->getPropertyType(),
  86. $listing->getPrice(),
  87. null,
  88. $listing->getArea(),
  89. null
  90. );
  91. } catch (\Exception $e) {
  92. $this->logger->error('Search Listener: '.$e->getMessage());
  93. }
  94. }
  96. public function onCreateInterest(userInterestEvent $event): void
  97. {
  98. $userInterestManager = $this->userInterestManager;
  100. /** @var \Aqarmap\Bundle\ListingBundle\Entity\LocationRepository $locationRepo */
  101. $locationRepo = $this->em->getRepository(\Aqarmap\Bundle\ListingBundle\Entity\Location::class);
  103. if (!$event->getUserInterest()->getLocation()->getSearchable()
  104. ) {
  105. $location = null;
  106. $locations = $locationRepo->getPath($event->getUserInterest()->getLocation());
  107. arsort($locations);
  108. foreach ($locations as $treeLocation) {
  109. if ($treeLocation->getSearchable()) {
  110. $location = $treeLocation;
  111. break;
  112. }
  113. }
  114. if ($location) {
  115. if ($location != $event->getUserInterest()->getLocation()) {
  116. $userInterestManager->addNew(
  117. $event->getUserInterest()->getUser(),
  118. $location,
  119. $event->getUserInterest()->getSection(),
  120. $event->getUserInterest()->getPropertyType(),
  121. $event->getUserInterest()->getMaxPrice(),
  122. $event->getUserInterest()->getMinPrice(),
  123. true,
  124. false
  125. )
  126. ->commit();
  127. }
  128. }
  129. }
  130. }
  132. public static function getSubscribedEvents(): array
  133. {
  134. return [
  135. 'aqarmap.listing.message_submitted' => 'onAddLead',
  136. 'aqarmap.listing.call_requested' => 'onAddLead',
  137. 'aqarmap.listing.show_seller_number' => 'onAddLead',
  138. 'aqarmap.interest.create_non_searchable' => 'onCreateInterest',
  139. ];
  140. }
  141. }