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

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