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

Open in your IDE?
  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.     /** @var BuyerAlertsManager */
  49.     private $buyerAlertsManager;
  51.     public function __construct(
  52.         EntityManagerInterface $em,
  53.         UserInterestManager $userInterestManager,
  54.         FeatureToggleManager $featureToggleManager,
  55.         LeadService $leadService,
  56.         UserInterestBuilderInterface $userInterestBuilder,
  57.         LoggerInterface $logger,
  58.         BuyerAlertsManager $buyerAlertsManager
  59.     ) {
  60.         $this->em = $em;
  61.         $this->userInterestManager = $userInterestManager;
  62.         $this->featureToggleManager = $featureToggleManager;
  63.         $this->leadService = $leadService;
  64.         $this->userInterestBuilder = $userInterestBuilder;
  65.         $this->logger = $logger;
  66.         $this->buyerAlertsManager = $buyerAlertsManager;
  67.     }
  69.     public function onAddInteraction(userInterestEvent $event): void
  70.     {
  71.         $userInterest = $event->getUserInterest();
  72.         $this->em->persist($userInterest);
  73.         $this->em->flush($userInterest);
  74.     }
  76.     public function onAddLead(LeadEvent $event): void
  77.     {
  78.         $listing = $event->getListing();
  80.         if ($this->featureToggleManager->isEnabled('web.client.served.count')) {
  81.             $this->leadService->publishUpdatingClientServedCount($listing->getUser()->getId());
  82.         }
  84.         try {
  85.             $this->buyerAlertsManager->addNewRecentSearch(
  86.                 $event->getUser(),
  87.                 $listing->getLocation(),
  88.                 $listing->getSection(),
  89.                 $listing->getPropertyType(),
  90.                 $listing->getPrice(),
  91.                 null,
  92.                 $listing->getArea(),
  93.                 null
  94.             );
  95.         } catch (\Exception $e) {
  96.             $this->logger->error('Search Listener: '.$e->getMessage());
  97.         }
  98.     }
  100.     public function onCreateInterest(userInterestEvent $event): void
  101.     {
  102.         $userInterestManager = $this->userInterestManager;
  104.         /** @var $locationRepo \Aqarmap\Bundle\ListingBundle\Entity\LocationRepository */
  105.         $locationRepo = $this->em->getRepository(\Aqarmap\Bundle\ListingBundle\Entity\Location::class);
  107.         if (!$event->getUserInterest()->getLocation()->getSearchable()
  108.         ) {
  109.             $location = null;
  110.             $locations = $locationRepo->getPath($event->getUserInterest()->getLocation());
  111.             arsort($locations);
  112.             foreach ($locations as $treeLocation) {
  113.                 if ($treeLocation->getSearchable()) {
  114.                     $location = $treeLocation;
  115.                     break;
  116.                 }
  117.             }
  118.             if ($location) {
  119.                 if ($location != $event->getUserInterest()->getLocation()) {
  120.                     $userInterestManager->addNew(
  121.                         $event->getUserInterest()->getUser(),
  122.                         $location,
  123.                         $event->getUserInterest()->getSection(),
  124.                         $event->getUserInterest()->getPropertyType(),
  125.                         $event->getUserInterest()->getMaxPrice(),
  126.                         $event->getUserInterest()->getMinPrice(),
  127.                         true,
  128.                         false
  129.                     )
  130.                         ->commit();
  131.                 }
  132.             }
  133.         }
  134.     }
  136.     public static function getSubscribedEvents()
  137.     {
  138.         return [
  139.             'aqarmap.listing.message_submitted' => 'onAddLead',
  140.             'aqarmap.listing.call_requested' => 'onAddLead',
  141.             'aqarmap.listing.show_seller_number' => 'onAddLead',
  142.             'aqarmap.interest.create_non_searchable' => 'onCreateInterest',
  143.         ];
  144.     }
  145. }