1. <?php
3. namespace Aqarmap\Bundle\ListingBundle\Controller\Api;
5. use App\Exception\BadRequestHttpException;
6. use App\Exception\LogicHttpException;
7. use Aqarmap\Bundle\CreditBundle\Constant\CreditStatus;
8. use Aqarmap\Bundle\CreditBundle\Contract\CreditManagerInterface;
9. use Aqarmap\Bundle\CreditBundle\Entity\Credit;
10. use Aqarmap\Bundle\FeatureToggleBundle\Service\FeatureToggleManager;
11. use Aqarmap\Bundle\ListingBundle\Constant\CountryCodes;
12. use Aqarmap\Bundle\ListingBundle\Constant\LeadTypes;
13. use Aqarmap\Bundle\ListingBundle\Constant\ListingFeaturedTypes;
14. use Aqarmap\Bundle\ListingBundle\Constant\ListingFeatures;
15. use Aqarmap\Bundle\ListingBundle\Constant\ListingStatus;
16. use Aqarmap\Bundle\ListingBundle\Constant\ListingSyncedFields;
17. use Aqarmap\Bundle\ListingBundle\Constant\PhotoTypes;
18. use Aqarmap\Bundle\ListingBundle\Contracts\PhoneManagerInterface;
19. use Aqarmap\Bundle\ListingBundle\Entity\CallRequest;
20. use Aqarmap\Bundle\ListingBundle\Entity\Listing;
21. use Aqarmap\Bundle\ListingBundle\Entity\ListingNote;
22. use Aqarmap\Bundle\ListingBundle\Entity\ListingPhone;
23. use Aqarmap\Bundle\ListingBundle\Entity\ListingPhoto;
24. use Aqarmap\Bundle\ListingBundle\Entity\Photo;
25. use Aqarmap\Bundle\ListingBundle\Entity\PropertyType;
26. use Aqarmap\Bundle\ListingBundle\Entity\Section;
27. use Aqarmap\Bundle\ListingBundle\Event\LeadEvent;
28. use Aqarmap\Bundle\ListingBundle\Event\ListingEvent;
29. use Aqarmap\Bundle\ListingBundle\Event\ListingUpdatedEvent;
30. use Aqarmap\Bundle\ListingBundle\Form\ContactSellerFormType;
31. use Aqarmap\Bundle\ListingBundle\Form\ListingApiType;
32. use Aqarmap\Bundle\ListingBundle\Form\ListingNoteType;
33. use Aqarmap\Bundle\ListingBundle\Form\PhotoType;
34. use Aqarmap\Bundle\ListingBundle\Form\QuickContactSellerType;
35. use Aqarmap\Bundle\ListingBundle\Form\QuickCreateLeadFormType;
36. use Aqarmap\Bundle\ListingBundle\Form\QuickLeadType;
37. use Aqarmap\Bundle\ListingBundle\Model\LeadModel;
38. use Aqarmap\Bundle\ListingBundle\Repository\ListingNoteRepository;
39. use Aqarmap\Bundle\ListingBundle\Repository\ListingRepository;
40. use Aqarmap\Bundle\ListingBundle\Service\CallLog\Logger;
41. use Aqarmap\Bundle\ListingBundle\Service\CallRequestManager;
42. use Aqarmap\Bundle\ListingBundle\Service\FavouriteService;
43. use Aqarmap\Bundle\ListingBundle\Service\InteractionService;
44. use Aqarmap\Bundle\ListingBundle\Service\LeadService;
45. use Aqarmap\Bundle\ListingBundle\Service\ListingManager;
46. use Aqarmap\Bundle\ListingBundle\Service\ListingNoteService;
47. use Aqarmap\Bundle\ListingBundle\Service\ListingRateService;
48. use Aqarmap\Bundle\ListingBundle\Service\ListingRuleMatcher;
49. use Aqarmap\Bundle\ListingBundle\Service\LocationManager;
50. use Aqarmap\Bundle\ListingBundle\Service\Mortgage\MortgageService;
51. use Aqarmap\Bundle\ListingBundle\Service\NewsFeed\ListingNewsFeed;
52. use Aqarmap\Bundle\ListingBundle\Twig\ListingExtension;
53. use Aqarmap\Bundle\MainBundle\Controller\Api\BaseController;
54. use Aqarmap\Bundle\MainBundle\Service\Setting;
55. use Aqarmap\Bundle\MessageBundle\Service\Composer;
56. use Aqarmap\Bundle\TopSellerBundle\Model\TopSeller;
57. use Aqarmap\Bundle\TopSellerBundle\Service\TopSellerRetrievalService;
58. use Aqarmap\Bundle\UserBundle\Entity\User;
59. use Aqarmap\Bundle\UserBundle\Services\UserManager;
60. use Doctrine\Common\Collections\Collection;
61. use Doctrine\ORM\EntityManager;
62. use Doctrine\ORM\EntityManagerInterface;
63. use Doctrine\ORM\OptimisticLockException;
64. use Doctrine\ORM\ORMException;
65. use FOS\RestBundle\Controller\Annotations as Rest;
66. use FOS\RestBundle\View\View;
67. use FOS\UserBundle\Model\UserManagerInterface;
68. use Gedmo\Translatable\TranslatableListener;
69. use Knp\Component\Pager\PaginatorInterface;
70. use OpenApi\Attributes as OA;
71. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
72. use Symfony\Component\Form\Form;
73. use Symfony\Component\HttpFoundation\File\UploadedFile;
74. use Symfony\Component\HttpFoundation\Request;
75. use Symfony\Component\HttpFoundation\Response;
76. use Symfony\Component\HttpKernel\Attribute\Cache;
77. use Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException;
78. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
79. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
80. use Symfony\Contracts\Translation\TranslatorInterface;
82. /**
83. * Class ListingController.
84. */
85. class ListingController extends BaseController
86. {
87. /**
88. * @var TokenStorageInterface
89. */
90. protected $tokenStorage;
92. /** @var FOSUserManager */
93. private $fosUserManager;
95. public function __construct(
96. private readonly Composer $messageComposer,
97. private readonly FavouriteService $favouriteService,
98. private readonly PaginatorInterface $paginator,
99. private readonly InteractionService $interactionService,
100. private readonly ListingManager $listingManager,
101. private readonly EventDispatcherInterface $dispatcher,
102. UserManagerInterface $fosUserManager,
103. private readonly TranslatorInterface $translator,
104. private readonly TranslatableListener $translatableListener,
105. private readonly Logger $logger,
106. private readonly UserManager $userManager,
107. private readonly ListingManager $listingService,
108. private readonly ListingNoteService $listingNoteService,
109. private readonly ListingRuleMatcher $listingRuleMatcher,
110. private readonly LocationManager $locationManager,
111. Setting $setting,
112. private readonly PhoneManagerInterface $phoneManager,
113. private readonly FeatureToggleManager $featureToggle,
114. private readonly ListingRateService $listingRateService,
115. TokenStorageInterface $tokenStorage,
116. private readonly LeadService $leadManager,
117. private readonly CallRequestManager $callRequestManager,
118. private readonly MortgageService $mortgageService,
119. private readonly CreditManagerInterface $creditManager,
120. private readonly ListingExtension $listingExtension,
121. private readonly ListingNewsFeed $listingNewsFeed,
122. private readonly EntityManagerInterface $entityManager,
123. private readonly \Doctrine\Persistence\ManagerRegistry $managerRegistry,
124. ) {
125. $this->fosUserManager = $fosUserManager;
126. $this->tokenStorage = $tokenStorage;
127. }
129. /**
130. * Get Listing.
131. *
132. * )
133. */
134. #[Rest\Get('/api/v2/listing/{id}', requirements: ['id' => '\d+'], options: ['i18n' => false], name: 'aqarmap_api_get_listing_v2')]
135. #[Rest\View(serializerGroups: ['Default', 'Details', 'Compound'])]
136. #[Cache(expires: '+2 hours', maxage: '+2 hours', smaxage: '+2 hours', public: false, vary: ['Accept-Language', 'X-Accept-Version', 'Accept'])]
137. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
138. public function getListing(Listing $listing): array
139. {
140. return ['listing' => $listing];
141. }
143. /**
144. * Listing details.
145. */
146. #[Rest\Get('/api/v4/listing/{id}', requirements: ['id' => '\d+'], options: ['i18n' => false], name: 'aqarmap_api_get_listing_v4')]
147. #[Rest\View(serializerGroups: ['listingDetails', 'listingDetailsWithLocationCompound'])]
148. #[Cache(expires: '+6 hours', maxage: '+6 hours', smaxage: '+6 hours', public: true, vary: ['Accept-Language', 'X-Accept-Version', 'Accept'])]
149. public function getListingDetails(int $id, ListingRepository $listingRepository, ListingManager $listingManager): array
150. {
151. $entityManagerFilters = $this->entityManager->getFilters();
153. if ($entityManagerFilters->isEnabled('softdeleteable')) {
154. $entityManagerFilters->disable('softdeleteable');
155. }
157. $listing = $listingRepository->find($id);
159. $entityManagerFilters->enable('softdeleteable');
161. return ['listing' => $listingManager->serializeListing($listing)];
162. }
164. /**
165. * Get Listing Children (Project Units).
166. *
167. * )
168. *
169. * @return array
170. */
171. #[Rest\Get('/api/v2/listing/{id}/children', options: ['i18n' => false], name: 'aqarmap_api_get_listing_children_v2')]
172. #[Rest\View(serializerGroups: ['Default', 'Details'])]
173. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
174. public function getListingChildren(Listing $listing)
175. {
176. return $this->respond($listing->getLiveChildren());
177. }
179. /**
180. * @return Collection
181. *
182. * @throws ORMException
183. * @throws OptimisticLockException
184. */
185. #[Rest\Post('/api/v2/listing/{listing}/phones', options: ['i18n' => false], name: 'aqarmap_api_get_listing_phones_v2')]
186. #[Rest\View(serializerGroups: ['Default', 'Details'])]
187. #[OA\Parameter(name: 'lead', in: 'query', description: '', required: false)]
188. public function getListingPhone(Listing $listing, Request $request, ?User $user = null)
189. {
190. $version = (float) ltrim((string) $request->headers->get('X-Accept-Version'), 'v');
191. $leadModel = new LeadModel();
193. $currentUrl = $request->getUri();
194. if (str_contains($currentUrl, 'v2')) {
195. if (!$user = $this->getUser() && $version <= 2.13) {
196. throw new AccessDeniedHttpException();
197. }
198. }
200. $form = $this->createForm(QuickLeadType::class, null, [
201. 'method' => 'POST',
202. 'csrf_protection' => false,
203. ]);
205. $form->handleRequest($request);
206. $lead = $form->getData();
208. $phoneManager = $this->phoneManager;
209. $originalPhoneNumber = $lead['phone'];
210. $phoneNumber = $phoneManager->trimZero($lead['phone'], $lead['countryCode']);
212. $aqarmapUserService = $this->userManager;
213. $hasEmail = !$lead['isAutoGeneratedEmail'];
215. /** @var $userManager \FOS\UserBundle\Model\UserManagerInterface */
216. $userManager = $this->fosUserManager;
218. /** @var User $user */
219. $user = $userManager->findUserByEmail($lead['email']);
220. $countryCode = $lead['countryCode'];
222. if (!$user && !$hasEmail) {
223. $user = $aqarmapUserService->findLatestByPhone($phoneNumber, $countryCode);
224. }
226. if (!$user && $hasEmail) {
227. $user = $aqarmapUserService->findAndReplaceUserAndEmail($phoneNumber, $lead['email'], $countryCode);
228. }
230. if (!$user) {
231. $user = $userManager->createUser();
232. $user
233. ->setFullName($lead['name'])
234. ->setPhoneNumber($lead['phone'])
235. ->setTempOriginalPhoneNumber($originalPhoneNumber)
236. ->setTempCountryCode($lead['countryCode'])
237. ->setEmail($lead['email'])
238. ->setHasEmail($hasEmail)
239. ->setLanguage('ar');
241. $user = $aqarmapUserService->quickRegistration($form, $user, $request);
242. }
244. $phone = $phoneManager->addNewUserPhone($phoneNumber, $lead['countryCode'], $user, true, false, null, $originalPhoneNumber);
245. $userManager->updateUser($user);
246. $userManager->reloadUser($user);
247. $leadModel->setPhone($phone->getPhone());
248. $leadModel->setName($request->request->get('name', $lead['name']));
249. $leadModel->setEmail($request->request->get('email', $lead['email']));
251. $leadService = $this->leadManager;
252. $leadModel->setLeadType(LeadTypes::SHOW_PHONE);
253. $leadModel->setListing($listing);
254. $leadModel->setSource('api');
255. $leadModel->setUser($user);
257. $lead = $leadService->addLead($leadModel);
259. if ($lead) {
260. $this->dispatcher->dispatch(
261. new LeadEvent(
262. $listing,
263. $user,
264. $lead
265. ),
266. 'aqarmap.listing.show_seller_number'
267. );
268. }
270. return $listing->getPhones();
271. }
273. /**
274. * @return bool|Form
275. *
276. * @throws AccessDeniedHttpException
277. */
278. #[Rest\Post('/api/v2/listing/{listing}/contact_seller', options: ['i18n' => false], name: 'aqarmap_api_listing_contact_seller_v2')]
279. #[Rest\QueryParam(name: 'campaign', description: 'Campaign Name')]
280. #[Rest\View(serializerGroups: ['Default', 'Details'])]
281. #[OA\Parameter(name: 'campaign', in: 'query', description: 'Campaign Name', required: false)]
282. #[OA\Parameter(name: 'contact_seller', in: 'query', description: '', required: false)]
283. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
284. public function contactSeller(Request $request, Listing $listing, ?User $user = null)
285. {
286. $currentUrl = $request->getUri();
287. if (str_contains($currentUrl, 'v2')) {
288. if (!$user = $this->getUser()) {
289. throw new AccessDeniedHttpException();
290. }
291. }
293. $form = $this->createForm(ContactSellerFormType::class, null, [
294. 'method' => 'POST',
295. 'csrf_protection' => false,
296. ]);
297. $form->handleRequest($request);
299. if ($form->isSubmitted() && $form->isValid()) {
300. // Get campaign name
301. $campaign = $request->query->get('campaign');
303. $message = $form->getData();
304. // Send contact seller message and send a lead
305. $composer = $this->messageComposer;
306. $composer
307. ->setSender($user)
308. ->compose($message['message'], $listing, $campaign);
310. return true;
311. }
313. return $form;
314. }
316. /**
317. * @return Response $response
318. *
319. * @throws \Exception
320. */
321. #[Rest\Post('/api/v2/listing/{listing}/contact_seller/quick', options: ['i18n' => false], name: 'aqarmap_api_listing_quick_contact_seller_v2')]
322. #[Rest\QueryParam(name: 'campaign', description: 'Campaign Name')]
323. #[Rest\View(serializerGroups: ['Default', 'Details'])]
324. #[OA\Parameter(name: 'campaign', in: 'query', description: 'Campaign Name', required: false)]
325. #[OA\Parameter(name: 'contact_seller', in: 'query', description: '', required: false)]
326. #[OA\Response(response: 201, description: 'Returned when user created and message sent successfully')]
327. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
328. #[OA\Response(response: 403, description: 'Returned when parameter is missing')]
329. public function contactSellerWithQuickRegistration(Request $request, Listing $listing): Response
330. {
331. if (!$this->isValidQuickContactSellerParameters($request->get('contact_seller'))) {
332. return new Response(null, Response::HTTP_FORBIDDEN);
333. }
335. $form = $this->createForm(QuickContactSellerType::class, null, [
336. 'method' => 'POST',
337. 'csrf_protection' => false,
338. ]);
339. $form->handleRequest($request);
340. if ($form->isSubmitted() && !$form->isValid()) {
341. return new Response(null, Response::HTTP_FORBIDDEN);
342. }
344. $userManager = $this->userManager;
345. $fromData = $form->getData();
346. $user = $userManager->createQuickUser($request, $form);
347. $campaign = $request->query->get('campaign');
349. $composer = $this->messageComposer;
350. $composer
351. ->setSender($user)
352. ->compose($fromData['message'], $listing, $campaign);
354. return new Response(null, Response::HTTP_CREATED);
355. }
357. private function isValidQuickContactSellerParameters(array $parameters): bool
358. {
359. if (
360. !\array_key_exists('email', $parameters)
361. || !\array_key_exists('phone', $parameters)
362. || !\array_key_exists('countryCode', $parameters)
363. ) {
364. return false;
365. }
367. return true;
368. }
370. /**
371. * @return bool|array
372. */
373. #[Rest\Post('/api/v2/listing/{listing}/call_request', options: ['i18n' => false], name: 'aqarmap_api_listing_call_request_v2')]
374. #[Rest\QueryParam(name: 'campaign', description: 'Campaign Name')]
375. #[Rest\View(serializerGroups: ['Default', 'Details'])]
376. public function callRequest(Listing $listing, Request $request, ?User $user = null)
377. {
378. $version = (float) ltrim((string) $request->headers->get('X-Accept-Version'), 'v');
379. $callRequest = new CallRequest();
381. $currentUrl = $request->getUri();
382. if (str_contains($currentUrl, 'v2')) {
383. if (!$user = $this->getUser() && $version <= 2.13) {
384. throw new AccessDeniedHttpException();
385. }
386. }
388. $form = $this->createForm(QuickLeadType::class, null, [
389. 'method' => 'POST',
390. 'csrf_protection' => false,
391. ]);
393. $form->handleRequest($request);
394. $lead = $form->getData();
396. /** @var $userManager \FOS\UserBundle\Model\UserManagerInterface */
397. $userManager = $this->fosUserManager;
398. $aqarmapUserManager = $this->userManager;
399. $hasEmail = !$lead['isAutoGeneratedEmail'];
401. $phoneManager = $this->phoneManager;
402. $originalPhoneNumber = $lead['phone'];
403. $countryCode = $lead['countryCode'];
404. $phoneNumber = $phoneManager->trimZero($lead['phone'], $countryCode);
406. /** @var User $user */
407. $user = $userManager->findUserByEmail($lead['email']);
409. if (!$user && !$hasEmail) {
410. $user = $aqarmapUserManager->findLatestByPhone($phoneNumber, $countryCode);
411. }
413. if (!$user && $hasEmail) {
414. $user = $aqarmapUserManager->findAndReplaceUserAndEmail($phoneNumber, $lead['email'], $countryCode);
415. }
417. if (!$user) {
418. $user = $userManager->createUser();
419. $user
420. ->setFullName($lead['name'])
421. ->setPhoneNumber($lead['phone'])
422. ->setTempOriginalPhoneNumber($originalPhoneNumber)
423. ->setTempCountryCode($lead['countryCode'])
424. ->setEmail($lead['email'])
425. ->setHasEmail($hasEmail)
426. ->setLanguage('ar');
428. $user = $aqarmapUserManager->quickRegistration($form, $user, $request);
429. }
431. $phone = $phoneManager->addNewUserPhone($phoneNumber, $lead['countryCode'], $user, true, false, null, $originalPhoneNumber);
432. $userManager->updateUser($user);
433. $userManager->reloadUser($user);
434. $callRequest->setPhone($phone->getPhone());
435. $callRequest->setLeadFullName($request->request->get('name'));
436. $callRequest->setLeadEmail($request->request->get('email'));
438. $campaign = $request->request->get('campaign');
440. $callRequest->setUser($user);
441. $callRequest->setListing($listing);
443. $this->callRequestManager->submitCallRequest($callRequest, $campaign);
445. return true;
446. }
448. /**
449. * Add New User Listing.
450. *
451. * @return View|Form
452. */
453. #[Rest\Post('/api/v2/listing', options: ['i18n' => false], name: 'aqarmap_api_add_listing')]
454. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'ROLE_USER')]
455. #[OA\Parameter(name: 'listing', in: 'query', description: '', required: false)]
456. #[OA\Response(response: 201, description: 'Returned when successfully created')]
457. #[OA\Response(response: 400, description: 'Returned when validation error')]
458. public function addListing(Request $request)
459. {
460. $form = $this->createForm(ListingApiType::class, $listing = new Listing(), [
461. 'csrf_protection' => false,
462. ]);
464. $form->handleRequest($request);
466. if ($form->isSubmitted() && $form->isValid()) {
467. if ($this->getUser()->getPhoneNumber()) {
468. $listing->addPhone(new ListingPhone($this->getUser()->getPhoneNumber()));
469. }
470. $listingManager = $this->listingService;
471. $listing->setUser($this->getUser());
472. $listing->setStatus(ListingStatus::DRAFT);
474. $listingManager->saveListing($listing);
476. $listingEvent = new ListingEvent($listing);
477. $this->dispatcher->dispatch($listingEvent, 'aqarmap.listing.submitted');
479. return View::create()->setData($listing)->setStatusCode(Response::HTTP_CREATED);
480. }
482. return View::create()->setData($form)->setStatusCode(Response::HTTP_BAD_REQUEST);
483. }
485. /**
486. * Create Single Listing Note.
487. */
488. #[Rest\Post('/api/v2/listing/{id}/note', options: ['i18n' => false])]
489. #[Rest\RequestParam(name: 'body', description: 'Note Body')]
490. #[Rest\RequestParam(name: 'source', description: 'Supported sources: 1 = Website, 2 = Consumer App, 3 = Live App')]
491. #[Rest\RequestParam(name: 'last_modified_at', description: 'dateTime')]
492. #[Rest\RequestParam(name: 'created_at', description: 'dateTime')]
493. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'ROLE_USER')]
494. public function postListingSingleNote(Request $request, #[\Symfony\Bridge\Doctrine\Attribute\MapEntity(converter: 'querystring', mapping: ['listing' => 'id'])]
495. Listing $listing, ListingNoteRepository $listingNoteRepository, EntityManagerInterface $em)
496. {
497. $currentUser = $this->getUser();
499. $listingNote = $listingNoteRepository->findOneBy([
500. 'user' => $currentUser,
501. 'listing' => $listing,
502. ]);
504. if (empty($listingNote)) {
505. $listingNote = new ListingNote();
506. $listingNote->setUser($currentUser);
507. $listingNote->setListing($listing);
508. $listingNote->setCreatedAt(new \DateTime());
509. }
511. $form = $this->createForm(ListingNoteType::class, $listingNote);
513. $form->handleRequest($request);
515. if ($form->isSubmitted() && $form->isValid()) {
516. $em->persist($listingNote);
517. $em->flush();
519. return $this->json([
520. 'message' => 'Successfully submitted',
521. ], Response::HTTP_CREATED);
522. }
524. return $this->json([
525. 'message' => 'Error occurred',
526. ], Response::HTTP_BAD_REQUEST);
527. }
529. /**
530. * Create Bulk Listing Note.
531. *
532. * @return array
533. */
534. #[Rest\Post('/api/v2/listing/note', options: ['i18n' => false])]
535. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'ROLE_USER')]
536. public function postListingBulkNote(Request $request)
537. {
538. $listingNoteService = $this->listingNoteService;
540. $listingNoteService->addBulk($request);
542. return $this->respond('Note Added Successfully!');
543. }
545. /**
546. * Update Listing.
547. *
548. * @return View|Form
549. */
550. #[Rest\Post('/api/v2/listing/{id}', options: ['i18n' => false], name: 'aqarmap_api_update_listing')]
551. #[Rest\View]
552. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'ROLE_OWNER', subject: 'listing')]
553. #[OA\Parameter(name: 'listing', in: 'query', description: '', required: false)]
554. #[OA\Response(response: 200, description: 'Returned when successfully Updated')]
555. #[OA\Response(response: 400, description: 'Returned when validation error')]
556. public function updateListing(Listing $listing, Request $request)
557. {
558. $listing->clearAttributes();
559. $form = $this->createForm(ListingApiType::class, $listing, [
560. 'csrf_protection' => false,
561. ]);
563. $form->handleRequest($request);
564. if ($form->isSubmitted() && $form->isValid()) {
565. if ($this->getUser()->getPhoneNumber()) {
566. $listing->addPhone(new ListingPhone($this->getUser()->getPhoneNumber()));
567. }
568. $listingManager = $this->listingService;
569. $listingManager->saveListing($listing);
571. $listingEvent = new ListingEvent($listing);
572. $this->dispatcher->dispatch($listingEvent, 'aqarmap.listing.submitted');
574. return View::create()->setData($listing)->setStatusCode(Response::HTTP_OK);
575. }
577. return View::create()->setData($form)->setStatusCode(Response::HTTP_BAD_REQUEST);
578. }
580. /**
581. * Upload listing photos.
582. *
583. * @return View|array
584. */
585. #[Rest\Post('/api/v2/listing/{id}/photos', options: ['i18n' => false], name: 'aqarmap_api_upload_listing_photos')]
586. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'ROLE_OWNER', subject: 'listing')]
587. #[OA\Parameter(name: 'photos', in: 'query', description: '', required: false)]
588. #[OA\Response(response: 201, description: 'Returned when successfully created')]
589. #[OA\Response(response: 400, description: 'Returned when validation error')]
590. public function upload(Request $request, Listing $listing)
591. {
592. $form = $this->createForm(PhotoType::class, null, [
593. 'csrf_protection' => false,
594. ]);
596. $form->handleRequest($request);
597. if ($form->isSubmitted() && $form->isValid()) {
598. $outputFiles = [];
599. $listingManager = $this->listingService;
600. $maxOrder = $listingManager->getMaxListingPhotoOrder($listing);
601. foreach ($form->get('file')->getData() as $index => $file) {
602. $photo = new Photo();
603. $photo->setFile($file);
605. $listingPhoto = new ListingPhoto();
606. $listingPhoto->setFile($photo);
607. $listingPhoto->setCaption($photo->getFile()->getClientOriginalName());
608. $listingPhoto->setOrder($maxOrder + $index + 1);
610. $outputFiles[] = $listingPhoto;
611. $listing->addPhoto($listingPhoto);
612. }
613. $listingEvent = new ListingEvent($listing);
614. $this->dispatcher->dispatch($listingEvent, 'aqarmap.listing.submitted');
615. $listingManager->saveListing($listing);
617. return View::create()->setData($outputFiles)->setStatusCode(Response::HTTP_CREATED);
618. }
620. return [
621. 'listing' => $listing,
622. 'form' => $form->createView(),
623. ];
624. }
626. /**
627. * Delete Listing entity.
628. */
629. #[Rest\Delete('/api/v2/listing/{listing}', options: ['i18n' => false], name: 'aqarmap_api_delete_listing')]
630. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'ROLE_OWNER', subject: 'listing')]
631. #[OA\Response(response: 204, description: 'Returned when successfully Deleted')]
632. #[OA\Response(response: 404, description: 'Returned when Listing is not found')]
633. #[OA\Response(response: 403, description: 'Returned when you are trying to remove listing that not yours.')]
634. public function delete(Listing $listing)
635. {
636. if (\in_array('ROLE_PREVENT_DELETE_LISTING', $this->getUser()->getRoles())) {
637. throw new AccessDeniedHttpException("Forbidden, user don't have this permession.");
638. }
640. $listingManager = $this->listingService;
641. $listingManager->remove($listing, ListingStatus::USER_DELETED);
643. return new Response(null, Response::HTTP_NO_CONTENT);
644. }
646. /**
647. * Undelete Listing entity.
648. *
649. * @return array
650. */
651. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'ROLE_OWNER', subject: 'listing')]
652. #[Rest\View]
653. #[Rest\Get('/api/v2/listing/{listing}/undelete', name: 'aqarmap_api_undelete_listing', options: ['i18n' => false])]
654. #[OA\Response(response: 200, description: 'Returned when successfully undeleted')]
655. #[OA\Response(response: 404, description: 'Returned when Listing is not found or is not on user deleted state')]
656. #[OA\Response(response: 403, description: 'Returned when you are trying to remove listing that not yours.')]
657. public function undelete(Listing $listing)
658. {
659. if (ListingStatus::USER_DELETED != $listing->getStatus()) {
660. throw $this->createNotFoundException('Unable to find this listing.');
661. }
663. $listingManager = $this->listingService;
664. $listingManager->changeStatus($listing, ListingStatus::PENDING);
666. $listingEvent = new ListingEvent($listing);
667. $this->dispatcher->dispatch($listingEvent, 'aqarmap.listing.resubmitted');
669. return ['listing' => $listing];
670. }
672. /**
673. * Republish Listing entity.
674. *
675. * @return array
676. */
677. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'ROLE_OWNER', subject: 'listing')]
678. #[Rest\View]
679. #[OA\Response(response: 200, description: 'Returned when successfully Republished')]
680. #[OA\Response(response: 404, description: 'Returned when Listing is not found or is not on Expired state')]
681. #[OA\Response(response: 403, description: 'Returned when you are trying to Republish listing that not yours.')]
682. #[Rest\Get('/api/v2/listing/{listing}/relist', name: 'aqarmap_api_republish_listing', options: ['i18n' => false])]
683. public function relist(Listing $listing)
684. {
685. if (ListingStatus::EXPIRED != $listing->getStatus()) {
686. throw $this->createNotFoundException('Unable to find this listing.');
687. }
689. $em = $this->managerRegistry->getManager();
690. $listingRepo = $em->getRepository(Listing::class);
692. $relistChild = $listingRepo->getRelistChild($listing);
693. // If the expired listing already republished before .. return the republished version.
694. if ($relistChild) {
695. return ['listing' => $relistChild];
696. }
698. $listingManager = $this->listingService;
699. $listing = $listingManager->relist($listing);
701. $listingEvent = new ListingEvent($listing);
702. $this->dispatcher->dispatch($listingEvent, 'aqarmap.listing.resubmitted');
704. return ['listing' => $listing];
705. }
707. /**
708. * Feature A Listing.
709. *
710. * @return View
711. */
712. #[Rest\Post('/api/v2/listing/{listing}/feature', options: ['i18n' => false], name: 'aqarmap_api_feature_listing')]
713. #[Rest\RequestParam(name: 'type', description: 'Feature Type, 1 for payment, 2 for making it featured')]
714. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'ROLE_OWNER', subject: 'listing')]
715. public function feature(Listing $listing, Request $request)
716. {
717. $type = $request->get('type');
718. if (!$type) {
719. throw new BadRequestHttpException('Please Specify the feature type');
720. }
722. $matcher = $this->listingRuleMatcher;
723. $listingRule = $matcher->match($listing);
724. $translator = $this->translator;
726. $featuredDuration = $listingRule['featured_duration'];
727. $featuredFees = $listingRule['featured_fees'];
729. if (ListingFeatures::FEATURED == $type) {
730. // Check if there is a value for featured_duration & featured_fees
731. if (empty($featuredDuration) || empty($featuredFees)) {
732. throw new LogicHttpException($translator->trans('Making a listing Featured is not available for this listing.', [], 'exceptions'));
733. }
735. try {
736. $this->listingService->makeItFeatured(
737. $listing,
738. [
739. 'featuredFees' => $featuredFees,
740. 'featuredDuration' => $featuredDuration,
741. 'listingFeaturedType' => ListingFeaturedTypes::FEATURED,
742. 'listingFeature' => $type,
743. ]
744. );
745. } catch (\Exception $e) {
746. throw new LogicHttpException($translator->trans($e->getMessage(), [], 'exceptions'));
747. }
748. } elseif (ListingFeatures::PAID == $type) {
749. /** @var \Aqarmap\Bundle\CreditBundle\Services\CreditManager $creditManager */
750. $creditManager = $this->creditManager;
752. if ($listing->getPublicationCredit()) {
753. throw new LogicHttpException($translator->trans('credit.already_paid'));
754. } elseif ($listingRule['publication_fees'] > $creditManager->getBalance($listing->getUser())) {
755. throw new LogicHttpException($translator->trans('credit.not_enough_credits'));
756. }
757. // Subtract publication fees
758. $credits = $creditManager->deduction($listing->getUser(), $listingRule['publication_fees'], 'Listing Fees', CreditStatus::PENDING);
759. foreach ($credits as $credit) {
760. if ($credit instanceof Credit) {
761. $this->listingService->addFeature($listing, ListingFeatures::PAID, null, $credit);
762. }
763. }
765. $listingEvent = new ListingEvent($listing);
766. $this->dispatcher->dispatch($listingEvent, 'aqarmap.listing.submitted');
767. }
769. return View::create()->setData(['listing' => $listing]);
770. }
772. // -------------------------------------------------------------------------//
773. // ++++++++++++++ Quick contact seller & call request Actions +++++++++++++++//
774. // -------------------------------------------------------------------------//
775. /**
776. * ).
777. *
778. * @return bool|Form|array
779. *
780. * @throws AccessDeniedHttpException
781. *
782. * ===============================================================
783. * |
784. * | DEPRECATED: USE QuickCreateLeadAction::LeadController instead
785. * |
786. * ===============================================================
787. */
788. #[Rest\Post('/api/v2/listing/{listing}/quick_create_lead', options: ['i18n' => false], name: 'aqarmap_api_listing_quick_create_lead')]
789. #[Rest\QueryParam(name: 'campaign', description: 'Campaign Name')]
790. #[Rest\QueryParam(name: 'country_code', default: null, description: 'Country Code')]
791. #[Rest\View(serializerGroups: ['Default', 'Details'])]
792. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
793. public function quickCreateLead(Request $request, Listing $listing)
794. {
795. $form = $this->createForm(QuickCreateLeadFormType::class, null, [
796. 'method' => 'POST',
797. 'csrf_protection' => false,
798. ]);
799. $form->handleRequest($request);
801. if ($form->isSubmitted() && $form->isValid()) {
802. $lead = $form->getData();
804. /** @var $userManager \FOS\UserBundle\Model\UserManagerInterface */
805. $userManager = $this->fosUserManager;
806. $leadModel = new LeadModel();
808. try {
809. /** @var User $user */
810. if ($user = $userManager->findUserByEmail($form->get('email')->getData())) {
811. $phone = $this->phoneManager->addNewUserPhone(
812. $lead['phoneNumber'],
813. '+'.str_replace(' ', '', $request->get('country_code')),
814. $user,
815. true,
816. true,
817. CountryCodes::getCountryFromCodeNumber('+'.str_replace(' ', '', $request->get('country_code'))),
818. $lead['phoneNumber']
819. );
820. $userManager->updateUser($user);
821. $leadModel->setUser($user);
822. } else {
823. $user = $userManager->createUser();
825. $user
826. ->setFullName($lead['fullName'])
827. ->setEmail($lead['email'])
828. ->setLanguage($request->getLocale());
830. $user = $this->userManager->quickRegistration($form, $user, $request);
832. $phone = $this->phoneManager->addNewUserPhone(
833. $lead['phoneNumber'],
834. '+'.str_replace(' ', '', $request->get('country_code')),
835. $user,
836. true,
837. true,
838. CountryCodes::getCountryFromCodeNumber('+'.str_replace(' ', '', $request->get('country_code'))),
839. $lead['phoneNumber']
840. );
842. $userManager->reloadUser($user);
843. $leadModel->setUser($user);
844. }
845. } catch (\Exception) {
846. return [
847. 'status' => 'error',
848. 'message' => 'Cannot create a user.',
849. ];
850. }
852. if ($user) {
853. try {
854. $leadModel->setEmail($lead['email']);
855. $leadModel->setName($lead['fullName']);
856. $leadModel->setPhone($phone->getPhone());
857. $leadModel->setCampaign($request->request->get('campaign'));
858. $leadModel->setMessage($form->get('message')->getData());
859. $leadModel->setListing($listing);
861. $this->listingService->quickCreateLead($leadModel);
863. return [
864. 'status' => 'ok',
865. ];
866. } catch (\Exception) {
867. return [
868. 'status' => 'error',
869. 'message' => 'Cannot create the lead.',
870. ];
871. }
872. }
873. }
875. return $form;
876. }
878. /**
879. * Get Listing Rules.
880. *
881. * )
882. *
883. * @return array
884. */
885. #[Rest\Get('/api/v2/listing/{id}/rules', options: ['i18n' => false], name: 'aqarmap_api_get_listing_rules')]
886. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'ROLE_OWNER', subject: 'listing')]
887. #[Rest\View]
888. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
889. public function getListingRules(Listing $listing)
890. {
891. $listingMatcher = $this->listingRuleMatcher;
892. $rules = $listingMatcher->match($listing);
894. return ['rules' => $rules];
895. }
897. /**
898. * Get Listing Note.
899. *
900. * @return array
901. */
902. #[Rest\Get('/api/v2/listing/{id}/note', options: ['i18n' => false], name: 'aqarmap_api_get_listing_note')]
903. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'ROLE_USER')]
904. #[Rest\View]
905. #[OA\Parameter(name: 'propertyType', in: 'query', description: 'propertyType of the unites', required: false)]
906. #[OA\Parameter(name: 'section', in: 'query', description: 'Section of the unites', required: false)]
907. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
908. public function getListingNote(Listing $listing)
909. {
910. /** @var EntityManager $em */
911. $em = $this->managerRegistry->getManager();
912. $listingNoteRepo = $em->getRepository(ListingNote::class);
914. return $listingNoteRepo->findOneBy([
915. 'user' => $this->getUser(),
916. 'listing' => $listing,
917. ]);
918. }
920. /**
921. * Get account statistics (Listings Statistics).
922. *
923. * @throws \Exception
924. */
925. #[Rest\Get('/api/user/listings/statistics', requirements: ['id' => '\d+'], options: ['expose' => true, 'i18n' => false], name: 'aqarmap_api_get_user_listings_rates_counts')]
926. #[Rest\Post('/api/v2/user/listings/statistics', options: ['i18n' => false], name: 'aqarmap_api_get_user_listings_rates_counts_v2')]
927. #[Rest\View(serializerGroups: ['Default', 'Details'])]
928. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'ROLE_USER')]
929. public function getUserListingsPerformanceStatistics(Request $request, #[\Symfony\Bridge\Doctrine\Attribute\MapEntity(isOptional: 'true', converter: 'querystring', mapping: ['user' => 'id'])]
930. ?User $user = null): View
931. {
932. $isSubAccount = null != $user && $this->getUser() === $user->getParent();
933. $startDate = null;
934. $period = $request->query->get('period', null);
936. if (!$this->getUser() && !$isSubAccount) {
937. throw new AccessDeniedHttpException();
938. }
940. $user = $user ?: $this->getUser();
942. if ('7Days' == $period) {
943. $startDate = date('Y-m-d', strtotime('-7 days'));
944. } elseif ('30Days' == $period) {
945. $startDate = date('Y-m-d', strtotime('-30 days'));
946. }
948. return $this->respond([
949. 'rates' => $this->listingService->getUserListingsPerformanceStatistics($user, $startDate, $period),
950. ]);
951. }
953. /**
954. * Generates XML file for Listings News feed for marketing purpose.
955. *
956. * @return Response
957. */
958. #[Rest\Get('/api/listings/feed/{platform}', options: ['expose' => true, 'i18n' => false], name: 'aqarmap_api_get_listings_news_feed', defaults: ['page' => 1])]
959. #[Rest\View(serializerGroups: ['Default', 'Details'])]
960. public function getNewsFeed($platform, Request $request)
961. {
962. $criteria = [];
963. $page = min($request->query->get('page') ?: 1, ListingNewsFeed::MAX_PAGES);
964. $limit = min($request->query->get('limit', 100), 100);
966. if ((int) $request->query->get('page', 1) > $page) {
967. throw new NotFoundHttpException('Exceeded maximum number of pages');
968. }
970. if ($request->query->get('ugc')) {
971. $data = explode(',', $request->query->get('ugc'));
972. $data = array_map('intval', $data);
973. $criteria['groupCategory'] = array_filter($data);
974. }
976. if ($request->query->get('ug')) {
977. $data = explode(',', $request->query->get('ug'));
978. $data = array_map('intval', $data);
979. $criteria['userGroup'] = array_filter($data);
980. }
982. if ($request->query->get('hl')) {
983. $criteria['locale'] = $request->query->get('hl');
984. }
986. if ($request->query->get('maxlead')) {
987. $criteria['maxlead'] = $request->query->get('maxlead');
988. }
990. if ($request->query->get('feat')) {
991. $criteria['feat'] = $request->query->get('feat');
992. }
994. if ($request->query->get('location')) {
995. $locations = $this->locationManager
996. ->buildLocationsArrayByParentId($request->query->get('location'));
998. if (!empty($locations)) {
999. $criteria['locations'] = $locations;
1000. }
1001. }
1003. if ($request->query->get('section')) {
1004. $data = explode(',', $request->query->get('section'));
1005. $data = array_map('intval', $data);
1006. $criteria['sections'] = array_filter($data);
1007. }
1009. $news = $this->listingNewsFeed;
1010. $offset = ($page - 1) * $limit;
1012. $excludedKeys = ['sections', 'maxlead'];
1013. if (!array_diff(array_keys($criteria), $excludedKeys)) {
1014. throw new BadRequestHttpException(sprintf('The request must contain parameters others than the following: %s', implode(', ', $excludedKeys)));
1015. }
1017. if ('json' == $request->query->get('format')) {
1018. return $this->responseJson($news->asJson($offset, $limit, $criteria));
1019. }
1021. return $this->responseXml($news->asXml($offset, $limit, $platform, $criteria));
1022. }
1024. /**
1025. * Get call log.
1026. *
1027. * @deprecated
1028. *
1029. * @return Response
1030. */
1031. #[Rest\Get('/api/listings/calllog', options: ['expose' => true, 'i18n' => false], name: 'aqarmap_api_get_listings_calllog')]
1032. #[Rest\View(serializerGroups: ['CallLog'])]
1033. public function getCallLog(Request $request)
1034. {
1035. $this->translatableListener->setTranslatableLocale($request->get('lang'));
1036. $em = $this->managerRegistry->getManager();
1038. $listings = $em
1039. ->getRepository(Listing::class)
1040. ->getByIds($this->logger->get());
1042. return View::create()->setData($listings);
1043. }
1045. /**
1046. * Remove call log.
1047. *
1048. * @return Response
1049. */
1050. #[Rest\Post('/api/listings/calllog', options: ['expose' => true, 'i18n' => false], name: 'aqarmap_api_remove_listings_calllog')]
1051. #[Rest\View]
1052. public function removeCallLog()
1053. {
1054. $this->logger->remove();
1056. return View::create()->setData([]);
1057. }
1059. /**
1060. * update listing fields.
1061. *
1062. * @return View
1063. */
1064. #[Rest\Post('api/listing/{id}/edit', options: ['i18n' => false, 'expose' => true], name: 'update_listing_field')]
1065. #[Rest\View(serializerGroups: ['Default', 'Details'])]
1066. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'ROLE_EDIT_REVIEW_LISTINGS')]
1067. public function update(Listing $listing, Request $request)
1068. {
1069. $listingManager = $this->listingManager;
1071. $isEnabled = $this->featureToggle
1072. ->isEnabled('web.mortgage.options');
1074. $mortgage = $request->get('eligibleForMortgage');
1075. $fields = $request->request->all();
1077. if ($isEnabled) {
1078. if (true == $mortgage) {
1079. $this->mortgageService->addEligibleMortgageTypes($listing);
1080. } else {
1081. $listingManager->setEligibleMortgageToNull($listing);
1082. }
1083. unset($fields['eligibleForMortgage']);
1084. }
1086. $this->dispatcher->dispatch(
1087. new ListingUpdatedEvent($listing, $fields),
1088. ListingUpdatedEvent::UPDATED
1089. );
1090. $listing = $listingManager->update($listing, $fields);
1092. if (ListingStatus::LIVE == $listing->getStatus()) {
1093. $listingManager->changeStatus($listing, ListingStatus::PENDING);
1094. }
1096. return $this->respond([
1097. 'listing' => $listing,
1098. 'msg' => 'Listing was updated successfully',
1099. ]);
1100. }
1102. /**
1103. * Get Photos Of The Given Listings.
1104. *
1105. * @return Response
1106. */
1107. #[Rest\Get('/api/listings/{listing}/photos', options: ['expose' => true, 'i18n' => false], name: 'aqarmap_api_get_listing_photos')]
1108. public function getListingPhotos(Listing $listing)
1109. {
1110. $listingPhotos = $listing->getPhotos();
1112. $listingPhotosData = [];
1114. foreach ($listingPhotos as $listingPhoto) {
1115. $listingPhotosData[] = [
1116. 'id' => $listingPhoto->getId(),
1117. 'type' => $listingPhoto->getType(),
1118. 'caption' => $listingPhoto->getCaption(),
1119. 'file' => $listingPhoto->getFile(),
1120. ];
1121. }
1123. return $this->respond($listingPhotosData);
1124. }
1126. /**
1127. * Get Photo Types.
1128. *
1129. * @return Response
1130. */
1131. #[Rest\Get('/api/listings/photoTypes', options: ['expose' => true, 'i18n' => false], name: 'aqarmap_api_get_listing_photo_types')]
1132. public function getPhotoTypes()
1133. {
1134. return $this->respond(PhotoTypes::getPhotoTypes());
1135. }
1137. /**
1138. * Upload Listing Photo.
1139. *
1140. * @return array
1141. *
1142. * @throws OptimisticLockException
1143. */
1144. #[Rest\Post('/api/listing/{id}/upload_photo', options: ['expose' => true, 'i18n' => false], name: 'aqarmap_api_admin_upload_listing_photo')]
1145. public function uploadListingPhoto(Listing $listing)
1146. {
1147. $outputFiles = [];
1148. $listingManager = $this->listingManager;
1149. $maxOrder = $listingManager->getMaxListingPhotoOrder($listing);
1151. $photo = new Photo();
1153. $file = $_FILES['file'];
1154. $file = new UploadedFile($file['tmp_name'], $file['name'], $file['type']);
1155. $photo->setFile($file);
1157. $listingPhoto = new ListingPhoto();
1158. $listingPhoto->setFile($photo);
1159. $listingPhoto->setCaption($photo->getFile()->getClientOriginalName());
1160. $listingPhoto->setOrder($maxOrder + 1);
1162. $outputFiles[] = $listingPhoto;
1163. $listing->addPhoto($listingPhoto);
1165. $em = $this->managerRegistry->getManager();
1166. $em->persist($listing);
1167. $em->flush();
1169. return $this->respond(['status' => 'OK']);
1170. }
1172. /**
1173. * Gets rate details of listing.
1174. */
1175. #[Rest\Get('/api/v2/listing/{listing}/rates', options: ['i18n' => false])]
1176. #[Rest\Get('/api/listing/{listing}/rates', options: ['expose' => true, 'i18n' => false], name: 'aqarmap_api_listing_rates_details')]
1177. #[Rest\View(serializerGroups: ['Rates'])]
1178. #[Cache(expires: '+1 week', maxage: '+1 week', smaxage: '+1 week', public: false, vary: ['Accept-Language', 'X-Accept-Version', 'Accept'])]
1179. public function getRateDetails(Listing $listing)
1180. {
1181. return $this->respond(
1182. current($this->listingRateService->getRatesDetails([$listing]))
1183. );
1184. }
1186. /**
1187. * @return View
1188. */
1189. #[Rest\Get('/api/v2/listing/{listing}/preview', options: ['i18n' => false])]
1190. #[Rest\Get('/api/listing/{listing}/preview', options: ['expose' => true, 'i18n' => false], name: 'aqarmap_api_listing_preview_data')]
1191. #[Rest\View(serializerGroups: ['Preview'])]
1192. public function getListingPreviewData(Listing $listing)
1193. {
1194. return $this->respond($listing);
1195. }
1197. /**
1198. * @return JsonResponse
1199. *
1200. * @throws \Exception
1201. */
1202. #[Rest\Get('/api/listing/{listing}/lead-analytics', options: ['i18n' => false, 'expose' => true], name: 'aqarmap_api_listing_lead_analytics')]
1203. public function getLeadAnalytics(Listing $listing)
1204. {
1205. $analytics = $this->listingService->getLeadAnalytics($listing);
1207. return $this->respond($analytics);
1208. }
1210. /**
1211. * @return string
1212. */
1213. #[Rest\Delete('/api/v2/listing/{listing}/favourite', options: ['i18n' => false])]
1214. #[Rest\Delete('/api/listing/{listing}/favourite', options: ['i18n' => false, 'expose' => true], name: 'aqarmap_api_remove_favourite_listing')]
1215. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'ROLE_USER')]
1216. public function deleteFavourite(Request $request)
1217. {
1218. $this->favouriteService->deleteByListing($request->attributes->get('listing'));
1220. return $this->respond('Favourite Deleted Successfully!');
1221. }
1223. /**
1224. * @return string
1225. */
1226. #[Rest\Delete('/api/v2/listing/{listing}/note', options: ['i18n' => false])]
1227. #[Rest\Delete('/api/listing/{listing}/note', options: ['i18n' => false, 'expose' => true], name: 'aqarmap_api_remove_listing_note')]
1228. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'ROLE_USER')]
1229. public function deleteNote(Request $request)
1230. {
1231. $this->listingNoteService->deleteByListing($request->attributes->get('listing'));
1233. return $this->respond('Note Deleted Successfully!');
1234. }
1236. /**
1237. * @return string
1238. */
1239. #[Rest\Post('/api/listing/{listing}/rate-review', options: ['i18n' => false, 'expose' => true], name: 'aqarmap_api_change_listing_rate_review_status')]
1240. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'ROLE_ADMIN')]
1241. public function rateReview(Request $request, Listing $listing)
1242. {
1243. $this->listingService->updateIsRateReviewed($listing, $request->request->get('isReviewed'));
1245. return $this->respond('Listing rate review status changed successfully');
1246. }
1248. /**
1249. * Get Similar Listings Count.
1250. *
1251. * )
1252. */
1253. #[Rest\Get('/api/listing/{id}/similar_listings_count', options: ['i18n' => false, 'expose' => true], name: 'aqarmap_api_get_similar_listings_count')]
1254. #[Rest\View(serializerGroups: ['Default', 'Details'])]
1255. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
1256. public function getSimilarListingsCount(Listing $listing): int
1257. {
1258. $listingManager = $this->listingService;
1260. try {
1261. $count = $listingManager->countSimilarListings($listing);
1262. } catch (\Exception $exception) {
1263. echo $exception->getMessage();
1264. $this->errorLogger->error(shell_exec("Error retriving similar listings count! {$exception->getMessage()}"));
1265. $count = 0;
1266. }
1268. return $count;
1269. }
1271. /**
1272. * ApiDoc(
1273. * resource = true,
1274. * section = "Listing",
1275. * description="Get Listings Objects with notes",
1276. * statusCodes={
1277. * 200="Returned when successful",
1278. * }
1279. * ).
1280. *
1281. * @return array
1282. */
1283. #[Rest\Get('/api/v2/listings/notes', options: ['i18n' => false])]
1284. #[Rest\Get('/api/listings/notes', options: ['i18n' => false, 'expose' => true], name: 'aqarmap_api_listing_notes_and_favourites')]
1285. #[Rest\QueryParam(name: 'from', description: '[favourites|notes]')]
1286. #[Rest\View(serializerGroups: ['Default', 'List'])]
1287. public function getListingsWithNotes(Request $request)
1288. {
1289. $listingsIdWithNotes = [];
1290. if ($content = $request->getContent()) {
1291. $listingsIdWithNotes = json_decode($content, true);
1292. }
1294. $listings = $this->managerRegistry->getRepository(Listing::class)
1295. ->getByIdsQuery(array_column($listingsIdWithNotes, 'listingId'));
1297. $pagination = $this->paginator->paginate(
1298. $listings,
1299. $request->query->get('page', 1),
1300. $request->query->get('limit', 10)
1301. );
1303. $data = $this->listingService->setStaticNotesFromPaginator($pagination, $listingsIdWithNotes);
1304. if ('favourites' == $request->query->get('from')) {
1305. return ['favourite' => $data];
1306. }
1308. return ['note' => $data];
1309. }
1311. /**
1312. * ApiDoc(
1313. * resource = true,
1314. * section = "Listing",
1315. * description="Get ApprovalRejectionWaitingTime",
1316. * statusCodes={
1317. * 200="Returned when successful",
1318. * }
1319. * ).
1320. *
1321. * @return array
1322. *
1323. * @throws \Exception
1324. */
1325. #[Rest\Get('/api/listing/arwt', options: ['i18n' => false, 'expose' => true], name: 'aqarmap_api_listing_arwt')]
1326. #[Rest\View]
1327. public function getApprovalRejectionWaitingTime(Request $request)
1328. {
1329. $criteria = array_merge(
1330. $request->query->all(),
1331. ['actionTime' => true]
1332. );
1333. $listingManager = $this->listingService;
1334. $listingExtension = $this->listingExtension;
1336. return [
1337. 'arwt' => $listingExtension->waited($listingManager->getApprovalRejectionWaitingTime($criteria)),
1338. ];
1339. }
1341. /**
1342. * filter Listing Children with property type (Project Units).
1343. *
1344. * @return array
1345. */
1346. #[Rest\Get('/api/listing/{id}/children', options: ['i18n' => false], name: 'aqarmap_api_get_listing_children')]
1347. #[Rest\QueryParam(name: 'propertyType', description: 'propertyType of the unites')]
1348. #[Rest\View(serializerGroups: ['UnitDetails'])]
1349. #[OA\Parameter(name: 'propertyType', in: 'query', description: 'propertyType of the unites', required: false)]
1350. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
1351. public function filterListingChildren(Listing $listing, #[\Symfony\Bridge\Doctrine\Attribute\MapEntity(isOptional: 'true', converter: 'querystring', mapping: ['propertyType' => 'id'])]
1352. ?PropertyType $propertyType = null): View
1353. {
1354. if (!$this->getUser()) {
1355. throw new AccessDeniedHttpException();
1356. }
1358. return $this->respond($listing->getLiveChildren($propertyType));
1359. }
1361. /**
1362. * Api for clonning listing.
1363. */
1364. #[Rest\Post('/api/listing/{id}/clone', options: ['i18n' => false], name: 'aqarmap_api_clone_listing_children')]
1365. #[Rest\Post('/api/v2/listing/{id}/clone', options: ['i18n' => false], name: 'aqarmap_api_v2_clone_listing_children')]
1366. #[Rest\RequestParam(name: 'propertyType', description: 'propertyType of the unites')]
1367. #[Rest\RequestParam(name: 'section', description: 'Section of the unites')]
1368. #[\Symfony\Component\Security\Http\Attribute\IsGranted(attribute: 'IS_AUTHENTICATED_REMEMBERED')]
1369. #[Rest\View(serializerGroups: ['UnitDetails'])]
1370. #[OA\Parameter(name: 'propertyType', in: 'query', description: 'propertyType of the unites', required: false)]
1371. #[OA\Parameter(name: 'section', in: 'query', description: 'Section of the unites', required: false)]
1372. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
1373. public function cloneListing(Listing $sourceListing, #[\Symfony\Bridge\Doctrine\Attribute\MapEntity(converter: 'querystring', mapping: ['propertyType' => 'id'])]
1374. PropertyType $propertyType, #[\Symfony\Bridge\Doctrine\Attribute\MapEntity(converter: 'querystring', mapping: ['section' => 'id'])]
1375. Section $section): View
1376. {
1377. $syncedFields = $sourceListing->getParent() ? ListingSyncedFields::UNIT_FIELDS : ListingSyncedFields::PARENT_FIELDS;
1378. try {
1379. $listing = $this->listingManager->initializeListingForCloning($sourceListing, $propertyType, $section, $this->getUser());
1380. $this->listingManager->syncListingForProject(
1381. [
1382. 'targetListingId' => $listing->getId(),
1383. 'sourceListingId' => $sourceListing->getId(),
1384. 'syncedFields' => $syncedFields,
1385. 'targetListingSavedAt' => $listing->getUpdatedAt()->getTimestamp(),
1386. ]
1387. );
1389. return $this->respond($listing->getId());
1390. } catch (\Exception) {
1391. throw new \Exception('something went wrong');
1392. }
1393. }
1395. #[Rest\Get('/api/v2/listing/{listing}/top-seller', options: ['i18n' => false], name: 'aqarmap_api_listing_top_seller')]
1396. #[Rest\View(serializerGroups: ['TopCustomers'])]
1397. public function getListingTopSeller(Listing $listing, TopSellerRetrievalService $topSellerRetrievalService)
1398. {
1399. $topSeller = new TopSeller();
1400. $topSeller->setLocation($listing->getLocation()->getId());
1401. $topSeller->setSection($listing->getSection()->getId());
1402. $topSeller->setPropertyType($listing->getPropertyType()->getId());
1404. return $topSellerRetrievalService->getTopSellerPersonalData($topSeller);
1405. }
1407. #[Rest\Get('/api/v2/listing/{listing}/related-listings', options: ['i18n' => false], name: 'aqarmap_api_listing_related_listings')]
1408. #[Cache(expires: '+1 days', maxage: '+1 days', smaxage: '+1 days', public: true, vary: ['Accept-Language', 'X-Accept-Version', 'Accept'])]
1409. #[Rest\View(serializerGroups: ['RelatedListingsV2'])]
1410. public function getRelatedListing(Listing $listing, ListingManager $listingManager, ListingRepository $listingRepository)
1411. {
1412. try {
1413. $relatedListingsElasticResponse = $listingManager->getRelatedListingsElasticResponse($listing);
1415. $listingsQueryBuilder = $listingRepository->getListingsByIds(array_column($relatedListingsElasticResponse['items'], 'id'));
1417. return $listingsQueryBuilder->getQuery()->getResult();
1418. } catch (\Exception) {
1419. throw new \Exception('something went wrong');
1420. }
1421. }
1423. #[Rest\Post('/api/v2/listing/{id}/views', options: ['i18n' => false, 'expose' => true], requirements: ['id' => '\d+'], name: 'aqarmap_api_add_listing_views')]
1424. #[Rest\View]
1425. public function increaseListingViews(Listing $listing): array
1426. {
1427. try {
1428. $this->interactionService->increaseViews($listing, $this->getUser());
1430. return [
1431. 'status' => 'ok',
1432. 'message' => 'Views Created Successfully!',
1433. ];
1434. } catch (\Exception) {
1435. throw new \Exception('something went wrong');
1436. }
1437. }
1438. }