src/Aqarmap/Bundle/ListingBundle/EventListener/ListingRuleListener.php line 218

  1. <?php
  3. namespace Aqarmap\Bundle\ListingBundle\EventListener;
  5. use App\Constant\LabelCode;
  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\ListingCategories;
  10. use Aqarmap\Bundle\ListingBundle\Constant\ListingFeaturedStatus;
  11. use Aqarmap\Bundle\ListingBundle\Constant\ListingSource;
  12. use Aqarmap\Bundle\ListingBundle\Constant\ListingStatus;
  13. use Aqarmap\Bundle\ListingBundle\Entity\Listing;
  14. use Aqarmap\Bundle\ListingBundle\Event\ListingEvent;
  15. use Aqarmap\Bundle\ListingBundle\Service\Contracts\ListingFeatureServiceInterface;
  16. use Aqarmap\Bundle\ListingBundle\Service\ListingFeatureService;
  17. use Aqarmap\Bundle\ListingBundle\Service\ListingManager;
  18. use Aqarmap\Bundle\ListingBundle\Service\ListingRuleMatcher;
  19. use Doctrine\ORM\EntityManagerInterface;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. use Symfony\Component\HttpFoundation\RedirectResponse;
  22. use Symfony\Component\HttpFoundation\RequestStack;
  23. use Symfony\Component\Routing\RouterInterface;
  24. use Symfony\Contracts\Translation\TranslatorInterface;
  26. class ListingRuleListener implements EventSubscriberInterface
  27. {
  28. public function __construct(
  29. private readonly ListingRuleMatcher $listingRuleMatcher,
  30. private readonly CreditManagerInterface $creditManager,
  31. private readonly ListingManager $listingManager,
  32. private readonly EntityManagerInterface $entityManager,
  33. private readonly ListingFeatureServiceInterface $listingFeatureService,
  34. private readonly RequestStack $requestStack,
  35. private readonly TranslatorInterface $translator,
  36. private readonly RouterInterface $router,
  37. ) {
  38. }
  40. public function preSaveListingEvent(ListingEvent $event): void
  41. {
  42. $listing = $event->getListing();
  44. if (
  45. !$listing->isDraft()
  46. && !$listing->isLive()
  47. && ListingCategories::FIRST_LISTING_FOR_FREE === $listing->getCategory()
  48. ) {
  49. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING, false);
  51. return;
  52. }
  54. $publicationCredit = $listing->getPublicationCredit();
  56. /** @var ListingRuleMatcher $matcher */
  57. $matcher = $this->listingRuleMatcher;
  58. $listingRule = $matcher->match($listing);
  60. $listingRulesRequirePhotos = ($listingRule['required_photos'] && $listing->getPhotos()->count() < $listingRule['required_photos']);
  61. $listingHasTitle = $listing->getTitle();
  63. if ($listingRulesRequirePhotos && $listingHasTitle) {
  64. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING_PHOTOS);
  65. }
  67. if (
  68. !$listing->isDraft()
  69. && !$listing->isLive()
  70. && !$listing->isProjectOrUnit()
  71. && ListingStatus::PENDING != $listing->getStatus()
  72. && ListingStatus::PENDING_PAYMENT != $listing->getStatus()
  73. && $listing->getPhotos()->count() >= $listingRule['required_photos']
  74. ) {
  75. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING_PAYMENT, false);
  76. }
  78. // If the listing is PENDING_PAYMENT, and the user already paid the fees
  79. if (ListingStatus::PENDING_PAYMENT === $listing->getStatus()) {
  80. if ($publicationCredit) {
  81. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING, false);
  82. }
  83. }
  85. // ----------------------------------------------------------------------
  86. // Toggle the listing's category on location change.
  87. // ----------------------------------------------------------------------
  89. $isPaid = ListingCategories::PAID === $listing->getCategory();
  90. $isScrapped = ListingCategories::SCRAPPED === $listing->getCategory();
  91. $isUnlimited = ListingCategories::UNLIMITED === $listing->getCategory();
  93. if (!$isPaid && !$isScrapped && !$isUnlimited && $listingRule['publication_fees'] > 0) {
  94. $listing->setCategory(ListingCategories::PAID);
  95. if (ListingStatus::PENDING === $listing->getStatus() && !$publicationCredit) {
  96. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING_PAYMENT, false);
  97. }
  98. }
  100. if (
  101. !$isPaid && !$isScrapped && !$isUnlimited && $listingHasTitle && $listingRule['publication_fees'] <= 0
  102. && \in_array($listing->getStatus(), [ListingStatus::PENDING_PAYMENT, ListingStatus::DRAFT])
  103. ) {
  104. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING, false);
  105. }
  107. if ($isPaid && !$isScrapped && !$isUnlimited && $listingRule['publication_fees'] <= 0) {
  108. $listing->setCategory(ListingCategories::NORMAL);
  109. if (ListingStatus::PENDING_PAYMENT === $listing->getStatus()) {
  110. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING_PAYMENT, false);
  111. }
  112. }
  114. if ($this->getListingManager()->isListingUserEbawab($listing)) {
  115. $listing->setCategory(ListingCategories::EBAWAB);
  116. }
  118. if ($this->getListingManager()->isListingUserManualScraped($listing)) {
  119. $listing->setCategory(ListingCategories::SCRAPPED);
  120. $this->listingManager->addLabelByCode($listing, LabelCode::LISTING_SCRAPPED);
  121. }
  122. }
  124. public function onSubmittedEvent(ListingEvent $event): void
  125. {
  126. /** @var Listing $listing */
  127. $listing = $event->getListing();
  129. $matcher = $this->listingRuleMatcher;
  130. $listingRule = $matcher->match($listing);
  132. if (!$listingRule['flf2'] && ListingCategories::PAID === $listing->getCategory() && $this->listingManager->isEligibleForFreePublishing($listing)) {
  133. $this->listingManager->createFirstListingForFree($listing);
  134. }
  136. if (
  137. ListingSource::LITE == $listing->getSource()
  138. || ListingSource::SCRAPPING == $listing->getSource()
  139. || ListingCategories::FIRST_LISTING_FOR_FREE === $listing->getCategory()
  140. ) {
  141. return;
  142. }
  144. if ($listingRule['publication_fees'] > 0
  145. && $listing->getPhotos()->count() >= $listingRule['required_photos']
  146. && !$listing->getPublicationCredit()
  147. ) {
  148. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING_PAYMENT, true, true);
  149. }
  150. }
  152. public function onSubmittedStatusRedirectionEvent(ListingEvent $event): void
  153. {
  154. /** @var Listing $listing */
  155. $listing = $event->getListing();
  157. switch ($listing->getStatus()) {
  158. case ListingStatus::PENDING_PAYMENT:
  159. $event->setResponse($this->redirect(
  160. 'listing_confirm_publish_credit',
  161. ['id' => $listing->getId()]
  162. ));
  163. break;
  165. case ListingStatus::PENDING_PHOTOS:
  166. $this->setFlashMessage('info', $this->getTranslator()->trans('add_listing_page.success_messages.add_photos_message'));
  168. $event->setResponse($this->redirect(
  169. 'listing_upload',
  170. ['id' => $event->getListing()->getId()]
  171. ));
  172. break;
  173. }
  174. }
  176. /**
  177. * @throws \Exception
  178. */
  179. public function onListingPublishEvent(ListingEvent $event): void
  180. {
  181. $listing = $event->getListing();
  183. $listingPublishPaid = $listing->getPublicationCredit();
  184. $listingPublishFeatured = $listing->getFeaturedPublicationCredit();
  185. $listingRule = $this->listingRuleMatcher->match($listing);
  187. if (ListingCategories::FIRST_LISTING_FOR_FREE === $listing->getCategory()) {
  188. $listing->setExpiresAt(new \DateTime('+'.$listingRule['first_free_duration'].' days'));
  190. return;
  191. }
  193. if ($listingRule['duration'] && (!$listing->getExpiresAt() || new \DateTime() >= $listing->getExpiresAt())) {
  194. $listing->setExpiresAt(new \DateTime('+'.$listingRule['duration'].' days'));
  195. }
  197. if ($listingPublishPaid) {
  198. if (!$listingPublishPaid->getExpiresAt()) {
  199. $listingPublishPaid->setExpiresAt($listing->getExpiresAt());
  200. }
  201. }
  202. if ($listingPublishFeatured) {
  203. if (!$listingPublishFeatured->getExpiresAt() && !$listingPublishFeatured->getFeaturingStatus()) {
  204. $duration = $this->getListingFeaturingService()->getFeaturedTypeDuration($listingRule, $listingPublishFeatured->getType());
  205. $listingPublishFeatured->setExpiresAt(new \DateTime('+'.$duration.' days'));
  206. }
  207. }
  208. }
  210. public function onFeaturingListingApprovalEvent(ListingEvent $event): void
  211. {
  212. $listing = $event->getListing();
  213. $listingPublishFeatured = $listing->getFeaturedPublicationCredit();
  214. $listingManager = $this->getListingManager();
  215. $listingFeatureService = $this->getListingFeaturingService();
  216. $listingRule = $listingManager->getListingRules($listing);
  218. if ($listingPublishFeatured && ListingStatus::LIVE == $listing->getStatus()) {
  219. $listing->setFeatured($listingFeatureService->getListingFeaturedType($listingPublishFeatured->getType()));
  220. $listingPublishFeatured->setFeaturingStatus(ListingFeaturedStatus::APPROVED);
  221. $listingPublishFeatured->setApprovedAt(new \DateTime());
  223. if (!$listingPublishFeatured->getExpiresAt()) {
  224. $duration = $this->getListingFeaturingService()->getFeaturedTypeDuration($listingRule, $listingPublishFeatured->getType());
  225. $listingPublishFeatured->setExpiresAt(new \DateTime('+'.$duration.' days'));
  226. }
  227. }
  228. $em = $this->getEntityManager();
  229. $em->persist($listing);
  230. $em->flush();
  231. }
  233. /**
  234. * @throws \Exception
  235. */
  236. public function onFeaturingListingRejectEvent(ListingEvent $event): void
  237. {
  238. $listing = $event->getListing();
  239. $listingFeatured = $listing->getLastListingFeature();
  241. if (ListingStatus::LIVE == $listing->getStatus()) {
  242. $listingFeatured->setFeaturingStatus(ListingFeaturedStatus::REJECTED);
  243. $listingFeatured->setExpiresAt(new \DateTime('-2 days'));
  244. }
  246. $em = $this->getEntityManager();
  247. $em->persist($listingFeatured);
  249. $featureTypeLabel = $this->getTranslator()->trans($listingFeatured->getPendingFeaturedLabel());
  250. $balance = $this->creditManager->getBalance($listing->getUser());
  251. $amount = abs($listingFeatured->getCredit()->getAmount());
  252. $credit = new Credit();
  253. $credit
  254. ->setUser($listing->getUser())
  255. ->setAmount(abs($listingFeatured->getCredit()->getAmount()))
  256. ->setDescription('Rejected to be '.$featureTypeLabel)
  257. ->setBalance($balance + $amount)
  258. ->setStatus(CreditStatus::SUCCESS)
  259. ->setCreatedAt(new \DateTime());
  260. $em->persist($credit);
  261. $em->flush();
  262. }
  264. public function getEntityManager()
  265. {
  266. return $this->entityManager;
  267. }
  269. /**
  270. * @return TranslatorInterface
  271. */
  272. public function getTranslator()
  273. {
  274. return $this->translator;
  275. }
  277. public static function getSubscribedEvents(): array
  278. {
  279. return [
  280. 'aqarmap.listing.pre_save' => ['preSaveListingEvent'],
  281. 'aqarmap.listing.submitted' => [['onSubmittedEvent'], ['onSubmittedStatusRedirectionEvent']],
  282. 'aqarmap.listing.resubmitted' => [['onSubmittedEvent'], ['onSubmittedStatusRedirectionEvent']],
  283. 'aqarmap.listing.publish' => ['onListingPublishEvent'],
  284. 'aqarmap.listing.featuring.approved' => ['onFeaturingListingApprovalEvent'],
  285. 'aqarmap.listing.free_publish' => ['onListingPublishEvent'],
  286. 'aqarmap.listing.publish_without_photos' => ['onListingPublishEvent'],
  287. 'aqarmap.listing.featuring.rejected' => ['onFeaturingListingRejectEvent'],
  288. ];
  289. }
  291. /**
  292. * @return ListingManager
  293. */
  294. protected function getListingManager()
  295. {
  296. return $this->listingManager;
  297. }
  299. /**
  300. * @return ListingFeatureService
  301. */
  302. protected function getListingFeaturingService()
  303. {
  304. return $this->listingFeatureService;
  305. }
  307. /**
  308. * @param string $type
  309. * @param string $message
  310. */
  311. private function setFlashMessage($type, $message): void
  312. {
  313. if (($req = $this->requestStack->getCurrentRequest()) && $req->hasPreviousSession()) {
  314. $req->getSession()->getFlashBag()->add($type, $message);
  315. }
  316. }
  318. private function redirect($route, $parameters = [])
  319. {
  320. return new RedirectResponse(
  321. $this->router->generate($route, $parameters),
  322. \Symfony\Component\HttpFoundation\Response::HTTP_FOUND
  323. );
  324. }
  325. }