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

  1. <?php
  3. namespace Aqarmap\Bundle\ListingBundle\EventListener;
  5. use App\Message\ProcessEmailBodyMessage;
  6. use Aqarmap\Bundle\ListingBundle\Constant\LeadTypes;
  7. use Aqarmap\Bundle\ListingBundle\Event\LeadEvent;
  8. use Aqarmap\Bundle\ListingBundle\Model\LeadModel;
  9. use Aqarmap\Bundle\ListingBundle\Service\LeadService;
  10. use Aqarmap\Bundle\MainBundle\Constant\ProcessEmailBodyTypes;
  11. use Aqarmap\Bundle\MainBundle\Model\MailUtilitiesModel;
  12. use Aqarmap\Bundle\UserBundle\Entity\User;
  13. use Doctrine\ORM\EntityManagerInterface;
  14. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Component\Messenger\MessageBusInterface;
  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 MessageBusInterface $bus,
  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. $this->bus->dispatch(new ProcessEmailBodyMessage(
  114. ProcessEmailBodyTypes::SHOW_PHONE_NUMBER_MAILS,
  115. [
  116. 'template' => '@AqarmapListingBundle/Lead/Email/show_phone.html.twig',
  117. 'subject' => $mailUtilities->getSubject(),
  118. 'from' => $mailUtilities->getFrom(),
  119. 'reply_to' => $mailUtilities->getReplyTo(),
  120. 'to' => $mailUtilities->getTo(),
  121. 'text_headers' => $mailUtilities->getTextHeaders(),
  122. 'data' => [
  123. 'listing' => $listing->getId(),
  124. 'user' => $user instanceof User ? $user->getId() : null,
  125. 'lead' => $lead->getId(),
  126. 'leads_insights_enabled' => $leadsInsightsEnabled,
  127. 'participant' => $participant->getId(),
  128. ],
  129. ]
  130. ));
  131. }
  132. }
  133. }
  135. /**
  136. * @return MailUtilitiesModel
  137. */
  138. private function buildMailUtilities(MailUtilitiesModel $mailUtility)
  139. {
  140. $subject = ucfirst($this->translator->trans('phone_call_email.subject', [
  141. '%user_name%' => $mailUtility->getSubject(),
  142. ], 'emails'));
  144. // check if name start with user+Number change subject in email
  145. if ('user+' == substr((string) $mailUtility->getSubject(), self::USERNAME_FIRST_LETTER_INDEX, self::USERNAME_LAST_LETTER_INDEX)) {
  146. $subject = ucfirst($this->translator->trans('phone_call_email.subject_without_name', [], 'emails'));
  147. }
  149. $from = [$this->parameterBag->get('website_email') => $this->translator->trans('layout.app_name')];
  150. $textHeaders = ['X-Mail-Category' => 'listings-lead-show-phone', 'X-Site-Country' => $this->parameterBag->get('country')];
  152. $mailUtility->setSubject($subject);
  153. $mailUtility->setFrom($from);
  154. $mailUtility->setTextHeaders($textHeaders);
  156. return $mailUtility;
  157. }
  159. public static function getSubscribedEvents(): array
  160. {
  161. return [
  162. 'aqarmap.listing.message_submitted' => 'onContactSeller',
  163. 'aqarmap.listing.show_seller_number' => 'onShowPhoneNumber',
  164. ];
  165. }
  166. }