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\Event\ListingFeatureEvent;
  16. use Aqarmap\Bundle\ListingBundle\Service\Contracts\ListingFeatureServiceInterface;
  17. use Aqarmap\Bundle\ListingBundle\Service\ListingFeatureService;
  18. use Aqarmap\Bundle\ListingBundle\Service\ListingManager;
  19. use Aqarmap\Bundle\ListingBundle\Service\ListingRuleMatcher;
  20. use Aqarmap\Bundle\ListingBundle\Service\SpecialAddListingService;
  21. use Aqarmap\Bundle\UserBundle\Constant\UserServicesType;
  22. use Aqarmap\Bundle\UserBundle\Services\UserServicesManager;
  23. use Doctrine\ORM\EntityManagerInterface;
  24. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  25. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  26. use Symfony\Component\HttpFoundation\RedirectResponse;
  27. use Symfony\Component\HttpFoundation\RequestStack;
  28. use Symfony\Component\Routing\RouterInterface;
  29. use Symfony\Contracts\Translation\TranslatorInterface;
  31. class ListingRuleListener implements EventSubscriberInterface
  32. {
  33. 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)
  34. {
  35. }
  37. public function preSaveListingEvent(ListingEvent $event): void
  38. {
  39. $listing = $event->getListing();
  41. if (
  42. !$listing->isDraft()
  43. && !$listing->isLive()
  44. && ListingCategories::FIRST_LISTING_FOR_FREE === $listing->getCategory()
  45. ) {
  46. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING, false);
  48. return;
  49. }
  51. $publicationCredit = $listing->getPublicationCredit();
  53. /** @var ListingRuleMatcher $matcher */
  54. $matcher = $this->listingRuleMatcher;
  55. $listingRule = $matcher->match($listing);
  57. $listingRulesRequirePhotos = ($listingRule['required_photos'] && $listing->getPhotos()->count() < $listingRule['required_photos']);
  58. $listingHasTitle = $listing->getTitle();
  60. if ($listingRulesRequirePhotos && $listingHasTitle) {
  61. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING_PHOTOS);
  62. }
  64. if (
  65. !$listing->isDraft()
  66. && !$listing->isLive()
  67. && !$listing->isProjectOrUnit()
  68. && ListingStatus::PENDING != $listing->getStatus()
  69. && ListingStatus::PENDING_PAYMENT != $listing->getStatus()
  70. && $listing->getPhotos()->count() >= $listingRule['required_photos']
  71. ) {
  72. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING_PAYMENT, false);
  73. }
  75. // If listing is PENDING_PAYMENT, the user already paid the fees
  76. if (ListingStatus::PENDING_PAYMENT === $listing->getStatus()) {
  77. if ($publicationCredit) {
  78. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING, false);
  79. }
  80. }
  82. // ----------------------------------------------------------------------
  83. // Toggle the listing's category on location change.
  84. // ----------------------------------------------------------------------
  86. $isPaid = ListingCategories::PAID === $listing->getCategory();
  87. $isScrapped = ListingCategories::SCRAPPED === $listing->getCategory();
  88. $isUnlimited = ListingCategories::UNLIMITED === $listing->getCategory();
  90. if (!$isPaid && !$isScrapped && !$isUnlimited && $listingRule['publication_fees'] > 0) {
  91. $listing->setCategory(ListingCategories::PAID);
  92. if (ListingStatus::PENDING === $listing->getStatus() && !$publicationCredit) {
  93. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING_PAYMENT, false);
  94. }
  95. }
  97. if (
  98. !$isPaid && !$isScrapped && !$isUnlimited && $listingHasTitle && $listingRule['publication_fees'] <= 0
  99. && \in_array($listing->getStatus(), [ListingStatus::PENDING_PAYMENT, ListingStatus::DRAFT])
  100. ) {
  101. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING, false);
  102. }
  104. if ($isPaid && !$isScrapped && !$isUnlimited && $listingRule['publication_fees'] <= 0) {
  105. $listing->setCategory(ListingCategories::NORMAL);
  106. if (ListingStatus::PENDING_PAYMENT === $listing->getStatus()) {
  107. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING_PAYMENT, false);
  108. }
  109. }
  111. if ($this->getListingManager()->isListingUserEbawab($listing)) {
  112. $listing->setCategory(ListingCategories::EBAWAB);
  113. }
  115. if ($this->getListingManager()->isListingUserManualScraped($listing)) {
  116. $listing->setCategory(ListingCategories::SCRAPPED);
  117. $this->listingManager->addLabelByCode($listing, LabelCode::LISTING_SCRAPPED);
  118. }
  119. }
  121. public function onSubmittedEvent(ListingEvent $event): void
  122. {
  123. /** @var Listing $listing */
  124. $listing = $event->getListing();
  126. $matcher = $this->listingRuleMatcher;
  127. $listingRule = $matcher->match($listing);
  129. if (!$listingRule['flf2'] && ListingCategories::PAID === $listing->getCategory() && $this->listingManager->isEligibleForFreePublishing($listing)) {
  130. $this->listingManager->createFirstListingForFree($listing);
  131. }
  133. if (
  134. ListingSource::LITE == $listing->getSource()
  135. || ListingSource::SCRAPPING == $listing->getSource()
  136. || ListingCategories::FIRST_LISTING_FOR_FREE === $listing->getCategory()
  137. ) {
  138. return;
  139. }
  141. if ($listingRule['publication_fees'] > 0 && $listing->getPhotos()->count() >= $listingRule['required_photos']) {
  142. if ((
  143. $this->specialAddListingService->hasSpecialAddListingGroup($listing->getUser())
  144. && !$listing->getSpecialPublicationCredit()
  145. )
  146. || (
  147. !$this->specialAddListingService->hasSpecialAddListingGroup($listing->getUser())
  148. && !$listing->getPublicationCredit()
  149. )
  150. ) {
  151. $this->getListingManager()->changeStatus($listing, ListingStatus::PENDING_PAYMENT, true, true);
  152. }
  153. }
  154. }
  156. public function onSubmittedStatusRedirectionEvent(ListingEvent $event): void
  157. {
  158. /** @var Listing $listing */
  159. $listing = $event->getListing();
  160. $userId = $listing->getUser();
  162. if ($this->specialAddListingService->hasSpecialAddListingGroup($userId)) {
  163. $userUnlimitedListings = $this->userServicesManager->hasActiveService(UserServicesType::UNLIMITED_LISTINGS, $userId);
  164. if (!$userUnlimitedListings || ($userUnlimitedListings && 0 == $userUnlimitedListings['remainingQuota'])) {
  165. $event->setResponse($this->redirect(
  166. 'listing_slug',
  167. ['id' => $listing->getId(), 'slug' => $listing->getSlug()]
  168. ));
  170. return;
  171. }
  172. }
  174. switch ($listing->getStatus()) {
  175. case ListingStatus::PENDING_PAYMENT:
  176. $event->setResponse($this->redirect(
  177. 'listing_confirm_publish_credit',
  178. ['id' => $listing->getId()]
  179. ));
  180. break;
  182. case ListingStatus::PENDING_PHOTOS:
  183. $this->setFlashMessage('info', $this->getTranslator()->trans('add_listing_page.success_messages.add_photos_message'));
  185. $event->setResponse($this->redirect(
  186. 'listing_upload',
  187. ['id' => $event->getListing()->getId()]
  188. ));
  189. break;
  190. }
  191. }
  193. /**
  194. * @throws \Exception
  195. */
  196. public function onListingPublishEvent(ListingEvent $event): void
  197. {
  198. $listing = $event->getListing();
  200. $listingPublishPaid = $listing->getPublicationCredit();
  201. $listingPublishFeatured = $listing->getFeaturedPublicationCredit();
  202. $listingRule = $this->listingRuleMatcher->match($listing);
  204. if (ListingCategories::FIRST_LISTING_FOR_FREE === $listing->getCategory()) {
  205. $listing->setExpiresAt(new \DateTime('+'.$listingRule['first_free_duration'].' days'));
  207. return;
  208. }
  210. if ($listingRule['duration'] && (!$listing->getExpiresAt() || new \DateTime() >= $listing->getExpiresAt())) {
  211. $listing->setExpiresAt(new \DateTime('+'.$listingRule['duration'].' days'));
  212. }
  214. if ($listingPublishPaid) {
  215. if (!$listingPublishPaid->getExpiresAt()) {
  216. $listingPublishPaid->setExpiresAt($listing->getExpiresAt());
  217. }
  218. }
  219. if ($listingPublishFeatured) {
  220. if (!$listingPublishFeatured->getExpiresAt() && !$listingPublishFeatured->getFeaturingStatus()) {
  221. $duration = $this->getListingFeaturingService()->getFeaturedTypeDuration($listingRule, $listingPublishFeatured->getType());
  222. $listingPublishFeatured->setExpiresAt(new \DateTime('+'.$duration.' days'));
  223. $this->dispatcher->dispatch(new ListingFeatureEvent($listingPublishFeatured), 'aqarmap.listing.feature.bumpup');
  224. }
  225. }
  226. }
  228. public function onFeaturingListingApprovalEvent(ListingEvent $event): void
  229. {
  230. $listing = $event->getListing();
  231. $listingPublishFeatured = $listing->getFeaturedPublicationCredit();
  232. $listingManager = $this->getListingManager();
  233. $listingFeatureService = $this->getListingFeaturingService();
  234. $listingRule = $listingManager->getListingRules($listing);
  236. if ($listingPublishFeatured && ListingStatus::LIVE == $listing->getStatus()) {
  237. $listing->setFeatured($listingFeatureService->getListingFeaturedType($listingPublishFeatured->getType()));
  238. $listingPublishFeatured->setFeaturingStatus(ListingFeaturedStatus::APPROVED);
  239. $listingPublishFeatured->setApprovedAt(new \DateTime());
  241. if (!$listingPublishFeatured->getExpiresAt()) {
  242. $duration = $this->getListingFeaturingService()->getFeaturedTypeDuration($listingRule, $listingPublishFeatured->getType());
  243. $listingPublishFeatured->setExpiresAt(new \DateTime('+'.$duration.' days'));
  244. }
  245. }
  246. $em = $this->getEntityManager();
  247. $em->persist($listing);
  248. $em->flush();
  249. }
  251. /**
  252. * @throws \Exception
  253. */
  254. public function onFeaturingListingRejectEvent(ListingEvent $event): void
  255. {
  256. $listing = $event->getListing();
  257. $listingFeatured = $listing->getLastListingFeature();
  259. if (ListingStatus::LIVE == $listing->getStatus()) {
  260. $listingFeatured->setFeaturingStatus(ListingFeaturedStatus::REJECTED);
  261. $listingFeatured->setExpiresAt(new \DateTime('-2 days'));
  262. }
  264. $em = $this->getEntityManager();
  265. $em->persist($listingFeatured);
  267. $featureTypeLabel = $this->getTranslator()->trans($listingFeatured->getPendingFeaturedLabel());
  268. $balance = $this->creditManager->getBalance($listing->getUser());
  269. $amount = abs($listingFeatured->getCredit()->getAmount());
  270. $credit = new Credit();
  271. $credit
  272. ->setUser($listing->getUser())
  273. ->setAmount(abs($listingFeatured->getCredit()->getAmount()))
  274. ->setDescription('Rejected to be '.$featureTypeLabel)
  275. ->setBalance($balance + $amount)
  276. ->setStatus(CreditStatus::SUCCESS)
  277. ->setCreatedAt(new \DateTime());
  278. $em->persist($credit);
  279. $em->flush();
  280. }
  282. public function getEntityManager()
  283. {
  284. return $this->entityManager;
  285. }
  287. /**
  288. * @return TranslatorInterface
  289. */
  290. public function getTranslator()
  291. {
  292. return $this->translator;
  293. }
  295. public static function getSubscribedEvents(): array
  296. {
  297. return [
  298. 'aqarmap.listing.pre_save' => ['preSaveListingEvent'],
  299. 'aqarmap.listing.submitted' => [['onSubmittedEvent'], ['onSubmittedStatusRedirectionEvent']],
  300. 'aqarmap.listing.resubmitted' => [['onSubmittedEvent'], ['onSubmittedStatusRedirectionEvent']],
  301. 'aqarmap.listing.publish' => ['onListingPublishEvent'],
  302. 'aqarmap.listing.featuring.approved' => ['onFeaturingListingApprovalEvent'],
  303. 'aqarmap.listing.free_publish' => ['onListingPublishEvent'],
  304. 'aqarmap.listing.publish_without_photos' => ['onListingPublishEvent'],
  305. 'aqarmap.listing.featuring.rejected' => ['onFeaturingListingRejectEvent'],
  306. ];
  307. }
  309. /**
  310. * @return ListingManager
  311. */
  312. protected function getListingManager()
  313. {
  314. return $this->listingManager;
  315. }
  317. /**
  318. * @return ListingFeatureService
  319. */
  320. protected function getListingFeaturingService()
  321. {
  322. return $this->listingFeatureService;
  323. }
  325. /**
  326. * @param string $type
  327. * @param string $message
  328. */
  329. private function setFlashMessage($type, $message): void
  330. {
  331. if (($req = $this->requestStack->getCurrentRequest()) && $req->hasPreviousSession()) {
  332. $req->getSession()->getFlashBag()->add($type, $message);
  333. }
  334. }
  336. private function redirect($route, $parameters = [])
  337. {
  338. return new RedirectResponse(
  339. $this->router->generate($route, $parameters),
  340. \Symfony\Component\HttpFoundation\Response::HTTP_FOUND
  341. );
  342. }
  343. }