1. <?php
3. namespace Aqarmap\Bundle\ListingBundle\Controller\Api;
5. use App\Enum\Listing\SectionTypeEnum;
6. use App\Exception\BadRequestHttpException;
7. use App\Exception\LogicHttpException;
8. use App\Security\Voter\SubAccountPermissionVoter;
9. use Aqarmap\Bundle\CreditBundle\Constant\CreditStatus;
10. use Aqarmap\Bundle\CreditBundle\Entity\Credit;
11. use Aqarmap\Bundle\CreditBundle\Services\CreditManager;
12. use Aqarmap\Bundle\FeatureToggleBundle\Service\FeatureToggleManager;
13. use Aqarmap\Bundle\ListingBundle\Constant\CountryCodes;
14. use Aqarmap\Bundle\ListingBundle\Constant\LeadTypes;
15. use Aqarmap\Bundle\ListingBundle\Constant\ListingFeaturedTypes;
16. use Aqarmap\Bundle\ListingBundle\Constant\ListingFeatures;
17. use Aqarmap\Bundle\ListingBundle\Constant\ListingStatus;
18. use Aqarmap\Bundle\ListingBundle\Constant\ListingSyncedFields;
19. use Aqarmap\Bundle\ListingBundle\Constant\PhotoTypes;
20. use Aqarmap\Bundle\ListingBundle\Contracts\PhoneManagerInterface;
21. use Aqarmap\Bundle\ListingBundle\Entity\CallRequest;
22. use Aqarmap\Bundle\ListingBundle\Entity\Favourite;
23. use Aqarmap\Bundle\ListingBundle\Entity\Listing;
24. use Aqarmap\Bundle\ListingBundle\Entity\ListingPhone;
25. use Aqarmap\Bundle\ListingBundle\Entity\ListingPhoto;
26. use Aqarmap\Bundle\ListingBundle\Entity\Photo;
27. use Aqarmap\Bundle\ListingBundle\Entity\PropertyType;
28. use Aqarmap\Bundle\ListingBundle\Entity\Section;
29. use Aqarmap\Bundle\ListingBundle\Event\LeadEvent;
30. use Aqarmap\Bundle\ListingBundle\Event\ListingEvent;
31. use Aqarmap\Bundle\ListingBundle\Event\ListingUpdatedEvent;
32. use Aqarmap\Bundle\ListingBundle\Form\ContactSellerFormType;
33. use Aqarmap\Bundle\ListingBundle\Form\ListingApiType;
34. use Aqarmap\Bundle\ListingBundle\Form\PhotoType;
35. use Aqarmap\Bundle\ListingBundle\Form\QuickContactSellerType;
36. use Aqarmap\Bundle\ListingBundle\Form\QuickCreateLeadFormType;
37. use Aqarmap\Bundle\ListingBundle\Form\QuickLeadType;
38. use Aqarmap\Bundle\ListingBundle\Model\LeadModel;
39. use Aqarmap\Bundle\ListingBundle\Repository\ListingRepository;
40. use Aqarmap\Bundle\ListingBundle\Repository\SectionRepository;
41. use Aqarmap\Bundle\ListingBundle\Service\CallRequestManager;
42. use Aqarmap\Bundle\ListingBundle\Service\FavoriteNoteService;
43. use Aqarmap\Bundle\ListingBundle\Service\FavouriteService;
44. use Aqarmap\Bundle\ListingBundle\Service\InteractionService;
45. use Aqarmap\Bundle\ListingBundle\Service\LeadService;
46. use Aqarmap\Bundle\ListingBundle\Service\ListingManager;
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\Service\SectionService;
53. use Aqarmap\Bundle\ListingBundle\Service\V4\CompoundDetailService;
54. use Aqarmap\Bundle\ListingBundle\Twig\ListingExtension;
55. use Aqarmap\Bundle\MainBundle\Controller\Api\BaseController;
56. use Aqarmap\Bundle\MainBundle\Service\Setting;
57. use Aqarmap\Bundle\MessageBundle\Service\Composer;
58. use Aqarmap\Bundle\TopSellerBundle\Model\TopSeller;
59. use Aqarmap\Bundle\TopSellerBundle\Service\TopSellerRetrievalService;
60. use Aqarmap\Bundle\UserBundle\Entity\User;
61. use Aqarmap\Bundle\UserBundle\Services\UserManager;
62. use Doctrine\Common\Collections\Collection;
63. use Doctrine\ORM\EntityManagerInterface;
64. use Doctrine\ORM\OptimisticLockException;
65. use Doctrine\ORM\ORMException;
66. use FOS\RestBundle\Controller\Annotations as Rest;
67. use FOS\RestBundle\View\View;
68. use FOS\UserBundle\Model\UserManagerInterface;
69. use Gedmo\Translatable\TranslatableListener;
70. use Knp\Component\Pager\PaginatorInterface;
71. use OpenApi\Attributes as OA;
72. use Psr\Cache\InvalidArgumentException;
73. use Symfony\Bridge\Doctrine\Attribute\MapEntity;
74. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
75. use Symfony\Component\ExpressionLanguage\Expression;
76. use Symfony\Component\Form\Extension\Core\Type\TextType;
77. use Symfony\Component\Form\Form;
78. use Symfony\Component\HttpFoundation\File\UploadedFile;
79. use Symfony\Component\HttpFoundation\Request;
80. use Symfony\Component\HttpFoundation\Response;
81. use Symfony\Component\HttpKernel\Attribute\Cache;
82. use Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException;
83. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
84. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
85. use Symfony\Component\Security\Http\Attribute\IsGranted;
86. use Symfony\Component\Validator\Constraints\NotBlank;
87. use Symfony\Contracts\Translation\TranslatorInterface;
89. /**
90. * Class ListingController.
91. */
92. class ListingController extends BaseController
93. {
94. /**
95. * @var TokenStorageInterface
96. */
97. protected $tokenStorage;
99. /** @var FOSUserManager */
100. private $fosUserManager;
102. public function __construct(
103. private readonly Composer $messageComposer,
104. private readonly FavouriteService $favouriteService,
105. private readonly PaginatorInterface $paginator,
106. private readonly InteractionService $interactionService,
107. private readonly ListingManager $listingManager,
108. private readonly EventDispatcherInterface $dispatcher,
109. UserManagerInterface $fosUserManager,
110. private readonly TranslatorInterface $translator,
111. private readonly TranslatableListener $translatableListener,
112. private readonly UserManager $userManager,
113. private readonly ListingManager $listingService,
114. private readonly FavoriteNoteService $listingNoteService,
115. private readonly ListingRuleMatcher $listingRuleMatcher,
116. private readonly LocationManager $locationManager,
117. Setting $setting,
118. private readonly PhoneManagerInterface $phoneManager,
119. private readonly FeatureToggleManager $featureToggle,
120. private readonly ListingRateService $listingRateService,
121. TokenStorageInterface $tokenStorage,
122. private readonly LeadService $leadManager,
123. private readonly CallRequestManager $callRequestManager,
124. private readonly MortgageService $mortgageService,
125. private readonly CreditManager $creditManager,
126. private readonly ListingExtension $listingExtension,
127. private readonly ListingNewsFeed $listingNewsFeed,
128. private readonly EntityManagerInterface $entityManager,
129. private readonly \Doctrine\Persistence\ManagerRegistry $managerRegistry,
130. ) {
131. $this->fosUserManager = $fosUserManager;
132. $this->tokenStorage = $tokenStorage;
133. }
135. /**
136. * Get Listing.
137. *
138. * )
139. */
140. #[Rest\Get('/api/v2/listing/{id}', name: 'aqarmap_api_get_listing_v2', requirements: ['id' => '\d+'], options: ['i18n' => false])]
141. #[Rest\View(serializerGroups: ['Default', 'Details', 'Compound'])]
142. #[Cache(expires: '+2 hours', maxage: '+2 hours', smaxage: '+2 hours', public: false, vary: ['Accept-Language', 'X-Accept-Version', 'Accept'])]
143. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
144. public function getListing(Listing $listing): array
145. {
146. return ['listing' => $listing];
147. }
149. /**
150. * Listing details.
151. */
152. #[Rest\Get('/api/v4/listing/{id}', name: 'aqarmap_api_get_listing_v4', requirements: ['id' => '\d+'], options: ['i18n' => false])]
153. #[Rest\View(serializerGroups: ['listingDetails', 'listingDetailsWithLocationCompound'])]
154. #[Cache(expires: '+6 hours', maxage: '+6 hours', smaxage: '+6 hours', public: true, vary: ['Accept-Language', 'X-Accept-Version', 'Accept'])]
155. public function getListingDetails(int $id, ListingRepository $listingRepository, ListingManager $listingManager): array
156. {
157. $entityManagerFilters = $this->entityManager->getFilters();
159. if ($entityManagerFilters->isEnabled('softdeleteable')) {
160. $entityManagerFilters->disable('softdeleteable');
161. }
163. $listing = $listingRepository->find($id);
165. if (!$listing) {
166. $entityManagerFilters->enable('softdeleteable');
167. throw $this->createNotFoundException();
168. }
170. $result = ['listing' => $listingManager->serializeListing($listing)];
172. $entityManagerFilters->enable('softdeleteable');
174. return $result;
175. }
177. /**
178. * Get Listing Children V4.
179. */
180. #[Rest\Get('/api/v4/listing/{id}/children', name: 'aqarmap_api_get_listing_children_v4', requirements: ['id' => '\d+'], options: ['i18n' => false])]
181. #[Rest\View(serializerGroups: ['ProjectDetailsV4'])]
182. #[Cache(expires: '+6 hours', maxage: '+6 hours', smaxage: '+6 hours', public: true, vary: ['Accept-Language', 'X-Accept-Version', 'Accept'])]
183. public function getListingChildrenV4(Listing $listing, CompoundDetailService $compoundDetailService, Request $request, SectionRepository $sectionRepository): array
184. {
185. $saleSection = $sectionRepository->findOneBy(['type' => SectionTypeEnum::SALE]);
186. $rentSection = $sectionRepository->findOneBy(['type' => SectionTypeEnum::RENT]);
188. $compoundDetailService->getPropertyTypeChildrens($listing, $request->getLocale());
189. $livePropertyTypes = $listing->getPropertyTypeChildren();
191. $compoundDetailService->getPropertyTypeUnitsChildrens($listing, $saleSection->getId(), $request->getLocale());
192. $resalePropertyTypes = $listing->getPropertyTypeChildren();
194. $compoundDetailService->getPropertyTypeUnitsChildrens($listing, $rentSection->getId(), $request->getLocale());
195. $rentPropertyTypes = $listing->getPropertyTypeChildren();
197. return [
198. 'livePropertyTypes' => $livePropertyTypes,
199. 'resalePropertyTypes' => $resalePropertyTypes,
200. 'rentPropertyTypes' => $rentPropertyTypes,
201. ];
202. }
204. /**
205. * Get Listing Children (Project Units).
206. *
207. * )
208. *
209. * @return array
210. */
211. #[Rest\Get('/api/v2/listing/{id}/children', name: 'aqarmap_api_get_listing_children_v2', options: ['i18n' => false])]
212. #[Rest\View(serializerGroups: ['Default', 'Details'])]
213. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
214. public function getListingChildren(Listing $listing)
215. {
216. return $this->respond($listing->getLiveChildren());
217. }
219. /**
220. * @return Collection
221. *
222. * @throws ORMException
223. * @throws OptimisticLockException
224. */
225. #[Rest\Post('/api/v2/listing/{listing}/phones', name: 'aqarmap_api_get_listing_phones_v2', options: ['i18n' => false])]
226. #[Rest\View(serializerGroups: ['Default', 'Details'])]
227. #[OA\Parameter(name: 'lead', description: '', in: 'query', required: false)]
228. public function getListingPhone(Listing $listing, Request $request, ?User $user = null)
229. {
230. $version = (float) ltrim((string) $request->headers->get('X-Accept-Version'), 'v');
231. $leadModel = new LeadModel();
233. $currentUrl = $request->getUri();
234. if (str_contains($currentUrl, 'v2')) {
235. if (!$user = $this->getUser() && $version <= 2.13) {
236. throw new AccessDeniedHttpException();
237. }
238. }
240. $form = $this->createForm(QuickLeadType::class, null, [
241. 'method' => 'POST',
242. 'csrf_protection' => false,
243. ]);
245. $form->handleRequest($request);
246. $lead = $form->getData();
248. $phoneManager = $this->phoneManager;
249. $originalPhoneNumber = $lead['phone'];
250. $phoneNumber = $phoneManager->trimZero($lead['phone'], $lead['countryCode']);
252. $aqarmapUserService = $this->userManager;
253. $hasEmail = !$lead['isAutoGeneratedEmail'];
255. /** @var UserManagerInterface $userManager */
256. $userManager = $this->fosUserManager;
258. /** @var User $user */
259. $user = $userManager->findUserByEmail($lead['email']);
260. $countryCode = $lead['countryCode'];
262. if (!$user && !$hasEmail) {
263. $user = $aqarmapUserService->findLatestByPhone($phoneNumber, $countryCode);
264. }
266. if (!$user && $hasEmail) {
267. $user = $aqarmapUserService->findAndReplaceUserAndEmail($phoneNumber, $lead['email'], $countryCode);
268. }
270. if (!$user) {
271. $user = $userManager->createUser();
272. $user
273. ->setFullName($lead['name'])
274. ->setPhoneNumber($lead['phone'])
275. ->setTempOriginalPhoneNumber($originalPhoneNumber)
276. ->setTempCountryCode($lead['countryCode'])
277. ->setEmail($lead['email'])
278. ->setHasEmail($hasEmail)
279. ->setLanguage('ar');
281. $user = $aqarmapUserService->quickRegistration($form, $user, $request);
282. }
284. $phone = $phoneManager->addNewUserPhone($phoneNumber, $lead['countryCode'], $user, true, false, null, $originalPhoneNumber);
285. $userManager->updateUser($user);
286. $userManager->reloadUser($user);
287. $leadModel->setPhone($phone->getPhone());
288. $leadModel->setName($request->request->get('name', $lead['name']));
289. $leadModel->setEmail($request->request->get('email', $lead['email']));
291. $leadService = $this->leadManager;
292. $leadModel->setLeadType(LeadTypes::SHOW_PHONE);
293. $leadModel->setListing($listing);
294. $leadModel->setSource('api');
295. $leadModel->setUser($user);
297. $lead = $leadService->addLead($leadModel);
299. if ($lead) {
300. $this->dispatcher->dispatch(
301. new LeadEvent(
302. $listing,
303. $user,
304. $lead
305. ),
306. 'aqarmap.listing.show_seller_number'
307. );
308. }
310. return $listing->getPhones();
311. }
313. /**
314. * @return bool|Form
315. *
316. * @throws AccessDeniedHttpException
317. */
318. #[Rest\Post('/api/v2/listing/{listing}/contact_seller', name: 'aqarmap_api_listing_contact_seller_v2', options: ['i18n' => false])]
319. #[Rest\QueryParam(name: 'campaign', description: 'Campaign Name')]
320. #[Rest\View(serializerGroups: ['Default', 'Details'])]
321. #[OA\Parameter(name: 'campaign', description: 'Campaign Name', in: 'query', required: false)]
322. #[OA\Parameter(name: 'contact_seller', description: '', in: 'query', required: false)]
323. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
324. public function contactSeller(Request $request, Listing $listing, ?User $user = null)
325. {
326. $currentUrl = $request->getUri();
327. if (str_contains($currentUrl, 'v2')) {
328. if (!$user = $this->getUser()) {
329. throw new AccessDeniedHttpException();
330. }
331. }
333. $form = $this->createForm(ContactSellerFormType::class, null, [
334. 'method' => 'POST',
335. 'csrf_protection' => false,
336. ]);
337. $form->handleRequest($request);
339. if ($form->isSubmitted() && $form->isValid()) {
340. // Get campaign name
341. $campaign = $request->query->get('campaign');
343. $message = $form->getData();
344. // Send contact seller message and send a lead
345. $composer = $this->messageComposer;
346. $composer
347. ->setSender($user)
348. ->compose($message['message'], $listing, $campaign);
350. return true;
351. }
353. return $form;
354. }
356. /**
357. * @return Response $response
358. *
359. * @throws \Exception
360. */
361. #[Rest\Post('/api/v2/listing/{listing}/contact_seller/quick', name: 'aqarmap_api_listing_quick_contact_seller_v2', options: ['i18n' => false])]
362. #[Rest\QueryParam(name: 'campaign', description: 'Campaign Name')]
363. #[Rest\View(serializerGroups: ['Default', 'Details'])]
364. #[OA\Parameter(name: 'campaign', description: 'Campaign Name', in: 'query', required: false)]
365. #[OA\Parameter(name: 'contact_seller', description: '', in: 'query', required: false)]
366. #[OA\Response(response: 201, description: 'Returned when user created and message sent successfully')]
367. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
368. #[OA\Response(response: 403, description: 'Returned when parameter is missing')]
369. public function contactSellerWithQuickRegistration(Request $request, Listing $listing): Response
370. {
371. if (!$this->isValidQuickContactSellerParameters($request->get('contact_seller'))) {
372. return new Response(null, Response::HTTP_FORBIDDEN);
373. }
375. $form = $this->createForm(QuickContactSellerType::class, null, [
376. 'method' => 'POST',
377. 'csrf_protection' => false,
378. ]);
379. $form->handleRequest($request);
380. if ($form->isSubmitted() && !$form->isValid()) {
381. return new Response(null, Response::HTTP_FORBIDDEN);
382. }
384. $userManager = $this->userManager;
385. $fromData = $form->getData();
386. $user = $userManager->createQuickUser($request, $form);
387. $campaign = $request->query->get('campaign');
389. $composer = $this->messageComposer;
390. $composer
391. ->setSender($user)
392. ->compose($fromData['message'], $listing, $campaign);
394. return new Response(null, Response::HTTP_CREATED);
395. }
397. private function isValidQuickContactSellerParameters(array $parameters): bool
398. {
399. if (
400. !\array_key_exists('email', $parameters)
401. || !\array_key_exists('phone', $parameters)
402. || !\array_key_exists('countryCode', $parameters)
403. ) {
404. return false;
405. }
407. return true;
408. }
410. /**
411. * @return bool|array
412. */
413. #[Rest\Post('/api/v2/listing/{listing}/call_request', name: 'aqarmap_api_listing_call_request_v2', options: ['i18n' => false])]
414. #[Rest\QueryParam(name: 'campaign', description: 'Campaign Name')]
415. #[Rest\View(serializerGroups: ['Default', 'Details'])]
416. public function callRequest(Listing $listing, Request $request, ?User $user = null)
417. {
418. $version = (float) ltrim((string) $request->headers->get('X-Accept-Version'), 'v');
419. $callRequest = new CallRequest();
421. $currentUrl = $request->getUri();
422. if (str_contains($currentUrl, 'v2')) {
423. if (!$user = $this->getUser() && $version <= 2.13) {
424. throw new AccessDeniedHttpException();
425. }
426. }
428. $form = $this->createForm(QuickLeadType::class, null, [
429. 'method' => 'POST',
430. 'csrf_protection' => false,
431. ]);
433. $form->handleRequest($request);
434. $lead = $form->getData();
436. /** @var UserManagerInterface $userManager */
437. $userManager = $this->fosUserManager;
438. $aqarmapUserManager = $this->userManager;
439. $hasEmail = !$lead['isAutoGeneratedEmail'];
441. $phoneManager = $this->phoneManager;
442. $originalPhoneNumber = $lead['phone'];
443. $countryCode = $lead['countryCode'];
444. $phoneNumber = $phoneManager->trimZero($lead['phone'], $countryCode);
446. /** @var User $user */
447. $user = $userManager->findUserByEmail($lead['email']);
449. if (!$user && !$hasEmail) {
450. $user = $aqarmapUserManager->findLatestByPhone($phoneNumber, $countryCode);
451. }
453. if (!$user && $hasEmail) {
454. $user = $aqarmapUserManager->findAndReplaceUserAndEmail($phoneNumber, $lead['email'], $countryCode);
455. }
457. if (!$user) {
458. $user = $userManager->createUser();
459. $user
460. ->setFullName($lead['name'])
461. ->setPhoneNumber($lead['phone'])
462. ->setTempOriginalPhoneNumber($originalPhoneNumber)
463. ->setTempCountryCode($lead['countryCode'])
464. ->setEmail($lead['email'])
465. ->setHasEmail($hasEmail)
466. ->setLanguage('ar');
468. $user = $aqarmapUserManager->quickRegistration($form, $user, $request);
469. }
471. $phone = $phoneManager->addNewUserPhone($phoneNumber, $lead['countryCode'], $user, true, false, null, $originalPhoneNumber);
472. $userManager->updateUser($user);
473. $userManager->reloadUser($user);
474. $callRequest->setPhone($phone->getPhone());
475. $callRequest->setLeadFullName($request->request->get('name'));
476. $callRequest->setLeadEmail($request->request->get('email'));
478. $campaign = $request->request->get('campaign');
480. $callRequest->setUser($user);
481. $callRequest->setListing($listing);
483. $this->callRequestManager->submitCallRequest($callRequest, $campaign);
485. return true;
486. }
488. /**
489. * Add New User Listing.
490. *
491. * @return View|Form
492. */
493. #[Rest\Post('/api/v2/listing', name: 'aqarmap_api_add_listing', options: ['i18n' => false])]
494. #[IsGranted(attribute: 'ROLE_USER')]
495. #[IsGranted(attribute: SubAccountPermissionVoter::MANAGE_LISTINGS)]
496. #[OA\Parameter(name: 'listing', description: '', in: 'query', required: false)]
497. #[OA\Response(response: 201, description: 'Returned when successfully created')]
498. #[OA\Response(response: 400, description: 'Returned when validation error')]
499. public function addListing(Request $request)
500. {
501. $form = $this->createForm(ListingApiType::class, $listing = new Listing(), [
502. 'csrf_protection' => false,
503. ]);
505. $form->handleRequest($request);
507. if ($form->isSubmitted() && $form->isValid()) {
508. if ($this->getUser()->getPhoneNumber()) {
509. $listing->addPhone(new ListingPhone($this->getUser()->getPhoneNumber()));
510. }
511. $listingManager = $this->listingService;
512. // Left unset so ListingListener can centralise ownership under the main account and
513. // record the caller as the publisher.
514. $listing->setStatus(ListingStatus::DRAFT);
516. $listingManager->saveListing($listing);
518. $listingEvent = new ListingEvent($listing);
519. $this->dispatcher->dispatch($listingEvent, 'aqarmap.listing.submitted');
521. return View::create()->setData($listing)->setStatusCode(Response::HTTP_CREATED);
522. }
524. return View::create()->setData($form)->setStatusCode(Response::HTTP_BAD_REQUEST);
525. }
527. /**
528. * Create Single Listing Note.
529. */
530. #[Rest\Post('/api/v2/listing/{id}/note', options: ['i18n' => false])]
531. #[Rest\RequestParam(name: 'body', description: 'Note Body')]
532. #[Rest\RequestParam(name: 'source', description: 'Supported sources: 1 = Website, 2 = Consumer App, 3 = Live App')]
533. #[Rest\RequestParam(name: 'last_modified_at', description: 'dateTime')]
534. #[Rest\RequestParam(name: 'created_at', description: 'dateTime')]
535. #[IsGranted(attribute: 'ROLE_USER')]
536. #[OA\Tag(name: 'Listing Notes')]
537. #[OA\Tag(name: 'User Activity')]
538. #[OA\Tag(name: 'Favorites')]
539. #[OA\RequestBody(
540. description: 'Note body to be added.',
541. required: true,
542. content: new OA\MediaType(
543. mediaType: 'application/x-www-form-urlencoded',
544. schema: new OA\Schema(
545. required: ['body'],
546. properties: [
547. new OA\Property(property: 'body', type: 'string', description: 'The note content.'),
548. ],
549. ),
550. ),
551. )]
552. #[OA\Response(response: 201, description: 'Returned when note is created or updated')]
553. #[OA\Response(response: 400, description: 'Returned when body is missing')]
554. public function postListingSingleNote(
555. Request $request,
556. Listing $listing,
557. ) {
558. $form = $this->createFormBuilder(null, ['csrf_protection' => false])
559. ->add('body', TextType::class, [
560. 'constraints' => [new NotBlank()],
561. ])
562. ->getForm();
563. $form->handleRequest($request);
565. if ($form->isSubmitted() && $form->isValid()) {
566. $data = $form->getData();
567. $this->listingNoteService->addOne($listing, [
568. 'body' => $data['body'],
569. ]);
571. return $this->json([
572. 'message' => 'Successfully submitted',
573. ], Response::HTTP_CREATED);
574. }
576. return $this->json(['message' => 'Error occurred'], Response::HTTP_BAD_REQUEST);
577. }
579. /**
580. * Create Bulk Listing Note.
581. *
582. * @return array
583. */
584. #[Rest\Post('/api/listing/note', options: ['i18n' => false])]
585. #[Rest\Post('/api/v2/listing/note', options: ['i18n' => false])]
586. #[IsGranted(attribute: 'ROLE_USER')]
587. #[OA\Tag(name: 'Listing Notes')]
588. #[OA\Tag(name: 'User Activity')]
589. public function postListingBulkNote(Request $request)
590. {
591. $listingNoteService = $this->listingNoteService;
593. $listingNoteService->addBulk($request);
595. return $this->respond('Note Added Successfully!');
596. }
598. /**
599. * Update Listing.
600. *
601. * @return View|Form
602. */
603. #[Rest\Post('/api/v2/listing/{id}', name: 'aqarmap_api_update_listing', options: ['i18n' => false])]
604. #[Rest\View]
605. #[IsGranted(attribute: 'ROLE_OWNER', subject: 'listing')]
606. #[OA\Parameter(name: 'listing', description: '', in: 'query', required: false)]
607. #[OA\Response(response: 200, description: 'Returned when successfully Updated')]
608. #[OA\Response(response: 400, description: 'Returned when validation error')]
609. public function updateListing(Listing $listing, Request $request)
610. {
611. $listing->clearAttributes();
612. $form = $this->createForm(ListingApiType::class, $listing, [
613. 'csrf_protection' => false,
614. ]);
616. $form->handleRequest($request);
617. if ($form->isSubmitted() && $form->isValid()) {
618. if ($this->getUser()->getPhoneNumber()) {
619. $listing->addPhone(new ListingPhone($this->getUser()->getPhoneNumber()));
620. }
621. $listingManager = $this->listingService;
622. $listingManager->saveListing($listing);
624. $listingEvent = new ListingEvent($listing);
625. $this->dispatcher->dispatch($listingEvent, 'aqarmap.listing.submitted');
627. return View::create()->setData($listing)->setStatusCode(Response::HTTP_OK);
628. }
630. return View::create()->setData($form)->setStatusCode(Response::HTTP_BAD_REQUEST);
631. }
633. /**
634. * Upload listing photos.
635. *
636. * @return View|array
637. */
638. #[Rest\Post('/api/v2/listing/{id}/photos', name: 'aqarmap_api_upload_listing_photos', options: ['i18n' => false])]
639. #[IsGranted(attribute: 'ROLE_OWNER', subject: 'listing')]
640. #[OA\Parameter(name: 'photos', description: '', in: 'query', required: false)]
641. #[OA\Response(response: 201, description: 'Returned when successfully created')]
642. #[OA\Response(response: 400, description: 'Returned when validation error')]
643. public function upload(Request $request, Listing $listing)
644. {
645. $form = $this->createForm(PhotoType::class, null, [
646. 'csrf_protection' => false,
647. ]);
649. $form->handleRequest($request);
650. if ($form->isSubmitted() && $form->isValid()) {
651. $outputFiles = [];
652. $listingManager = $this->listingService;
653. $maxOrder = $listingManager->getMaxListingPhotoOrder($listing);
654. foreach ($form->get('file')->getData() as $index => $file) {
655. $photo = new Photo();
656. $photo->setFile($file);
658. $listingPhoto = new ListingPhoto();
659. $listingPhoto->setFile($photo);
660. $listingPhoto->setCaption($photo->getFile()?->getClientOriginalName());
661. $listingPhoto->setOrder($maxOrder + $index + 1);
663. $outputFiles[] = $listingPhoto;
664. $listing->addPhoto($listingPhoto);
665. }
666. $listingEvent = new ListingEvent($listing);
667. $this->dispatcher->dispatch($listingEvent, 'aqarmap.listing.submitted');
668. $listingManager->saveListing($listing);
670. return View::create()->setData($outputFiles)->setStatusCode(Response::HTTP_CREATED);
671. }
673. return [
674. 'listing' => $listing,
675. 'form' => $form->createView(),
676. ];
677. }
679. /**
680. * Delete Listing entity.
681. */
682. #[Rest\Delete('/api/v2/listing/{listing}', name: 'aqarmap_api_delete_listing', options: ['i18n' => false])]
683. #[IsGranted(attribute: 'ROLE_OWNER', subject: 'listing')]
684. #[OA\Response(response: 204, description: 'Returned when successfully Deleted')]
685. #[OA\Response(response: 404, description: 'Returned when Listing is not found')]
686. #[OA\Response(response: 403, description: 'Returned when you are trying to remove listing that not yours.')]
687. public function delete(Listing $listing)
688. {
689. if (\in_array('ROLE_PREVENT_DELETE_LISTING', $this->getUser()->getRoles())) {
690. throw new AccessDeniedHttpException("Forbidden, user don't have this permission.");
691. }
693. $listingManager = $this->listingService;
694. $listingManager->remove($listing, ListingStatus::USER_DELETED);
696. return new Response(null, Response::HTTP_NO_CONTENT);
697. }
699. /**
700. * Undelete Listing entity.
701. *
702. * @return array
703. */
704. #[IsGranted(attribute: 'ROLE_OWNER', subject: 'listing')]
705. #[Rest\View]
706. #[Rest\Get('/api/v2/listing/{listing}/undelete', name: 'aqarmap_api_undelete_listing', options: ['i18n' => false])]
707. #[OA\Response(response: 200, description: 'Returned when successfully undeleted')]
708. #[OA\Response(response: 404, description: 'Returned when Listing is not found or is not on user deleted state')]
709. #[OA\Response(response: 403, description: 'Returned when you are trying to remove listing that not yours.')]
710. public function undelete(Listing $listing)
711. {
712. if (ListingStatus::USER_DELETED != $listing->getStatus()) {
713. throw $this->createNotFoundException('Unable to find this listing.');
714. }
716. $listingManager = $this->listingService;
717. $listingManager->changeStatus($listing, ListingStatus::PENDING);
719. $listingEvent = new ListingEvent($listing);
720. $this->dispatcher->dispatch($listingEvent, 'aqarmap.listing.resubmitted');
722. return ['listing' => $listing];
723. }
725. /**
726. * Republish Listing entity.
727. *
728. * @return array
729. */
730. #[IsGranted(attribute: 'ROLE_OWNER', subject: 'listing')]
731. #[Rest\View]
732. #[OA\Response(response: 200, description: 'Returned when successfully Republished')]
733. #[OA\Response(response: 404, description: 'Returned when Listing is not found or is not on Expired state')]
734. #[OA\Response(response: 403, description: 'Returned when you are trying to Republish listing that not yours.')]
735. #[Rest\Get('/api/v2/listing/{listing}/relist', name: 'aqarmap_api_republish_listing', options: ['i18n' => false])]
736. public function relist(Listing $listing)
737. {
738. if (ListingStatus::EXPIRED != $listing->getStatus()) {
739. throw $this->createNotFoundException('Unable to find this listing.');
740. }
742. $em = $this->managerRegistry->getManager();
743. $listingRepo = $em->getRepository(Listing::class);
745. $relistChild = $listingRepo->getRelistChild($listing);
746. // If the expired listing already republished before .. return the republished version.
747. if ($relistChild) {
748. return ['listing' => $relistChild];
749. }
751. $listingManager = $this->listingService;
752. $listing = $listingManager->relist($listing);
754. $listingEvent = new ListingEvent($listing);
755. $this->dispatcher->dispatch($listingEvent, 'aqarmap.listing.resubmitted');
757. return ['listing' => $listing];
758. }
760. /**
761. * Feature A Listing.
762. *
763. * @return View
764. */
765. #[Rest\Post('/api/v2/listing/{listing}/feature', name: 'aqarmap_api_feature_listing', options: ['i18n' => false])]
766. #[Rest\RequestParam(name: 'type', description: 'Feature Type, 1 for payment, 2 for making it featured')]
767. #[IsGranted(attribute: 'ROLE_OWNER', subject: 'listing')]
768. // Featuring spends the owning account's points, so a sub account needs the manage-listings permission.
769. #[IsGranted(attribute: SubAccountPermissionVoter::MANAGE_LISTINGS)]
770. public function feature(Listing $listing, Request $request)
771. {
772. $type = $request->get('type');
773. if (!$type) {
774. throw new BadRequestHttpException('Please Specify the feature type');
775. }
777. $matcher = $this->listingRuleMatcher;
778. $listingRule = $matcher->match($listing);
779. $translator = $this->translator;
781. $featuredDuration = $listingRule['featured_duration'];
782. $featuredFees = $listingRule['featured_fees'];
784. if (ListingFeatures::FEATURED == $type) {
785. // Check if there is a value for featured_duration & featured_fees
786. if (empty($featuredDuration) || empty($featuredFees)) {
787. throw new LogicHttpException($translator->trans('Making a listing Featured is not available for this listing.', [], 'exceptions'));
788. }
790. try {
791. $this->listingService->makeItFeatured(
792. $listing,
793. [
794. 'featuredFees' => $featuredFees,
795. 'featuredDuration' => $featuredDuration,
796. 'listingFeaturedType' => ListingFeaturedTypes::FEATURED,
797. 'listingFeature' => $type,
798. ]
799. );
800. } catch (\Exception $e) {
801. throw new LogicHttpException($translator->trans($e->getMessage(), [], 'exceptions'));
802. }
803. } elseif (ListingFeatures::PAID == $type) {
804. /** @var CreditManager $creditManager */
805. $creditManager = $this->creditManager;
807. if ($listing->getPublicationCredit()) {
808. throw new LogicHttpException($translator->trans('credit.already_paid'));
809. } elseif ($listingRule['publication_fees'] > $creditManager->getBalance($listing->getUser())) {
810. throw new LogicHttpException($translator->trans('credit.not_enough_credits'));
811. }
812. // Subtract publication fees
813. $credits = $creditManager->deduction($listing->getUser(), $listingRule['publication_fees'], 'Listing Fees', CreditStatus::PENDING);
814. foreach ($credits as $credit) {
815. if ($credit instanceof Credit) {
816. $this->listingService->addFeature($listing, ListingFeatures::PAID, null, $credit);
817. }
818. }
820. $listingEvent = new ListingEvent($listing);
821. $this->dispatcher->dispatch($listingEvent, 'aqarmap.listing.submitted');
822. }
824. return View::create()->setData(['listing' => $listing]);
825. }
827. // -------------------------------------------------------------------------//
828. // ++++++++++++++ Quick contact seller & call request Actions +++++++++++++++//
829. // -------------------------------------------------------------------------//
830. /**
831. * ).
832. *
833. * @return bool|Form|array
834. *
835. * @throws AccessDeniedHttpException
836. *
837. * ===============================================================
838. * |
839. * | DEPRECATED: USE QuickCreateLeadAction::LeadController instead
840. * |
841. * ===============================================================
842. */
843. #[Rest\Post('/api/v2/listing/{listing}/quick_create_lead', name: 'aqarmap_api_listing_quick_create_lead', options: ['i18n' => false])]
844. #[Rest\QueryParam(name: 'campaign', description: 'Campaign Name')]
845. #[Rest\QueryParam(name: 'country_code', default: null, description: 'Country Code')]
846. #[Rest\View(serializerGroups: ['Default', 'Details'])]
847. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
848. public function quickCreateLead(Request $request, Listing $listing)
849. {
850. $form = $this->createForm(QuickCreateLeadFormType::class, null, [
851. 'method' => 'POST',
852. 'csrf_protection' => false,
853. ]);
854. $form->handleRequest($request);
856. if ($form->isSubmitted() && $form->isValid()) {
857. $lead = $form->getData();
859. /** @var UserManagerInterface $userManager */
860. $userManager = $this->fosUserManager;
861. $leadModel = new LeadModel();
863. try {
864. /** @var User $user */
865. if ($user = $userManager->findUserByEmail($form->get('email')->getData())) {
866. $phone = $this->phoneManager->addNewUserPhone(
867. $lead['phoneNumber'],
868. '+'.str_replace(' ', '', $request->get('country_code')),
869. $user,
870. true,
871. true,
872. CountryCodes::getCountryFromCodeNumber('+'.str_replace(' ', '', $request->get('country_code'))),
873. $lead['phoneNumber']
874. );
875. $userManager->updateUser($user);
876. $leadModel->setUser($user);
877. } else {
878. $user = $userManager->createUser();
880. $user
881. ->setFullName($lead['fullName'])
882. ->setEmail($lead['email'])
883. ->setLanguage($request->getLocale());
885. $user = $this->userManager->quickRegistration($form, $user, $request);
887. $phone = $this->phoneManager->addNewUserPhone(
888. $lead['phoneNumber'],
889. '+'.str_replace(' ', '', $request->get('country_code')),
890. $user,
891. true,
892. true,
893. CountryCodes::getCountryFromCodeNumber('+'.str_replace(' ', '', $request->get('country_code'))),
894. $lead['phoneNumber']
895. );
897. $userManager->reloadUser($user);
898. $leadModel->setUser($user);
899. }
900. } catch (\Exception) {
901. return [
902. 'status' => 'error',
903. 'message' => 'Cannot create a user.',
904. ];
905. }
907. if ($user) {
908. try {
909. $leadModel->setEmail($lead['email']);
910. $leadModel->setName($lead['fullName']);
911. $leadModel->setPhone($phone->getPhone());
912. $leadModel->setCampaign($request->request->get('campaign'));
913. $leadModel->setMessage($form->get('message')->getData());
914. $leadModel->setListing($listing);
916. $this->listingService->quickCreateLead($leadModel);
918. return [
919. 'status' => 'ok',
920. ];
921. } catch (\Exception) {
922. return [
923. 'status' => 'error',
924. 'message' => 'Cannot create the lead.',
925. ];
926. }
927. }
928. }
930. return $form;
931. }
933. /**
934. * Get Listing Rules.
935. *
936. * )
937. *
938. * @return array
939. */
940. #[Rest\Get('/api/v2/listing/{id}/rules', name: 'aqarmap_api_get_listing_rules', options: ['i18n' => false])]
941. #[IsGranted(attribute: 'ROLE_OWNER', subject: 'listing')]
942. #[Rest\View]
943. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
944. public function getListingRules(Listing $listing)
945. {
946. $listingMatcher = $this->listingRuleMatcher;
947. $rules = $listingMatcher->match($listing);
949. return ['rules' => $rules];
950. }
952. /**
953. * Get Listing Note.
954. *
955. * @return array
956. */
957. #[Rest\Get('/api/v2/listing/{id}/note', name: 'aqarmap_api_get_listing_note', options: ['i18n' => false])]
958. #[IsGranted(attribute: 'ROLE_USER')]
959. #[Rest\View]
960. #[OA\Tag(name: 'Listing Notes')]
961. #[OA\Tag(name: 'User Activity')]
962. #[OA\Parameter(name: 'propertyType', description: 'propertyType of the unites', in: 'query', required: false)]
963. #[OA\Parameter(name: 'section', description: 'Section of the unites', in: 'query', required: false)]
964. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
965. #[OA\Response(response: 200, description: 'Returns listing note from user_favorites note field')]
966. public function getListingNote(Listing $listing)
967. {
968. $favoriteRepository = $this->managerRegistry->getRepository(Favourite::class);
970. return $favoriteRepository->findOneBy([
971. 'user' => $this->getUser(),
972. 'listing' => $listing,
973. ]);
974. }
976. /**
977. * Get account statistics (Listings Statistics).
978. *
979. * @throws \Exception
980. */
981. #[Rest\Get('/api/user/listings/statistics', name: 'aqarmap_api_get_user_listings_rates_counts', requirements: ['id' => '\d+'], options: ['expose' => true, 'i18n' => false])]
982. #[Rest\View(serializerGroups: ['Default', 'Details'])]
983. #[IsGranted(attribute: 'ROLE_USER')]
984. public function getUserListingsPerformanceStatistics(
985. Request $request,
986. #[MapEntity(id: 'user')]
987. ?User $user = null,
988. ): View {
989. return $this->userListingsPerformanceStatistics($request, $user);
990. }
992. #[Rest\Post('/api/v2/user/listings/statistics', name: 'aqarmap_api_get_user_listings_rates_counts_v2', options: ['i18n' => false])]
993. #[Rest\View(serializerGroups: ['Default', 'Details'])]
994. #[IsGranted(attribute: 'ROLE_BROKER_LIVE_APP')]
995. public function getUserListingsPerformanceStatisticsV2(
996. Request $request,
997. #[MapEntity(id: 'user')]
998. ?User $user = null,
999. ): View {
1000. return $this->userListingsPerformanceStatistics($request, $user);
1001. }
1003. private function userListingsPerformanceStatistics(Request $request, ?User $user): View
1004. {
1005. $isSubAccount = null != $user && $this->getUser() === $user->getParent();
1006. $startDate = null;
1007. $period = $request->query->get('period', null);
1009. if (!$this->getUser() && !$isSubAccount) {
1010. throw new AccessDeniedHttpException();
1011. }
1013. $user = $user ?: $this->getUser();
1015. if ('7Days' == $period) {
1016. $startDate = date('Y-m-d', strtotime('-7 days'));
1017. } elseif ('30Days' == $period) {
1018. $startDate = date('Y-m-d', strtotime('-30 days'));
1019. }
1021. return $this->respond([
1022. 'rates' => $this->listingService->getUserListingsPerformanceStatistics($user, $startDate, $period),
1023. ]);
1024. }
1026. /**
1027. * Generates XML file for Listings News feed for marketing purpose.
1028. *
1029. * @return Response
1030. */
1031. #[Rest\Get('/api/listings/feed/{platform}', name: 'aqarmap_api_get_listings_news_feed', options: ['i18n' => false], defaults: ['page' => 1])]
1032. #[Rest\View(serializerGroups: ['Default', 'Details'])]
1033. public function getNewsFeed($platform, Request $request)
1034. {
1035. $criteria = [];
1036. $page = min($request->query->getInt('page') ?: 1, ListingNewsFeed::MAX_PAGES);
1037. $limit = min($request->query->getInt('limit', 100), 100);
1039. if ((int) $request->query->getInt('page', 1) > $page) {
1040. throw new NotFoundHttpException('Exceeded maximum number of pages');
1041. }
1043. if ($request->query->get('ugc')) {
1044. $data = explode(',', $request->query->get('ugc'));
1045. $data = array_map('intval', $data);
1046. $criteria['groupCategory'] = array_filter($data);
1047. }
1049. if ($request->query->get('ug')) {
1050. $data = explode(',', $request->query->get('ug'));
1051. $data = array_map('intval', $data);
1052. $criteria['userGroup'] = array_filter($data);
1053. }
1055. if ($request->query->get('hl')) {
1056. $criteria['locale'] = $request->query->get('hl');
1057. }
1059. if ($request->query->get('maxlead')) {
1060. $criteria['maxlead'] = $request->query->get('maxlead');
1061. }
1063. if ($request->query->get('feat')) {
1064. $criteria['feat'] = $request->query->get('feat');
1065. }
1067. if ($request->query->get('location')) {
1068. $locations = $this->locationManager
1069. ->buildLocationsArrayByParentId($request->query->get('location'));
1071. if (!empty($locations)) {
1072. $criteria['locations'] = $locations;
1073. }
1074. }
1076. if ($request->query->get('section')) {
1077. $data = explode(',', $request->query->get('section'));
1078. $data = array_map('intval', $data);
1079. $criteria['sections'] = array_filter($data);
1080. }
1082. $news = $this->listingNewsFeed;
1083. $offset = ($page - 1) * $limit;
1085. $excludedKeys = ['sections', 'maxlead'];
1086. if (!array_diff(array_keys($criteria), $excludedKeys)) {
1087. throw new BadRequestHttpException(sprintf('Invalid Request: Please add at least one additional filter besides %s.', implode(', ', $excludedKeys)));
1088. }
1090. if ('json' == $request->query->get('format')) {
1091. return $this->responseJson($news->asJson($offset, $limit, $criteria));
1092. }
1094. return $this->responseXml($news->asXml($offset, $limit, $platform, $criteria));
1095. }
1097. /**
1098. * Stateful endpoint to update listing fields.
1099. */
1100. #[Rest\Post('api/listing/{id}/edit', name: 'update_listing_field', options: ['i18n' => false, 'expose' => true])]
1101. #[Rest\View(serializerGroups: ['Default', 'Details'])]
1102. #[IsGranted(attribute: 'ROLE_EDIT_REVIEW_LISTINGS')]
1103. #[IsGranted(attribute: new Expression('is_granted("ROLE_ADMIN") or is_granted("ROLE_OWNER", subject["listing"])'), subject: ['listing'])]
1104. public function update(Listing $listing, Request $request): View
1105. {
1106. $listingManager = $this->listingManager;
1108. $isEnabled = $this->featureToggle
1109. ->isEnabled('web.mortgage.options');
1111. $mortgage = $request->get('eligibleForMortgage');
1112. $fields = $request->request->all();
1114. if ($isEnabled) {
1115. if (true == $mortgage) {
1116. $this->mortgageService->addEligibleMortgageTypes($listing);
1117. } else {
1118. $listingManager->setEligibleMortgageToNull($listing);
1119. }
1120. unset($fields['eligibleForMortgage']);
1121. }
1123. $this->dispatcher->dispatch(
1124. new ListingUpdatedEvent($listing, $fields),
1125. ListingUpdatedEvent::UPDATED
1126. );
1127. $listing = $listingManager->update($listing, $fields);
1129. if (ListingStatus::LIVE == $listing->getStatus()) {
1130. $listingManager->changeStatus($listing, ListingStatus::PENDING);
1131. }
1133. return $this->respond([
1134. 'listing' => $listing,
1135. 'msg' => 'Listing was updated successfully',
1136. ]);
1137. }
1139. /**
1140. * Stateful endpoint to get Photos Of The Given Listings.
1141. */
1142. #[Rest\Get('/api/listings/{listing}/photos', name: 'aqarmap_api_get_listing_photos', options: ['expose' => true, 'i18n' => false])]
1143. #[IsGranted(attribute: new Expression('is_granted("ROLE_ADMIN") or is_granted("ROLE_OWNER", subject["listing"])'), subject: ['listing'])]
1144. public function getListingPhotos(Listing $listing): View
1145. {
1146. $listingPhotos = $listing->getPhotos();
1148. $listingPhotosData = [];
1150. foreach ($listingPhotos as $listingPhoto) {
1151. $listingPhotosData[] = [
1152. 'id' => $listingPhoto->getId(),
1153. 'type' => $listingPhoto->getType(),
1154. 'caption' => $listingPhoto->getCaption(),
1155. 'file' => $listingPhoto->getFile(),
1156. ];
1157. }
1159. return $this->respond($listingPhotosData);
1160. }
1162. /**
1163. * Get Photo Types.
1164. *
1165. * @return Response
1166. */
1167. #[Rest\Get('/api/listings/photoTypes', name: 'aqarmap_api_get_listing_photo_types', options: ['expose' => true, 'i18n' => false])]
1168. public function getPhotoTypes()
1169. {
1170. return $this->respond(PhotoTypes::getPhotoTypes());
1171. }
1173. /**
1174. * Upload Listing Photo.
1175. *
1176. * @return array
1177. *
1178. * @throws OptimisticLockException
1179. */
1180. #[Rest\Post('/api/listing/{id}/upload_photo', name: 'aqarmap_api_admin_upload_listing_photo', options: ['expose' => true, 'i18n' => false])]
1181. public function uploadListingPhoto(Listing $listing)
1182. {
1183. $outputFiles = [];
1184. $listingManager = $this->listingManager;
1185. $maxOrder = $listingManager->getMaxListingPhotoOrder($listing);
1187. $photo = new Photo();
1189. $file = $_FILES['file'];
1190. $file = new UploadedFile($file['tmp_name'], $file['name'], $file['type']);
1191. $photo->setFile($file);
1193. $listingPhoto = new ListingPhoto();
1194. $listingPhoto->setFile($photo);
1195. $listingPhoto->setCaption($photo->getFile()?->getClientOriginalName());
1196. $listingPhoto->setOrder($maxOrder + 1);
1198. $outputFiles[] = $listingPhoto;
1199. $listing->addPhoto($listingPhoto);
1201. $em = $this->managerRegistry->getManager();
1202. $em->persist($listing);
1203. $em->flush();
1205. return $this->respond(['status' => 'OK']);
1206. }
1208. /**
1209. * Gets rate details of listing.
1210. */
1211. #[Rest\Get('/api/v2/listing/{listing}/rates', options: ['i18n' => false])]
1212. #[Rest\Get('/api/listing/{listing}/rates', name: 'aqarmap_api_listing_rates_details', options: ['expose' => true, 'i18n' => false])]
1213. #[Rest\View(serializerGroups: ['Rates'])]
1214. #[Cache(expires: '+1 week', maxage: '+1 week', smaxage: '+1 week', public: false, vary: ['Accept-Language', 'X-Accept-Version', 'Accept'])]
1215. public function getRateDetails(Listing $listing)
1216. {
1217. return $this->respond(
1218. current($this->listingRateService->getRatesDetails([$listing]))
1219. );
1220. }
1222. /**
1223. * @return View
1224. */
1225. #[Rest\Get('/api/v2/listing/{listing}/preview', options: ['i18n' => false])]
1226. #[Rest\Get('/api/listing/{listing}/preview', name: 'aqarmap_api_listing_preview_data', options: ['expose' => true, 'i18n' => false])]
1227. #[Rest\View(serializerGroups: ['Preview'])]
1228. public function getListingPreviewData(Listing $listing)
1229. {
1230. return $this->respond($listing);
1231. }
1233. /**
1234. * @return JsonResponse
1235. *
1236. * @throws \Exception
1237. */
1238. #[Rest\Get('/api/listing/{listing}/lead-analytics', name: 'aqarmap_api_listing_lead_analytics', options: ['i18n' => false, 'expose' => true])]
1239. public function getLeadAnalytics(Listing $listing)
1240. {
1241. $analytics = $this->listingService->getLeadAnalytics($listing);
1243. return $this->respond($analytics);
1244. }
1246. /**
1247. * @return string
1248. */
1249. #[Rest\Delete('/api/v2/listing/{listing}/favourite', options: ['i18n' => false])]
1250. #[Rest\Delete('/api/listing/{listing}/favourite', name: 'aqarmap_api_remove_favourite_listing', options: ['i18n' => false])]
1251. #[IsGranted(attribute: 'ROLE_USER')]
1252. #[OA\Tag(name: 'Favorites')]
1253. #[OA\Tag(name: 'User Activity')]
1254. public function deleteFavourite(Request $request)
1255. {
1256. $this->favouriteService->deleteByListing($request->attributes->get('listing'));
1258. return $this->respond('Favourite Deleted Successfully!');
1259. }
1261. /**
1262. * @return string
1263. */
1264. #[Rest\Delete('/api/v2/listing/{listing}/note', options: ['i18n' => false])]
1265. #[Rest\Delete('/api/listing/{listing}/note', name: 'aqarmap_api_remove_listing_note', options: ['i18n' => false])]
1266. #[IsGranted(attribute: 'ROLE_USER')]
1267. #[OA\Tag(name: 'Listing Notes')]
1268. #[OA\Tag(name: 'User Activity')]
1269. #[OA\Tag(name: 'Favorites')]
1270. #[OA\Response(response: 200, description: 'Clears note while keeping favorite relation for backward compatibility')]
1271. public function deleteNote(Request $request)
1272. {
1273. $this->listingNoteService->deleteByListing($request->attributes->get('listing'));
1275. return $this->respond('Note Deleted Successfully!');
1276. }
1278. #[Rest\Post('/api/listing/{listing}/rate-review', name: 'aqarmap_api_change_listing_rate_review_status', options: ['i18n' => false, 'expose' => true])]
1279. #[IsGranted(attribute: 'ROLE_ADMIN')]
1280. public function rateReview(Request $request, Listing $listing): View
1281. {
1282. $this->listingService->updateIsRateReviewed($listing, $request->request->get('isReviewed'));
1284. return $this->respond('Listing rate review status changed successfully');
1285. }
1287. #[Rest\Get('/api/listing/{id}/similar_listings_count', name: 'aqarmap_api_get_similar_listings_count', options: ['i18n' => false, 'expose' => true])]
1288. #[Rest\View(serializerGroups: ['Default', 'Details'])]
1289. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
1290. public function getSimilarListingsCount(Listing $listing): int
1291. {
1292. $listingManager = $this->listingService;
1294. try {
1295. $count = $listingManager->countSimilarListings($listing);
1296. } catch (\Exception) {
1297. $count = 0;
1298. }
1300. return $count;
1301. }
1303. #[Rest\Get('/api/v2/listings/notes', options: ['i18n' => false])]
1304. #[Rest\Get('/api/listings/notes', name: 'aqarmap_api_listing_notes_and_favourites', options: ['i18n' => false])]
1305. #[Rest\QueryParam(name: 'from', description: '[favourites|notes]')]
1306. #[Rest\View(serializerGroups: ['Default', 'List'])]
1307. #[OA\Tag(name: 'Listing Notes')]
1308. #[OA\Tag(name: 'User Activity')]
1309. #[OA\Parameter(name: 'from', description: 'favourites or notes', in: 'query', required: false)]
1310. #[OA\Response(response: 200, description: 'Returns listings while preserving legacy response keys: favourite or note')]
1311. public function getListingsWithNotes(Request $request): array
1312. {
1313. $listingsIdWithNotes = [];
1314. if ($content = $request->getContent()) {
1315. $listingsIdWithNotes = json_decode($content, true);
1316. }
1318. $listings = $this->managerRegistry->getRepository(Listing::class)
1319. ->getByIdsQuery(array_column($listingsIdWithNotes, 'listingId'));
1321. $pagination = $this->paginator->paginate(
1322. $listings,
1323. $request->query->getInt('page', 1),
1324. $request->query->getInt('limit', 10)
1325. );
1327. $data = $this->listingService->setStaticNotesFromPaginator($pagination, $listingsIdWithNotes);
1328. if ('favourites' == $request->query->get('from')) {
1329. return ['favourite' => $data];
1330. }
1332. return ['note' => $data];
1333. }
1335. #[Rest\Get('/api/listing/arwt', name: 'aqarmap_api_listing_arwt', options: ['i18n' => false])]
1336. #[Rest\View]
1337. #[OA\Get(
1338. summary: 'Get Approval/Rejection Waiting Time',
1339. tags: ['Listing'],
1340. )]
1341. public function getApprovalRejectionWaitingTime(Request $request): array
1342. {
1343. $criteria = array_merge(
1344. $request->query->all(),
1345. ['actionTime' => true]
1346. );
1347. $listingManager = $this->listingService;
1348. $listingExtension = $this->listingExtension;
1350. return [
1351. 'arwt' => $listingExtension->waited($listingManager->getApprovalRejectionWaitingTime($criteria)),
1352. ];
1353. }
1355. /**
1356. * filter Listing Children with property type (Project Units).
1357. *
1358. * @return array
1359. */
1360. #[Rest\Get('/api/listing/{id}/children', name: 'aqarmap_api_get_listing_children', options: ['i18n' => false])]
1361. #[Rest\QueryParam(name: 'propertyType', description: 'propertyType of the unites')]
1362. #[Rest\View(serializerGroups: ['UnitDetails'])]
1363. #[OA\Parameter(name: 'propertyType', description: 'propertyType of the unites', in: 'query', required: false)]
1364. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
1365. public function filterListingChildren(
1366. Listing $listing,
1367. #[MapEntity(id: 'propertyType')]
1368. ?PropertyType $propertyType = null,
1369. ): View {
1370. if (!$this->getUser()) {
1371. throw new AccessDeniedHttpException();
1372. }
1374. return $this->respond($listing->getLiveChildren($propertyType));
1375. }
1377. /**
1378. * API for cloning listing.
1379. */
1380. #[Rest\Post('/api/listing/{id}/clone', name: 'aqarmap_api_clone_listing_children', options: ['i18n' => false])]
1381. #[Rest\Post('/api/v2/listing/{id}/clone', name: 'aqarmap_api_v2_clone_listing_children', options: ['i18n' => false])]
1382. #[Rest\RequestParam(name: 'propertyType', description: 'propertyType of the unites')]
1383. #[Rest\RequestParam(name: 'section', description: 'Section of the unites')]
1384. #[IsGranted(attribute: 'IS_AUTHENTICATED_REMEMBERED')]
1385. #[Rest\View(serializerGroups: ['UnitDetails'])]
1386. #[OA\Parameter(name: 'propertyType', description: 'propertyType of the unites', in: 'query', required: false)]
1387. #[OA\Parameter(name: 'section', description: 'Section of the unites', in: 'query', required: false)]
1388. #[OA\Response(response: 404, description: 'Returned when the listing, propertyType or section is not found')]
1389. public function cloneListing(
1390. #[MapEntity(expr: 'repository.find(request.get("section"))', stripNull: false)]
1391. ?Section $section,
1392. #[MapEntity(expr: 'repository.find(request.get("propertyType"))', stripNull: false)]
1393. ?PropertyType $propertyType,
1394. Listing $sourceListing
1395. ): View {
1396. $syncedFields = $sourceListing->getParent() ? ListingSyncedFields::UNIT_FIELDS : ListingSyncedFields::PARENT_FIELDS;
1397. try {
1398. $listing = $this->listingManager->initializeListingForCloning($sourceListing, $propertyType, $section, $this->getUser());
1399. $this->listingManager->syncListingForProject(
1400. [
1401. 'targetListingId' => $listing->getId(),
1402. 'sourceListingId' => $sourceListing->getId(),
1403. 'syncedFields' => $syncedFields,
1404. 'targetListingSavedAt' => $listing->getUpdatedAt()->getTimestamp(),
1405. ]
1406. );
1408. return $this->respond($listing->getId());
1409. } catch (\Exception $exception) {
1410. throw new \Exception('Could not clone listing', null, $exception);
1411. }
1412. }
1414. /**
1415. * @throws InvalidArgumentException
1416. */
1417. #[Rest\Get('/api/v2/listing/{listing}/top-seller', name: 'aqarmap_api_listing_top_seller', options: ['i18n' => false])]
1418. #[Rest\View(serializerGroups: ['TopCustomers'])]
1419. public function getListingTopSeller(Listing $listing, TopSellerRetrievalService $topSellerRetrievalService, SectionService $sectionService)
1420. {
1421. $topSeller = new TopSeller();
1422. $topSeller->setLocation($listing->getLocation()->getId());
1423. $section = $listing->getSection();
1424. if ($section->getType() === SectionTypeEnum::COMPOUNDS) {
1425. $saleSection = $sectionService->getCachedSectionByType(SectionTypeEnum::SALE);
1426. if ($saleSection !== null) {
1427. $section = $saleSection;
1428. }
1429. }
1430. $topSeller->setSection($section->getId());
1431. $topSeller->setPropertyType($listing->getPropertyType()->getId());
1433. return $topSellerRetrievalService->getTopSellerPersonalData($topSeller);
1434. }
1436. #[OA\Get(summary: 'Deprecated: Use /api/v4/listings/search/related instead', deprecated: true)]
1437. #[Rest\Get('/api/v2/listing/{listing}/related-listings', name: 'aqarmap_api_listing_related_listings', options: ['i18n' => false])]
1438. #[Cache(expires: '+1 days', maxage: '+1 days', smaxage: '+1 days', public: true, vary: ['Accept-Language', 'X-Accept-Version', 'Accept'])]
1439. #[Rest\View(serializerGroups: ['RelatedListingsV2'])]
1440. public function getRelatedListing(Listing $listing, ListingManager $listingManager, ListingRepository $listingRepository)
1441. {
1442. try {
1443. $relatedListingsElasticResponse = $listingManager->getRelatedListingsElasticResponse($listing);
1445. $listingsQueryBuilder = $listingRepository->getListingsByIds(array_column($relatedListingsElasticResponse['items'], 'id'));
1447. return $listingsQueryBuilder->getQuery()->getResult();
1448. } catch (\Exception $exception) {
1449. throw new \Exception('Could not get related listings', null, $exception);
1450. }
1451. }
1453. #[Rest\Post('/api/v2/listing/{id}/views', name: 'aqarmap_api_add_listing_views', requirements: ['id' => '\d+'], options: ['i18n' => false])]
1454. #[Rest\View]
1455. #[OA\Post(description: 'Increments the view count for the listing.', summary: 'Submit a listing view', tags: ['Listing'])]
1456. #[OA\Parameter(name: 'id', in: 'path', required: true, schema: new OA\Schema(type: 'integer'))]
1457. #[OA\Response(
1458. response: 200,
1459. description: 'View recorded',
1460. content: new OA\JsonContent(
1461. properties: [
1462. new OA\Property(property: 'status', type: 'string', example: 'ok'),
1463. new OA\Property(property: 'message', type: 'string', example: 'Views Created Successfully!'),
1464. ],
1465. type: 'object'
1466. )
1467. )]
1468. #[OA\Response(response: 404, description: 'Returned when the listing is not found')]
1469. #[OA\Response(response: 400, description: 'Returned when the listing is not published')]
1470. public function increaseListingViews(Listing $listing): array
1471. {
1472. if (ListingStatus::LIVE !== $listing->getStatus()) {
1473. throw new BadRequestHttpException('Cannot increase views for not published listings.');
1474. }
1476. try {
1477. $this->interactionService->increaseViews($listing, $this->getUser());
1479. return [
1480. 'status' => 'ok',
1481. 'message' => 'Views Created Successfully!',
1482. ];
1483. } catch (\Exception $exception) {
1484. throw new \Exception('Could not increase listing views', null, $exception);
1485. }
1486. }
1487. }