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

  1. if (200 === $response->getStatusCode()) {
  2. $data = $response->toArray();
  4. if (isset($data['data']) && is_array($data['data'])) {
  5. foreach ($data['data'] as &$item) {
  6. if (isset($item['listings']) && is_array($item['listings'])) {
  7. $listings = $listingRepository->getListingsByIds(array_column($item['listings'], 'id'))->getQuery()->getResult();
  8. $context = SerializationContext::create()
  9. ->setGroups(['DefaultV4', 'SearchV4']);
  11. $item['listings'] = json_decode(
  12. $jmsSerializer->serialize($listings, 'json', $context),
  13. true
  14. );
  15. }
  16. }
  17. }
  19. return $this->json($data);
  20. }
  22. return $this->json([
  23. 'error' => 'Failed to fetch nearest search listings',
  24. ], $response->getStatusCode());
  25. }
  27. #[Rest\Get('/api/v4/listings', name: 'aqarmap_api_get_listings', options: ['i18n' => false])]
  28. #[Rest\Get('/api/v4/listings/search', name: 'aqarmap_api_listings_search_v4', options: ['i18n' => false])]
  29. #[Rest\QueryParam(name: 'personalizedSearch', requirements: '(1)|(0)', nullable: true, strict: true, description: 'Enable personalized search', default: '0')]
  30. #[OA\Parameter(name: 'personalizedSearch', in: 'query', description: 'Enable personalized search (requires active subscription)', required: false)]
  31. public function getListings(Request $request, ListingRepository $listingRepository, ListingManager $listingManager, CacheInterface $cache, MessageBusInterface $messageBus)
  32. {
  33. /** @var UserInterface $user */
  34. $user = $this->getUser();
  35. $hasSearchScoringRole = $user && $user->hasRole('ROLE_SEARCH_SCORING');
  36. if (!$hasSearchScoringRole && ($request->get('esdebug') || $request->get('scoredebug'))) {
  37. $request->query->remove('esdebug');
  38. $request->query->remove('scoredebug');
  39. }
  41. if ($request->get('location')) {
  42. $request->query->set('locations', explode(',', $request->query->get('location', '')));
  43. }
  45. $personalizedSearch = $request->query->getBoolean('personalizedSearch', false);
  46. if ($personalizedSearch) {
  47. if (!$user instanceof User) {
  48. throw new UnauthorizedHttpException('Personalized search requires an active session. Please log in.');
  49. }
  51. if (!$user->hasSubscriptionPlan()) {
  52. throw new AccessDeniedHttpException('Active subscription required for personalized search.');
  53. }
  55. $request->query->set('personalizedSearch', true);
  56. $request->query->set('personalizedForUser', $user->getId());
  57. }
  59. if ($personalizedSearch) {
  60. $data = $this->getSerializedListingSearchResults($request, $listingRepository, $listingManager);
  61. } else {
  62. $cacheKey = sprintf('api_listings_search_v4_%s_%s', $request->getLocale(), md5(http_build_query($request->query->all())));
  63. $data = $cache->get(
  64. $cacheKey,
  65. function(ItemInterface $item) use ($request, $listingRepository, $listingManager) {
  66. $item->expiresAfter(3600 * 3);
  68. return $this->getSerializedListingSearchResults($request, $listingRepository, $listingManager);
  69. }
  70. );
  71. }
  73. return new Response($data);
  74. }
  76. private function getSerializedListingSearchResults(Request $request, ListingRepository $listingRepository, ListingManager $listingManager): string
  77. {
  78. $listingsElasticResponse = $listingManager->getListingsElasticResponse($request);
  79. $listingsQueryBuilder = $listingRepository->getListingsByIds(array_column($listingsElasticResponse['items'], 'id'));
  81. if ('aqarmap_api_listings_search_v4' === $request->attributes->get('_route')) {
  82. $listingsElasticResponse['pagination']['totalPages'] = (float) $listingsElasticResponse['pagination']['totalPages'];
  83. }
  85. $listings = $listingsQueryBuilder->getQuery()->getResult();
  87. $data = [
  88. 'default' => $this->mapPaginatedBody($listingsElasticResponse, $listings),
  89. 'related' => [],
  90. ];
  92. return $this->serializer->serialize(
  93. $data,
  94. 'json',
  95. SerializationContext::create()
  96. ->setGroups('SearchV4')
  97. ->enableMaxDepthChecks()
  98. );
  99. }
  101. #[Rest\Get('/api/v4/listings/debug', options: ['i18n' => false], name: 'aqarmap_api_get_listings_debug')]
  102. public function getListingsEsDebug(Request $request, ListingManager $listingManager)
  103. {
  104. /** @var UserInterface $user */
  105. $user = $this->getUser();
  107. if (!($user && $user->hasRole('ROLE_SEARCH_SCORING'))) {
  108. throw new UnauthorizedHttpException();
  109. }
  111. $request->query->set('esdebug', 1);
  113. if ($request->get('location')) {
  114. $request->query->set('locations', explode(',', $request->query->get('location', '')));
  115. }
  117. $listingsDebugElasticResponse = $listingManager->getListingsDebugElasticResponse($request);
  119. if ('aqarmap_api_listings_search_v4' === $request->attributes->get('_route')) {
  120. $listingsDebugElasticResponse['pagination']['totalPages'] = (float) $listingsDebugElasticResponse['pagination']['totalPages'];
  121. }
  123. $data = [
  124. 'default' => $this->mapPaginatedBody($listingsDebugElasticResponse, $listingsDebugElasticResponse['items']),
  125. ];
  127. return new JsonResponse($data);
  128. }
  130. #[Rest\Get('/api/v4/listings/search/ssr-data', name: 'aqarmap_api_get_listings_search_ssr-data', options: ['i18n' => false])]
  131. public function getListingsSearchSSRData(Request $request, ListingManager $listingManager, CacheInterface $cache, SectionService $sectionService)
  132. {
  133. $cacheKey = sprintf('api_listings_search_ssr_data_%s_%s', $request->getLocale(), md5(http_build_query($request->query->all())));
  134. $cachedResponse = $cache->getItem($cacheKey);
  136. if (!$cachedResponse->isHit() || empty($cachedResponse->get())) {
  137. $customParagraph = $locationChildren = $slugResolver = $faqData = $locationParents = [];
  139. if ($request->get('location')) {
  140. $request->query->set('locations', explode(',', $request->query->get('location', '')));
  141. }
  143. $location = $request->query->all('locations') ? $request->query->all('locations')[0] : null;
  144. $location = $this->locationRepository->findOneBy(['slug' => $location]);
  145. $section = $this->sectionRepository->findOneBy(['slug' => $request->query->get('section')]);
  146. $propertyType = $this->propertyTypeRepository->findOneBy(['slug' => $request->query->get('propertyType')]);
  148. if ($location) {
  149. $locationChildren = $listingManager->getSerializedLocationChildren($location);
  150. $locationParents = $listingManager->getLocationParents($location, $request->getLocale());
  151. }
  153. if ($section && $propertyType && $location) {
  154. $longTail = $this->seoListingSearchService->getSerializedLongTailData($section, $propertyType, $location) ?? [];
  155. }
  157. if ($section && $propertyType) {
  158. $byOwnerOnly = filter_var($request->get('byOwnerOnly'), FILTER_VALIDATE_BOOLEAN, FILTER_NULL_ON_FAILURE) ?? false;
  159. $customParagraph = $listingManager->getSerializedCustomParagraph($section, $propertyType, $location, $byOwnerOnly) ?? [];
  160. $slugResolver = $listingManager->getSerializedResolvedSlugs($section, $propertyType, $request->query->all('locations'));
  161. $faqData = $listingManager->getFaqs($section, $propertyType, $location, $request->getLocale());
  162. }
  164. $response = [
  165. 'locationChildren' => !empty($locationChildren) ? json_decode((string) $locationChildren, true) : [],
  166. 'longTail' => !empty($longTail) ? json_decode((string) $longTail, true) : [],
  167. 'customParagraph' => !empty($customParagraph) ? json_decode((string) $customParagraph, true) : [],
  168. 'slugResolver' => !empty($slugResolver) ? json_decode((string) $slugResolver, true) : [],
  169. 'faqData' => $faqData,
  170. 'locationParents' => $locationParents,
  171. 'sections' => json_decode((string) $sectionService->getSerializedSections(), true),
  172. 'propertyTypeChips' => $listingManager->getListingPropertyTypesChips($request, $location, $section, $propertyType),
  173. ];
  175. $cachedResponse->set(json_encode($response));
  176. $cachedResponse->expiresAfter(3600 * 3);
  177. $cache->save($cachedResponse);
  178. }
  180. return new JsonResponse(json_decode((string) $cachedResponse->get(), true));
  181. }
  183. #[Rest\Get('/api/v4/listings/trigger-search', options: ['i18n' => false], name: 'aqarmap_api_trigger_search_listings_v4')]
  184. public function triggerSearchListings(Request $request, MessageBusInterface $messageBus)
  185. {
  186. $user = $this->getUser();
  188. if ($request->get('location')) {
  189. $request->query->set('locations', explode(',', $request->query->get('location', '')));
  190. }
  192. if ($request->get('keywordSearch')) {
  193. $this->eventDispatcher->dispatch(new SearchTriggerEvent($request));
  194. }
  196. if ($user) {
  197. $messageBus->dispatch(new Search($request->query, $user));
  198. }
  200. return new JsonResponse([
  201. 'statusCode' => Response::HTTP_OK,
  202. 'statusMessage' => 'Search triggered successfully!',
  203. ]);
  204. }
  206. private function mapPaginatedBody(array $result, array $listings): array
  207. {
  208. if (!$result['pagination']) {
  209. return [
  210. 'statusCode' => $this->getStatusCode(),
  211. 'statusMessage' => $this->getStatusMessage(),
  212. 'paginate' => [],
  213. 'data' => [],
  214. 'errors' => $this->getErrors(),
  215. ];
  216. }
  218. return [
  219. 'statusCode' => $this->getStatusCode(),
  220. 'statusMessage' => $this->getStatusMessage(),
  221. 'paginate' => $result['pagination'],
  222. 'data' => $listings,
  223. 'errors' => $this->getErrors(),
  224. ];
  225. }
  226. }