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

  1. <?php
  3. namespace Aqarmap\Bundle\ListingBundle\EventListener;
  5. use Aqarmap\Bundle\CreditBundle\Constant\CreditStatus;
  6. use Aqarmap\Bundle\CreditBundle\Contract\CreditManagerInterface;
  7. use Aqarmap\Bundle\CreditBundle\Entity\Credit;
  8. use Aqarmap\Bundle\ListingBundle\Constant\ListingCategories;
  9. use Aqarmap\Bundle\ListingBundle\Constant\ListingFeaturedStatus;
  10. use Aqarmap\Bundle\ListingBundle\Constant\ListingSource;
  11. use Aqarmap\Bundle\ListingBundle\Constant\ListingStatus;
  12. use Aqarmap\Bundle\ListingBundle\Entity\Listing;
  13. use Aqarmap\Bundle\ListingBundle\Event\ListingEvent;
  14. use Aqarmap\Bundle\ListingBundle\Event\ListingFeatureEvent;
  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 Aqarmap\Bundle\ListingBundle\Service\SpecialAddListingService;
  20. use Aqarmap\Bundle\UserBundle\Constant\UserServicesType;
  21. use Aqarmap\Bundle\UserBundle\Services\UserServicesManager;
  22. use Doctrine\ORM\EntityManagerInterface;
  23. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  24. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  25. use Symfony\Component\HttpFoundation\RedirectResponse;
  26. use Symfony\Component\HttpFoundation\RequestStack;
  27. use Symfony\Component\Routing\RouterInterface;
  28. use Symfony\Contracts\Translation\TranslatorInterface;
  30. class ListingRuleListener implements EventSubscriberInterface
  31. {
  32. public function __construct(private readonly ListingRuleMatcher $listingRuleMatcher, private readonly CreditManagerInterface $creditManager, private readonly ListingManager $listingManager, private readonly EntityManagerInterface $entityManager, private readonly ListingFeatureServiceInterface $listingFeatureService, private readonly RequestStack $requestStack, private readonly TranslatorInterface $translator, private readonly RouterInterface $router, private readonly SpecialAddListingService $specialAddListingService, private readonly UserServicesManager $userServicesManager, private readonly EventDispatcherInterface $dispatcher)
  33. {
  34. }
  36. public function preSaveListingEvent(ListingEvent $event): void
  37. {
  38. $listing = $event->getListing();
  40. if (
  41. !$listing->isDraft()
  42. && !$listing->isLive()
  43. && ListingCategories::FIRST_LISTING_FOR_FREE === $listing->getCategory()
  44. ) {
  45. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING, false);
  47. return;
  48. }
  50. $publicationCredit = $listing->getPublicationCredit();
  52. /** @var ListingRuleMatcher $matcher */
  53. $matcher = $this->listingRuleMatcher;
  54. $listingRule = $matcher->match($listing);
  56. $listingRulesRequirePhotos = ($listingRule['required_photos'] && $listing->getPhotos()->count() < $listingRule['required_photos']);
  57. $listingHasTitle = $listing->getTitle();
  59. if ($listingRulesRequirePhotos && $listingHasTitle) {
  60. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING_PHOTOS);
  61. }
  63. if (
  64. !$listing->isDraft()
  65. && !$listing->isLive()
  66. && !$listing->isProjectOrUnit()
  67. && ListingStatus::PENDING != $listing->getStatus()
  68. && ListingStatus::PENDING_PAYMENT != $listing->getStatus()
  69. && $listing->getPhotos()->count() >= $listingRule['required_photos']
  70. ) {
  71. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING_PAYMENT, false);
  72. }
  74. // If listing is PENDING_PAYMENT, the user already paid the fees
  75. if (ListingStatus::PENDING_PAYMENT === $listing->getStatus()) {
  76. if ($publicationCredit) {
  77. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING, false);
  78. }
  79. }
  81. // ----------------------------------------------------------------------
  82. // Toggle the listing's category on location change.
  83. // ----------------------------------------------------------------------
  85. $isPaid = ListingCategories::PAID === $listing->getCategory();
  86. $isScrapped = ListingCategories::SCRAPPED === $listing->getCategory();
  87. $isUnlimited = ListingCategories::UNLIMITED === $listing->getCategory();
  89. if (!$isPaid && !$isScrapped && !$isUnlimited && $listingRule['publication_fees'] > 0) {
  90. $listing->setCategory(ListingCategories::PAID);
  91. if (ListingStatus::PENDING === $listing->getStatus() && !$publicationCredit) {
  92. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING_PAYMENT, false);
  93. }
  94. }
  96. if (
  97. !$isPaid && !$isScrapped && !$isUnlimited && $listingHasTitle && $listingRule['publication_fees'] <= 0
  98. && \in_array($listing->getStatus(), [ListingStatus::PENDING_PAYMENT, ListingStatus::DRAFT])
  99. ) {
  100. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING, false);
  101. }
  103. if ($isPaid && !$isScrapped && !$isUnlimited && $listingRule['publication_fees'] <= 0) {
  104. $listing->setCategory(ListingCategories::NORMAL);
  105. if (ListingStatus::PENDING_PAYMENT === $listing->getStatus()) {
  106. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING_PAYMENT, false);
  107. }
  108. }
  110. if ($this->getListingManager()->isListingUserEbawab($listing)) {
  111. $listing->setCategory(ListingCategories::EBAWAB);
  112. }
  114. if ($this->getListingManager()->isListingUserManualScraped($listing)) {
  115. $listing->setCategory(ListingCategories::SCRAPPED);
  116. }
  117. }
  119. public function onSubmittedEvent(ListingEvent $event): void
  120. {
  121. /** @var Listing $listing */
  122. $listing = $event->getListing();
  124. $matcher = $this->listingRuleMatcher;
  125. $listingRule = $matcher->match($listing);
  127. if (!$listingRule['flf2'] && ListingCategories::PAID === $listing->getCategory() && $this->listingManager->isEligibleForFreePublishing($listing)) {
  128. $this->listingManager->createFirstListingForFree($listing);
  129. }
  131. if (
  132. ListingSource::LITE == $listing->getSource()
  133. || ListingSource::SCRAPPING == $listing->getSource()
  134. || ListingCategories::FIRST_LISTING_FOR_FREE === $listing->getCategory()
  135. ) {
  136. return;
  137. }
  139. if ($listingRule['publication_fees'] > 0 && $listing->getPhotos()->count() >= $listingRule['required_photos']) {
  140. if ((
  141. $this->specialAddListingService->hasSpecialAddListingGroup($listing->getUser())
  142. && !$listing->getSpecialPublicationCredit()
  143. )
  144. || (
  145. !$this->specialAddListingService->hasSpecialAddListingGroup($listing->getUser())
  146. && !$listing->getPublicationCredit()
  147. )
  148. ) {
  149. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING_PAYMENT, true, true);
  150. }
  151. }
  152. }
  154. public function onSubmittedStatusRedirectionEvent(ListingEvent $event): void
  155. {
  156. /** @var Listing $listing */
  157. $listing = $event->getListing();
  158. $userId = $listing->getUser();
  160. if ($this->specialAddListingService->hasSpecialAddListingGroup($userId)) {
  161. $userUnlimitedListings = $this->userServicesManager->hasActiveService(UserServicesType::UNLIMITED_LISTINGS, $userId);
  162. if (!$userUnlimitedListings || ($userUnlimitedListings && 0 == $userUnlimitedListings['remainingQuota'])) {
  163. $event->setResponse($this->redirect(
  164. 'listing_slug',
  165. ['id' => $listing->getId(), 'slug' => $listing->getSlug()]
  166. ));
  168. return;
  169. }
  170. }
  172. switch ($listing->getStatus()) {
  173. case ListingStatus::PENDING_PAYMENT:
  174. $event->setResponse($this->redirect(
  175. 'listing_confirm_publish_credit',
  176. ['id' => $listing->getId()]
  177. ));
  178. break;
  180. case ListingStatus::PENDING_PHOTOS:
  181. $this->setFlashMessage('info', $this->getTranslator()->trans('add_listing_page.success_messages.add_photos_message'));
  183. $event->setResponse($this->redirect(
  184. 'listing_upload',
  185. ['id' => $event->getListing()->getId()]
  186. ));
  187. break;
  188. }
  189. }
  191. /**
  192. * @throws \Exception
  193. */
  194. public function onListingPublishEvent(ListingEvent $event): void
  195. {
  196. $listing = $event->getListing();
  198. $listingPublishPaid = $listing->getPublicationCredit();
  199. $listingPublishFeatured = $listing->getFeaturedPublicationCredit();
  200. $listingRule = $this->listingRuleMatcher->match($listing);
  202. if (ListingCategories::FIRST_LISTING_FOR_FREE === $listing->getCategory()) {
  203. $listing->setExpiresAt(new \DateTime('+'.$listingRule['first_free_duration'].' days'));
  205. return;
  206. }
  208. if ($listingRule['duration'] && (!$listing->getExpiresAt() || new \DateTime() >= $listing->getExpiresAt())) {
  209. $listing->setExpiresAt(new \DateTime('+'.$listingRule['duration'].' days'));
  210. }
  212. if ($listingPublishPaid) {
  213. if (!$listingPublishPaid->getExpiresAt()) {
  214. $listingPublishPaid->setExpiresAt($listing->getExpiresAt());
  215. }
  216. }
  217. if ($listingPublishFeatured) {
  218. if (!$listingPublishFeatured->getExpiresAt() && !$listingPublishFeatured->getFeaturingStatus()) {
  219. $duration = $this->getListingFeaturingService()->getFeaturedTypeDuration($listingRule, $listingPublishFeatured->getType());
  220. $listingPublishFeatured->setExpiresAt(new \DateTime('+'.$duration.' days'));
  221. $this->dispatcher->dispatch(new ListingFeatureEvent($listingPublishFeatured), 'aqarmap.listing.feature.bumpup');
  222. }
  223. }
  224. }
  226. public function onFeaturingListingApprovalEvent(ListingEvent $event): void
  227. {
  228. $listing = $event->getListing();
  229. $listingPublishFeatured = $listing->getFeaturedPublicationCredit();
  230. $listingManager = $this->getListingManager();
  231. $listingFeatureService = $this->getListingFeaturingService();
  232. $listingRule = $listingManager->getListingRules($listing);
  234. if ($listingPublishFeatured && ListingStatus::LIVE == $listing->getStatus()) {
  235. $listing->setFeatured($listingFeatureService->getListingFeaturedType($listingPublishFeatured->getType()));
  236. $listingPublishFeatured->setFeaturingStatus(ListingFeaturedStatus::APPROVED);
  237. $listingPublishFeatured->setApprovedAt(new \DateTime());
  239. if (!$listingPublishFeatured->getExpiresAt()) {
  240. $duration = $this->getListingFeaturingService()->getFeaturedTypeDuration($listingRule, $listingPublishFeatured->getType());
  241. $listingPublishFeatured->setExpiresAt(new \DateTime('+'.$duration.' days'));
  242. }
  243. }
  244. $em = $this->getEntityManager();
  245. $em->persist($listing);
  246. $em->flush();
  247. }
  249. /**
  250. * @throws \Exception
  251. */
  252. public function onFeaturingListingRejectEvent(ListingEvent $event): void
  253. {
  254. $listing = $event->getListing();
  255. $listingFeatured = $listing->getLastListingFeature();
  257. if (ListingStatus::LIVE == $listing->getStatus()) {
  258. $listingFeatured->setFeaturingStatus(ListingFeaturedStatus::REJECTED);
  259. $listingFeatured->setExpiresAt(new \DateTime('-2 days'));
  260. }
  262. $em = $this->getEntityManager();
  263. $em->persist($listingFeatured);
  265. $featureTypeLabel = $this->getTranslator()->trans($listingFeatured->getPendingFeaturedLabel());
  266. $balance = $this->creditManager->getBalance($listing->getUser());
  267. $amount = abs($listingFeatured->getCredit()->getAmount());
  268. $credit = new Credit();
  269. $credit
  270. ->setUser($listing->getUser())
  271. ->setAmount(abs($listingFeatured->getCredit()->getAmount()))
  272. ->setDescription('Rejected to be '.$featureTypeLabel)
  273. ->setBalance($balance + $amount)
  274. ->setStatus(CreditStatus::SUCCESS)
  275. ->setCreatedAt(new \DateTime());
  276. $em->persist($credit);
  277. $em->flush();
  278. }
  280. public function getEntityManager()
  281. {
  282. return $this->entityManager;
  283. }
  285. /**
  286. * @return TranslatorInterface
  287. */
  288. public function getTranslator()
  289. {
  290. return $this->translator;
  291. }
  293. public static function getSubscribedEvents(): array
  294. {
  295. return [
  296. 'aqarmap.listing.pre_save' => ['preSaveListingEvent'],
  297. 'aqarmap.listing.submitted' => [['onSubmittedEvent'], ['onSubmittedStatusRedirectionEvent']],
  298. 'aqarmap.listing.resubmitted' => [['onSubmittedEvent'], ['onSubmittedStatusRedirectionEvent']],
  299. 'aqarmap.listing.publish' => ['onListingPublishEvent'],
  300. 'aqarmap.listing.featuring.approved' => ['onFeaturingListingApprovalEvent'],
  301. 'aqarmap.listing.free_publish' => ['onListingPublishEvent'],
  302. 'aqarmap.listing.publish_without_photos' => ['onListingPublishEvent'],
  303. 'aqarmap.listing.featuring.rejected' => ['onFeaturingListingRejectEvent'],
  304. ];
  305. }
  307. /**
  308. * @return ListingManager
  309. */
  310. protected function getListingManager()
  311. {
  312. return $this->listingManager;
  313. }
  315. /**
  316. * @return ListingFeatureService
  317. */
  318. protected function getListingFeaturingService()
  319. {
  320. return $this->listingFeatureService;
  321. }
  323. /**
  324. * @param string $type
  325. * @param string $message
  326. */
  327. private function setFlashMessage($type, $message): void
  328. {
  329. if (($req = $this->requestStack->getCurrentRequest()) && $req->hasPreviousSession()) {
  330. $req->getSession()->getFlashBag()->add($type, $message);
  331. }
  332. }
  334. private function redirect($route, $parameters = [])
  335. {
  336. return new RedirectResponse(
  337. $this->router->generate($route, $parameters),
  338. \Symfony\Component\HttpFoundation\Response::HTTP_FOUND
  339. );
  340. }
  341. }