src/Aqarmap/Bundle/ListingBundle/EventListener/ListingStatusListener.php line 330

  1. <?php
  3. namespace Aqarmap\Bundle\ListingBundle\EventListener;
  5. use App\Message\Listing\AfterChangeStatusMessage;
  6. use Aqarmap\Bundle\CreditBundle\Constant\CreditStatus;
  7. use Aqarmap\Bundle\CreditBundle\Contract\CreditManagerInterface;
  8. use Aqarmap\Bundle\CreditBundle\Entity\Credit;
  9. use Aqarmap\Bundle\ListingBundle\Constant\ListingActivityType;
  10. use Aqarmap\Bundle\ListingBundle\Constant\ListingCategories;
  11. use Aqarmap\Bundle\ListingBundle\Constant\ListingFeatures;
  12. use Aqarmap\Bundle\ListingBundle\Constant\ListingStatus;
  13. use Aqarmap\Bundle\ListingBundle\Document\ListingActivityLog;
  14. use Aqarmap\Bundle\ListingBundle\Entity\Listing;
  15. use Aqarmap\Bundle\ListingBundle\Event\ListingEvent;
  16. use Aqarmap\Bundle\ListingBundle\Message\ListingDeleted;
  17. use Aqarmap\Bundle\ListingBundle\Service\ListingManager;
  18. use Aqarmap\Bundle\ListingBundle\Service\ListingRuleMatcher;
  19. use Aqarmap\Bundle\ListingBundle\Service\SpecialAddListingService;
  20. use Aqarmap\Bundle\MainBundle\Adapter\MailerServiceInterface;
  21. use Aqarmap\Bundle\MainBundle\Constant\ActivityType;
  22. use Aqarmap\Bundle\MainBundle\Constant\Locales;
  23. use Aqarmap\Bundle\MainBundle\Helpers\MailerHelper;
  24. use Aqarmap\Bundle\MainBundle\Service\ActivityLogger;
  25. use Aqarmap\Bundle\NotificationBundle\Types\ListingHasExpired;
  26. use Aqarmap\Bundle\UserBundle\Constant\UserTypes;
  27. use Aqarmap\Bundle\UserBundle\Entity\User;
  28. use Doctrine\Common\Collections\ArrayCollection;
  29. use Doctrine\ODM\MongoDB\DocumentManager;
  30. use Doctrine\ORM\EntityManagerInterface;
  31. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  32. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  33. use Symfony\Component\Messenger\MessageBusInterface;
  34. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  35. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  36. use Symfony\Contracts\Translation\TranslatorInterface;
  37. use Twig\Environment;
  39. class ListingStatusListener implements EventSubscriberInterface
  40. {
  41. /**
  42. * @var MailerServiceInterface
  43. */
  44. protected $mailer;
  46. /**
  47. * Constructor.
  48. */
  49. public function __construct(
  50. MailerServiceInterface $mailer,
  51. private readonly EntityManagerInterface $entityManager,
  52. private readonly TokenStorageInterface $tokenStorage,
  53. private readonly ListingRuleMatcher $listingRuleMatcher,
  54. private readonly CreditManagerInterface $creditManager,
  55. private readonly ActivityLogger $activityLogger,
  56. private readonly EventDispatcherInterface $eventDispatcher,
  57. private readonly TranslatorInterface $translator,
  58. private readonly ListingManager $listingManager,
  59. private readonly Environment $engine,
  60. private readonly MailerHelper $mailerHelper,
  61. private readonly ParameterBagInterface $parameterBag,
  62. private readonly SpecialAddListingService $specialAddListingService,
  63. private readonly MessageBusInterface $messageBus,
  64. private readonly DocumentManager $documentManager,
  65. ) {
  66. $this->mailer = $mailer;
  67. }
  69. public function preSaveListingEvent(ListingEvent $event): void
  70. {
  71. $listing = $event->getListing();
  72. if (null === $listing->getStatus()) {
  73. $this->getListingManager()->changeStatus($listing, ListingStatus::DRAFT, false);
  74. }
  75. }
  77. public function onSubmittedEvent(ListingEvent $event): void
  78. {
  79. $listing = $event->getListing();
  81. // Add or edit status
  82. $isDraftOrLive = \in_array($listing->getStatus(), [
  83. ListingStatus::DRAFT,
  84. ListingStatus::LIVE,
  85. ListingStatus::REJECTED,
  86. ]);
  88. // Checking the title to prevent in-complete listings (multi-steps form) from being approved
  89. if ($isDraftOrLive && !empty($listing->getTitle())) {
  90. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING, true);
  91. }
  93. if ($this->specialAddListingService->hasSpecialAddListingGroup($listing->getUser())
  94. && ListingStatus::PENDING_PAYMENT === $listing->getStatus()
  95. && $listing->getSpecialPublicationCredit()
  96. ) {
  97. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING, true);
  98. }
  99. }
  101. public function onListingPublishEvent(ListingEvent $event): void
  102. {
  103. $listing = $event->getListing();
  104. $user = $listing->getUser();
  106. // unsetting pending payment and photos statuses
  107. $listing->setPendingPaymentStatus(null);
  108. $listing->setPendingPhotosStatus(null);
  110. // If no publish did already or the listing is expired and being relisted give it a bump
  111. if (!$listing->getPublishedAt() || ListingStatus::EXPIRED == $listing->getStatus()) {
  112. $listing->setPublishedAt(new \DateTime());
  113. }
  115. $em = $this->entityManager;
  116. $userListingsCount = $em->getRepository(Listing::class)
  117. ->getUserListingsCountByStatus($user, [ListingStatus::LIVE]);
  118. $token = $this->tokenStorage->getToken();
  120. // Only flag if user has more than 3 listings and he is not already flagged
  121. if ($token
  122. && !$user->hasRole('ROLE_IN_HOUSE')
  123. && $userListingsCount >= 2
  124. && UserTypes::INDIVIDUAL == $user->getUserType()
  125. ) {
  126. $user->setUserType(UserTypes::BROKER);
  127. $em->persist($user);
  128. $em->flush($user);
  129. }
  131. $listing->addRejections(new ArrayCollection());
  132. }
  134. public function onListingPublishForFreeEvent(ListingEvent $event): void
  135. {
  136. $listing = $event->getListing();
  137. $listingRules = $this->listingRuleMatcher->match($listing);
  138. if ($listingRules['publication_fees']) {
  139. $creditManager = $this->creditManager;
  140. $credits = $creditManager->deduction($listing->getUser(), (float) 0, 'Free publishing', CreditStatus::SUCCESS);
  142. foreach ($credits as $credit) {
  143. if ($credit instanceof Credit) {
  144. $this->getListingManager()->addFeature($listing, ListingFeatures::PAID, null, $credit);
  145. }
  146. }
  148. // Record this action in the activity logger with the acting user
  149. if (ListingCategories::SCRAPPED != $listing->getCategory()) {
  150. $actor = $this->tokenStorage->getToken()?->getUser();
  151. if (!$actor instanceof User) {
  152. $actor = $listing->getUser();
  153. }
  155. $this->activityLogger->record(ActivityType::LISTING_FREE_PUBLISH, $actor, $listing->getId());
  156. }
  157. }
  158. }
  160. public function onPublishedForFreeEmailEvent(ListingEvent $event): void
  161. {
  162. $listing = $event->getListing();
  163. $originalLocale = $this->getTranslator()->getLocale();
  164. $this->getTranslator()->setLocale($this->getListingLanguage($listing));
  165. $template = '@AqarmapListingBundle/Admin/Email/listingApprovedForFree.html.twig';
  166. $templateContext = ['listing' => $listing];
  167. $compose = $this->getComposeMessage($listing, $template, $templateContext, 'listings-free-publish');
  168. $this->getMailer()->sendMessage($compose);
  169. $this->getTranslator()->setLocale($originalLocale);
  170. }
  172. /**
  173. * Unset DeletedAt date on undelete event.
  174. */
  175. public function onListingUndeleteEvent(ListingEvent $event): void
  176. {
  177. $listing = $event->getListing();
  178. $listing->setDeletedAt(null);
  179. }
  181. /**
  182. * Refund listing credit on delete event.
  183. */
  184. public function onListingDeleteEvent(ListingEvent $event): void
  185. {
  186. $listing = $event->getListing();
  187. $listingFeatured = $listing->getNotExpiredCredit();
  189. /*
  190. Refund Policy,
  191. listings should have paid features that are not expired yet,
  192. Also the listing should never been published before.
  193. */
  194. if (!empty($listingFeatured) && !$listing->getPublishedAt()) {
  195. foreach ((array) $listingFeatured as $listingFees) {
  196. $credits[] = $listingFees->getCredit();
  197. }
  199. $creditManager = $this->creditManager;
  201. $em = $this->getEntityManager();
  203. foreach ($credits as $credit) {
  204. if ($credit->canBeCancelled()) {
  205. $creditManager->deposit($credit->getUser(), -$credit->getAmount(), CreditStatus::SUCCESS, CreditStatus::REFUND_LABEL);
  206. $credit->setStatus(CreditStatus::REFUND);
  207. $em->persist($credit);
  208. }
  209. }
  210. $em->flush();
  211. }
  213. $listing->setDeletedAt(new \DateTime());
  214. }
  216. /**
  217. * Refund listing credit on delete event.
  218. */
  219. public function onListingStatusDeleteEvent(ListingEvent $event): void
  220. {
  221. $this->messageBus->dispatch(new ListingDeleted($event->getListing()));
  222. }
  224. public function onApprovedSendEmailEvent(ListingEvent $event): void
  225. {
  226. $listing = $event->getListing();
  227. $originalLocale = $this->getTranslator()->getLocale();
  228. $this->getTranslator()->setLocale($this->getListingLanguage($listing));
  229. $template = '@AqarmapListingBundle/Admin/Email/listingApproved.html.twig';
  230. $templateContext = ['listing' => $listing];
  231. $compose = $this->getComposeMessage($listing, $template, $templateContext, 'listings-approval');
  232. $this->getMailer()->sendMessage($compose);
  233. $this->getTranslator()->setLocale($originalLocale);
  234. }
  236. public function onListingExpiredEvent(ListingEvent $event): void
  237. {
  238. $listing = $event->getListing();
  239. $this->eventDispatcher
  240. ->dispatch((new ListingHasExpired())->setSubject($listing), 'listing.has.expired');
  241. }
  243. public function onListingPhotosDeleted(ListingEvent $event): void
  244. {
  245. $listing = $event->getListing();
  246. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING_PHOTOS, true);
  247. }
  249. /**
  250. * @return object
  251. */
  252. public function getEntityManager()
  253. {
  254. return $this->entityManager;
  255. }
  257. /**
  258. * @return MailerServiceInterface
  259. */
  260. public function getMailer()
  261. {
  262. return $this->mailer;
  263. }
  265. /**
  266. * @return \Symfony\Component\Translation\LoggingTranslator
  267. */
  268. public function getTranslator()
  269. {
  270. return $this->translator;
  271. }
  273. public function getTemplating()
  274. {
  275. return $this->engine;
  276. }
  278. public function changeListingWaitingTime(ListingEvent $event): void
  279. {
  280. $now = new \DateTime();
  281. $listing = $event->getListing();
  282. $activityRepo = $this->documentManager->getRepository(ListingActivityLog::class);
  283. $lastActivityWaitingTime = $activityRepo->getLastActivity($listing->getId(), ListingActivityType::PENDING_APPROVAL);
  284. $listing->setWaitingTime($lastActivityWaitingTime ? $now->getTimestamp() - $lastActivityWaitingTime->getCreatedAt()->getTimestamp() : null);
  286. $this->entityManager->persist($listing);
  287. $this->entityManager->flush();
  288. }
  290. public function onListingStatusPendingEvent(ListingEvent $event): void
  291. {
  292. $listing = $event->getListing();
  294. if (!$listing->getPendingStatusCreatedAt() && !$event->getIsAdmin()) {
  295. $listing->setPendingStatusCreatedAt(new \DateTime());
  296. }
  298. $listing->setAutoReviewedAt(null);
  299. }
  301. public function onListingStatusChangedEvent(ListingEvent $event): void
  302. {
  303. $listing = $event->getListing();
  304. if ($listing->getId()) {
  305. $this->messageBus->dispatch(new AfterChangeStatusMessage($listing->getId()));
  306. }
  307. }
  309. public static function getSubscribedEvents(): array
  310. {
  311. return [
  312. 'aqarmap.listing.pre_save' => ['preSaveListingEvent'],
  313. 'aqarmap.listing.publish' => [
  314. ['onListingPublishEvent', 100], ['changeListingWaitingTime'],
  315. ],
  316. 'aqarmap.listing.submitted' => ['onSubmittedEvent', 100],
  317. 'aqarmap.listing.expired' => ['onListingExpiredEvent'],
  318. 'aqarmap.listing.undelete' => ['onListingUndeleteEvent'],
  319. 'aqarmap.listing.delete' => [['onListingStatusDeleteEvent'], ['onListingDeleteEvent']],
  320. 'aqarmap.listing.delete_by_user' => ['onListingStatusDeleteEvent'],
  321. 'aqarmap.listing.free_publish' => [
  322. ['onListingPublishForFreeEvent'], ['onListingPublishEvent'], ['onPublishedForFreeEmailEvent'],
  323. ],
  324. 'aqarmap.listing.publish_without_photos' => [
  325. ['onListingPublishForFreeEvent'], ['onListingPublishEvent'],
  326. ],
  327. 'aqarmap.listing.photos_deleted' => ['onListingPhotosDeleted'],
  328. 'aqarmap.listing.rejected' => ['changeListingWaitingTime'],
  329. 'aqarmap.listing.pending_approval' => ['onListingStatusPendingEvent'],
  330. 'aqarmap.listing.after_change_status' => ['onListingStatusChangedEvent'],
  331. ];
  332. }
  334. /**
  335. * @return ListingManager
  336. */
  337. protected function getListingManager()
  338. {
  339. return $this->listingManager;
  340. }
  342. private function getComposeMessage($listing, $template, $templateContext, $headerCategory)
  343. {
  344. $composeMessage = $this->mailerHelper->createMessageWithGlobalAttributes();
  345. $composeMessage->setSubject($this->getTranslator()->trans('email.subject.listing_approved'));
  346. $composeMessage->setTo($listing->getUser()->getEmailCanonical());
  347. $composeMessage->setReplyTo($listing->getUser()->getEmailCanonical());
  348. $composeMessage->setTemplate($template);
  349. $composeMessage->setTemplateContext($templateContext);
  351. $compose = $this->getMailer()->composeMessage($composeMessage);
  353. $compose->getHeaders()->addTextHeader('X-Mail-Category', $headerCategory);
  354. $compose->getHeaders()->addTextHeader('X-Site-Country', $this->parameterBag->get('country'));
  356. return $compose;
  357. }
  359. private function getListingLanguage($listing)
  360. {
  361. $language = Locales::AR;
  363. if (null !== $listing->getUser()->getLanguage()) {
  364. $language = $listing->getUser()->getLanguage();
  365. }
  367. return $language;
  368. }
  369. }