src/Aqarmap/Bundle/SearchBundle/Controller/Api/V4/ListingSearchController.php line 511

  1. $mapped->setMapListingAttributes(true);
  2. $mapped->setMapListingMainPhoto(true);
  3. $mapped->setMapListingPhotos(true);
  5. $data = [
  6. 'default' => $this->makeMappedPaginatedBody($result['searchResults'], $mapped),
  7. 'related' => [],
  8. ];
  10. $data = $this->serializer->serialize(
  11. $data,
  12. 'json',
  13. SerializationContext::create()
  14. ->setGroups('SearchV4')
  15. ->enableMaxDepthChecks()
  16. );
  18. $cachedSerialize->set($data);
  19. $cachedSerialize->expiresAfter(3600 * 3);
  20. $cache->save($cachedSerialize);
  21. }
  23. return new Response($cachedSerialize->get());
  24. }
  26. /**
  27. * Related Listings Search V4.
  28. *
  29. * @return View
  30. *
  31. * @throws \Exception
  32. */
  33. #[Rest\Get('/api/v4/listings/search/related', options: ['i18n' => false], name: 'aqarmap_api_get_related_results_v4')]
  34. #[Rest\QueryParam(name: 'propertyType', requirements: '\d+', default: null, description: 'Property Type ID')]
  35. #[Rest\QueryParam(name: 'location', requirements: '\d+', default: null, description: 'Location ID comma spereted')]
  36. #[Rest\QueryParam(name: 'section', requirements: '\d+', default: null, description: 'Section ID')]
  37. #[Rest\QueryParam(name: 'page', requirements: '\d+', nullable: true, default: 1, description: 'Page number, starting from 1.')]
  38. #[Rest\QueryParam(name: 'limit', requirements: '\d+', nullable: true, default: 10, description: 'Number of items per page.')]
  39. #[Rest\QueryParam(name: 'sort', requirements: 'price|area', nullable: true, default: null, description: 'Sort search results by price or area.')]
  40. #[Rest\QueryParam(name: 'direction', requirements: 'asc|desc', nullable: true, default: 'asc', description: 'Ascending (A to Z, 0 to 9), Descending (Z to A, 9 to 0)')]
  41. #[Rest\View(serializerGroups: ['DefaultV4', 'SearchV4'])]
  42. #[OA\Parameter(name: 'propertyType', in: 'query', description: 'Property Type ID', required: false)]
  43. #[OA\Parameter(name: 'location', in: 'query', description: 'Location ID comma spereted', required: false)]
  44. #[OA\Parameter(name: 'section', in: 'query', description: 'Section ID', required: false)]
  45. #[OA\Parameter(name: 'page', in: 'query', description: 'Page number, starting from 1.', required: false)]
  46. #[OA\Parameter(name: 'limit', in: 'query', description: 'Number of items per page.', required: false)]
  47. #[OA\Parameter(name: 'sort', in: 'query', description: 'Sort search results by price or area.', required: false)]
  48. #[OA\Parameter(name: 'direction', in: 'query', description: 'Ascending (A to Z, 0 to 9), Descending (Z to A, 9 to 0)', required: false)]
  49. #[OA\Response(response: 500, description: 'Returned when something went wrong, for example if you entered non existing propertyType ID')]
  50. public function getRelatedSearchListings(Request $request, HttpClientInterface $searchClient, SerializerInterface $jmsSerializer, ListingRepository $listingRepository)
  51. {
  52. $response = $searchClient->request('GET', '/api/listing/nearest', [
  53. 'query' => $request->query->all(),
  54. 'headers' => [
  55. 'Accept-Language' => $request->getPreferredLanguage(),
  56. ],
  57. ]);
  59. if (200 === $response->getStatusCode()) {
  60. $data = $response->toArray();
  62. if (isset($data['data']) && is_array($data['data'])) {
  63. foreach ($data['data'] as &$item) {
  64. if (isset($item['listings']) && is_array($item['listings'])) {
  65. $listings = $listingRepository->getListingsByIds(array_column($item['listings'], 'id'))->getQuery()->getResult();
  66. $context = SerializationContext::create()
  67. ->setGroups(['DefaultV4', 'SearchV4']);
  69. $item['listings'] = json_decode(
  70. $jmsSerializer->serialize($listings, 'json', $context),
  71. true
  72. );
  73. }
  74. }
  75. }
  77. return $this->json($data);
  78. }
  80. return $this->json([
  81. 'error' => 'Failed to fetch nearest search listings',
  82. ], $response->getStatusCode());
  83. }
  85. #[Rest\Get('/api/v4/listings', options: ['i18n' => false], name: 'aqarmap_api_get_listings')]
  86. #[Rest\Get('/api/v4/listings/search', options: ['i18n' => false], name: 'aqarmap_api_listings_search_v4')]
  87. public function getListings(Request $request, ListingRepository $listingRepository, ListingManager $listingManager, CacheInterface $cache, MessageBusInterface $messageBus)
  88. {
  89. /** @var UserInterface $user */
  90. $user = $this->getUser();
  91. $hasSearchScoringRole = $user && $user->hasRole('ROLE_SEARCH_SCORING');
  92. if (!$hasSearchScoringRole && ($request->get('esdebug') || $request->get('scoredebug'))) {
  93. $request->query->remove('esdebug');
  94. $request->query->remove('scoredebug');
  95. }
  97. if ($request->get('location')) {
  98. $request->query->set('locations', explode(',', $request->query->get('location', '')));
  99. }
  101. $cacheKey = sprintf('api_listings_search_v4_%s_%s', $request->getLocale(), md5(http_build_query($request->query->all())));
  102. $cachedSerialize = $cache->getItem($cacheKey);
  103. if (!$cachedSerialize->isHit() || empty($cachedSerialize->get())) {
  104. $listingsElasticResponse = $listingManager->getListingsElasticResponse($request);
  105. $listingsQueryBuilder = $listingRepository->getListingsByIds(array_column($listingsElasticResponse['items'], 'id'));
  107. if ('aqarmap_api_listings_search_v4' === $request->attributes->get('_route')) {
  108. $listingsElasticResponse['pagination']['totalPages'] = (float) $listingsElasticResponse['pagination']['totalPages'];
  109. }
  111. $listings = $listingsQueryBuilder->getQuery()->getResult();
  113. $data = [
  114. 'default' => $this->mapPaginatedBody($listingsElasticResponse, $listings),
  115. 'related' => [],
  116. ];
  118. $data = $this->serializer->serialize(
  119. $data,
  120. 'json',
  121. SerializationContext::create()
  122. ->setGroups('SearchV4')
  123. ->enableMaxDepthChecks()
  124. );
  126. $cachedSerialize->set($data);
  127. $cachedSerialize->expiresAfter(3600 * 3);
  128. $cache->save($cachedSerialize);
  129. }
  131. return new Response($cachedSerialize->get());
  132. }
  134. #[Rest\Get('/api/v4/listings/debug', options: ['i18n' => false], name: 'aqarmap_api_get_listings_debug')]
  135. public function getListingsEsDebug(Request $request, ListingManager $listingManager)
  136. {
  137. /** @var UserInterface $user */
  138. $user = $this->getUser();
  140. if (!($user && $user->hasRole('ROLE_SEARCH_SCORING'))) {
  141. throw new UnauthorizedHttpException();
  142. }
  144. $request->query->set('esdebug', 1);
  146. if ($request->get('location')) {
  147. $request->query->set('locations', explode(',', $request->query->get('location', '')));
  148. }
  150. $listingsDebugElasticResponse = $listingManager->getListingsDebugElasticResponse($request);
  152. if ('aqarmap_api_listings_search_v4' === $request->attributes->get('_route')) {
  153. $listingsDebugElasticResponse['pagination']['totalPages'] = (float) $listingsDebugElasticResponse['pagination']['totalPages'];
  154. }
  156. $data = [
  157. 'default' => $this->mapPaginatedBody($listingsDebugElasticResponse, $listingsDebugElasticResponse['items']),
  158. ];
  160. return new JsonResponse($data);
  161. }
  163. #[Rest\Get('/api/v4/listings/search/ssr-data', options: ['i18n' => false], name: 'aqarmap_api_get_listings_search_ssr-data')]
  164. public function getListingsSearchSSRData(Request $request, ListingManager $listingManager, CacheInterface $cache, SectionService $sectionService)
  165. {
  166. $cacheKey = sprintf('api_listings_search_ssr_data_%s_%s', $request->getLocale(), md5(http_build_query($request->query->all())));
  167. $cachedResponse = $cache->getItem($cacheKey);
  169. if (!$cachedResponse->isHit() || empty($cachedResponse->get())) {
  170. $customParagraph = $locationChildren = $slugResolver = $faqData = $locationParents = [];
  172. if ($request->get('location')) {
  173. $request->query->set('locations', explode(',', $request->query->get('location', '')));
  174. }
  176. $location = $request->get('locations') ? $request->get('locations')[0] : null;
  177. $location = $this->locationRepository->findOneBy(['slug' => $location]);
  178. $section = $this->sectionRepository->findOneBy(['slug' => $request->query->get('section')]);
  179. $propertyType = $this->propertyTypeRepository->findOneBy(['slug' => $request->query->get('propertyType')]);
  181. if ($location) {
  182. $locationChildren = $listingManager->getSerializedLocationChildren($location);
  183. $locationParents = $listingManager->getLocationParents($location, $request->getLocale());
  184. }
  186. if ($section && $propertyType && $location) {
  187. $longTail = $this->seoListingSearchService->getSerializedLongTailData($section, $propertyType, $location) ?? [];
  188. }
  190. if ($section && $propertyType) {
  191. $byOwnerOnly = filter_var($request->get('byOwnerOnly'), FILTER_VALIDATE_BOOLEAN, FILTER_NULL_ON_FAILURE) ?? false;
  192. $customParagraph = $listingManager->getSerializedCustomParagraph($section, $propertyType, $location, $byOwnerOnly) ?? [];
  193. $slugResolver = $listingManager->getSerializedResolvedSlugs($section, $propertyType, (array) $request->query->get('locations', []));
  194. $faqData = $listingManager->getFaqs($section, $propertyType, $location, $request->getLocale());
  195. }
  197. $response = [
  198. 'locationChildren' => !empty($locationChildren) ? json_decode((string) $locationChildren, true) : [],
  199. 'longTail' => !empty($longTail) ? json_decode((string) $longTail, true) : [],
  200. 'customParagraph' => !empty($customParagraph) ? json_decode((string) $customParagraph, true) : [],
  201. 'slugResolver' => !empty($slugResolver) ? json_decode((string) $slugResolver, true) : [],
  202. 'faqData' => $faqData,
  203. 'locationParents' => $locationParents,
  204. 'sections' => json_decode((string) $sectionService->getSerializedSections(), true),
  205. 'propertyTypeChips' => $listingManager->getListingPropertyTypesChips($request, $location, $section, $propertyType),
  206. ];
  208. $cachedResponse->set(json_encode($response));
  209. $cachedResponse->expiresAfter(3600 * 3);
  210. $cache->save($cachedResponse);
  211. }
  213. return new JsonResponse(json_decode((string) $cachedResponse->get(), true));
  214. }
  216. #[Rest\Get('/api/v4/listings/trigger-search', options: ['i18n' => false], name: 'aqarmap_api_trigger_search_listings_v4')]
  217. public function triggerSearchListings(Request $request, MessageBusInterface $messageBus)
  218. {
  219. $user = $this->getUser();
  221. if ($request->get('location')) {
  222. $request->query->set('locations', explode(',', $request->query->get('location', '')));
  223. }
  225. if ($request->get('keywordSearch')) {
  226. $this->eventDispatcher->dispatch(new SearchTriggerEvent($request));
  227. }
  229. if ($user) {
  230. $messageBus->dispatch(new Search($request->query, $user));
  231. }
  233. return new JsonResponse([
  234. 'statusCode' => Response::HTTP_OK,
  235. 'statusMessage' => 'Search triggered successfully!',
  236. ]);
  237. }
  239. private function mapPaginatedBody(array $result, array $listings): array
  240. {
  241. if (!$result['pagination']) {
  242. return [
  243. 'statusCode' => $this->getStatusCode(),
  244. 'statusMessage' => $this->getStatusMessage(),
  245. 'paginate' => [],
  246. 'data' => [],
  247. 'errors' => $this->getErrors(),
  248. ];
  249. }
  251. return [
  252. 'statusCode' => $this->getStatusCode(),
  253. 'statusMessage' => $this->getStatusMessage(),
  254. 'paginate' => $result['pagination'],
  255. 'data' => $listings,
  256. 'errors' => $this->getErrors(),
  257. ];
  258. }
  259. }