src/Aqarmap/Bundle/ListingBundle/EventListener/NotifierSubscribeListener.php line 64

  1. <?php
  3. namespace Aqarmap\Bundle\ListingBundle\EventListener;
  5. use Aqarmap\Bundle\BuyerAlertsBundle\Service\BuyerAlertsManager;
  6. use Aqarmap\Bundle\ListingBundle\Entity\Location;
  7. use Aqarmap\Bundle\ListingBundle\Entity\PropertyType;
  8. use Aqarmap\Bundle\ListingBundle\Entity\Section;
  9. use Aqarmap\Bundle\ListingBundle\Event\LeadEvent;
  10. use Aqarmap\Bundle\ListingBundle\Event\SearchTriggerEvent;
  11. use Aqarmap\Bundle\ListingBundle\Event\SearchTriggerInterface;
  12. use Aqarmap\Bundle\ListingBundle\Repository\PropertyTypeRepository;
  13. use Aqarmap\Bundle\NotifierBundle\Service\NotifierManager;
  14. use Aqarmap\Bundle\UserBundle\Entity\User;
  15. use Doctrine\ORM\EntityManagerInterface;
  16. use Psr\Log\LoggerInterface;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\HttpFoundation\Request;
  19. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  21. class NotifierSubscribeListener implements EventSubscriberInterface
  22. {
  23. /**
  24. * @var EntityManagerInterface
  25. */
  26. protected $em;
  28. protected $notifierManager;
  30. /** @var UserInterface */
  31. protected $user;
  33. public function __construct(
  34. EntityManagerInterface $em,
  35. NotifierManager $notifierManager,
  36. TokenStorageInterface $tokenStorage,
  37. private readonly LoggerInterface $logger,
  38. private readonly BuyerAlertsManager $buyerAlertsManager,
  39. private readonly PropertyTypeRepository $propertyTypeRepository,
  40. ) {
  41. $this->em = $em;
  42. $this->notifierManager = $notifierManager;
  43. $this->user = $tokenStorage->getToken() ? $tokenStorage->getToken()->getUser() : null;
  44. }
  46. public function onAddLead(LeadEvent $event): void
  47. {
  48. $listing = $event->getListing();
  50. $this->buyerAlertsManager->addNewRecentSearch(
  51. $event->getUser(),
  52. $listing->getLocation(),
  53. $listing->getSection(),
  54. $listing->getPropertyType(),
  55. $listing->getPrice() ?: null,
  56. null,
  57. $listing->getArea() ?: null,
  58. null
  59. );
  60. }
  62. /**
  63. * Update Notifier.
  64. */
  65. public function updateNotifier(SearchTriggerInterface $event): void
  66. {
  67. $item = $this->prepareData($event->getRequest());
  69. if ($this->user instanceof User && $item) {
  70. try {
  71. $this->buyerAlertsManager->addNewRecentSearch(
  72. $this->user,
  73. $item['location'],
  74. $item['section'],
  75. $item['propertyType'],
  76. $item['maxPrice'],
  77. $item['minPrice']
  78. );
  79. } catch (\Exception $e) {
  80. if ($this->user && $this->user->hasRole('ROLE_ADMIN')) {
  81. $this->logger->error('Search Listener: '.$e->getMessage());
  82. }
  83. }
  84. }
  85. }
  87. /**
  88. * Prepares notifier data.
  89. *
  90. * @return array
  91. */
  92. private function prepareData(Request $request)
  93. {
  94. $location = $request->attributes->get('location') ?? (int) current(
  95. explode(',', (string) $request->query->get('location'))
  96. );
  98. if (!$location) {
  99. return;
  100. }
  102. $locationEntity = (
  103. $location instanceof Location
  104. )
  105. ? $location
  106. : $this->em->getReference(Location::class, $location);
  108. $sectionEntity = null;
  109. $propertyTypeEntity = null;
  111. if ($sectionId = $request->query->get('section')) {
  112. $sectionEntity = $this->em->getReference(Section::class, $sectionId);
  113. }
  115. if ($propertyTypeId = $request->query->get('propertyType')) {
  116. $propertyTypeEntity = $this->em->getReference(PropertyType::class, $propertyTypeId);
  117. }
  119. if (null === $request->query->get('propertyType')) {
  120. $propertyTypeEntity = $this->propertyTypeRepository
  121. ->getRootNodesQuery()
  122. ->getOneOrNullResult();
  123. }
  125. return [
  126. 'location' => $locationEntity,
  127. 'section' => $sectionEntity ?? $request->attributes->get('section'),
  128. 'propertyType' => $propertyTypeEntity ?? $request->attributes->get('propertyType'),
  129. 'maxPrice' => (int) $request->query->get('maxPrice'),
  130. 'minPrice' => (int) $request->query->get('minPrice'),
  131. ];
  132. }
  134. public static function getSubscribedEvents(): array
  135. {
  136. return [
  137. 'aqarmap.listing.message_submitted' => 'onAddLead',
  138. 'aqarmap.listing.call_requested' => 'onAddLead',
  139. 'aqarmap.listing.show_seller_number' => 'onAddLead',
  140. SearchTriggerEvent::EVENT_NAME => 'updateNotifier',
  141. ];
  142. }
  143. }