src/Aqarmap/Bundle/ListingBundle/EventListener/LeadSubscribeListener.php line 71

  1. <?php
  3. namespace Aqarmap\Bundle\ListingBundle\EventListener;
  5. use Aqarmap\Bundle\ListingBundle\Constant\LeadTypes;
  6. use Aqarmap\Bundle\ListingBundle\Event\LeadEvent;
  7. use Aqarmap\Bundle\ListingBundle\Model\LeadModel;
  8. use Aqarmap\Bundle\ListingBundle\Service\LeadService;
  9. use Aqarmap\Bundle\MainBundle\Constant\ProcessEmailBodyTypes;
  10. use Aqarmap\Bundle\MainBundle\Constant\ProducerQueues;
  11. use Aqarmap\Bundle\MainBundle\Contract\ProducerFactoryInterface;
  12. use Aqarmap\Bundle\MainBundle\Model\MailUtilitiesModel;
  13. use Aqarmap\Bundle\UserBundle\Entity\User;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  18. use Symfony\Contracts\Translation\TranslatorInterface;
  20. class LeadSubscribeListener implements EventSubscriberInterface
  21. {
  22. public const USERNAME_FIRST_LETTER_INDEX = 0;
  23. public const USERNAME_LAST_LETTER_INDEX = 5;
  25. /**
  26. * @var EntityManagerInterface
  27. */
  28. protected $em;
  30. /**
  31. * @var LeadService
  32. */
  33. protected $leadService;
  35. /**
  36. * @var ParameterBagInterface
  37. */
  38. protected $parameterBagInterface;
  40. public function __construct(
  41. EntityManagerInterface $em,
  42. LeadService $leadService,
  43. ParameterBagInterface $parameterBag,
  44. private readonly TokenStorageInterface $tokenStorage,
  45. private readonly TranslatorInterface $translator,
  46. private readonly ProducerFactoryInterface $producerFactory,
  47. ) {
  48. $this->em = $em;
  49. $this->leadService = $leadService;
  50. $this->parameterBag = $parameterBag;
  51. }
  53. public function onContactSeller(LeadEvent $event): void
  54. {
  55. if (null != $event->getSource()
  56. && \in_array($event->getSource(), [LeadTypes::TARGET_USER_MESSAGE, LeadTypes::USER_DOMAIN_MESSAGE])
  57. ) {
  58. return;
  59. }
  60. $source = 'message-subscriber';
  62. $leadModel = new LeadModel();
  64. $leadModel->setLeadType(LeadTypes::SEND_MESSAGE);
  65. $leadModel->setListing($event->getListing());
  66. $leadModel->setUser($event->getUser());
  67. $leadModel->setSource($source);
  68. $leadModel->setCampaign($event->getCampaign());
  70. $this->leadService->addLead($leadModel, true);
  71. }
  73. public function onShowPhoneNumber(LeadEvent $event): void
  74. {
  75. $listing = $event->getListing();
  76. $lead = $event->getLead();
  78. // Check user listing role
  79. if ($listing->getParent() && $listing->getParent()->getSection()->getSearchable()) {
  80. return;
  81. }
  83. $token = $this->tokenStorage->getToken();
  85. $user = $token ?: null;
  87. if (!$user instanceof User) {
  88. $user = $lead->getUser();
  89. }
  91. $leadsInsightsEnabled = true;
  93. /** @var User $participant */
  94. foreach ($listing->getAllParticipants() as $participant) {
  95. if ($lead
  96. && (!$listing->getSection()->getSearchable() || $listing->getParent())) {
  97. $leadsInsightsEnabled = true;
  98. $user = $lead->getUser();
  99. }
  101. $subjectUsername = $lead->getFullName() ?: $user->getUsername();
  103. $mailUtility = new MailUtilitiesModel();
  104. $mailUtility->setSubject($subjectUsername);
  105. $mailUtility->setReplyTo([$listing->getUser()->getEmailCanonical()]);
  106. $mailUtility->setTo([$participant->getEmailCanonical()]);
  108. $this->translator->setLocale($participant->getLanguage() ?? $this->parameterBag->get('locale'));
  110. if ($user->getMainNumber() && 'undefined' != $user->getMainNumber()->getPhone()->getNumber()
  111. || 'undefined' != $lead->getPhone()->getNumber() || 'undefined' != $lead->getEmail()) {
  112. $mailUtilities = $this->buildMailUtilities($mailUtility);
  113. $producerFactory = $this->producerFactory;
  114. $producer = $producerFactory->create(ProducerQueues::PROCESS_EMAIL_BODY);
  116. $producer->publish(serialize([ProducerQueues::PROCESS_EMAIL_BODY_KEY => [
  117. 'type' => ProcessEmailBodyTypes::SHOW_PHONE_NUMBER_MAILS,
  118. 'template' => '@AqarmapListingBundle/Lead/Email/show_phone.html.twig',
  119. 'subject' => $mailUtilities->getSubject(),
  120. 'from' => $mailUtilities->getFrom(),
  121. 'reply_to' => $mailUtilities->getReplyTo(),
  122. 'to' => $mailUtilities->getTo(),
  123. 'text_headers' => $mailUtilities->getTextHeaders(),
  124. 'data' => [
  125. 'listing' => $listing->getId(),
  126. 'user' => $user instanceof User ? $user->getId() : null,
  127. 'lead' => $lead->getId(),
  128. 'leads_insights_enabled' => $leadsInsightsEnabled,
  129. 'participant' => $participant->getId(),
  130. ],
  131. ],
  132. ]));
  133. }
  134. }
  135. }
  137. /**
  138. * @return MailUtilitiesModel
  139. */
  140. private function buildMailUtilities(MailUtilitiesModel $mailUtility)
  141. {
  142. $subject = ucfirst($this->translator->trans('phone_call_email.subject', [
  143. '%user_name%' => $mailUtility->getSubject(),
  144. ], 'emails'));
  146. // check if name start with user+Number change subject in email
  147. if ('user+' == substr((string) $mailUtility->getSubject(), self::USERNAME_FIRST_LETTER_INDEX, self::USERNAME_LAST_LETTER_INDEX)) {
  148. $subject = ucfirst($this->translator->trans('phone_call_email.subject_without_name', [], 'emails'));
  149. }
  151. $from = [$this->parameterBag->get('website_email') => $this->translator->trans('layout.app_name')];
  152. $textHeaders = ['X-Mail-Category' => 'listings-lead-show-phone', 'X-Site-Country' => $this->parameterBag->get('country')];
  154. $mailUtility->setSubject($subject);
  155. $mailUtility->setFrom($from);
  156. $mailUtility->setTextHeaders($textHeaders);
  158. return $mailUtility;
  159. }
  161. public static function getSubscribedEvents(): array
  162. {
  163. return [
  164. 'aqarmap.listing.message_submitted' => 'onContactSeller',
  165. 'aqarmap.listing.show_seller_number' => 'onShowPhoneNumber',
  166. ];
  167. }
  168. }