src/Controller/SearchController.php line 79

Open in your IDE?
  1. <?php
  3. namespace Slivki\Controller;
  5. use Slivki\Entity\Offer;
  6. use Slivki\Entity\UserGroup;
  7. use Slivki\Services\DeviceTypeService;
  8. use Slivki\Services\Seo\SeoResourceService;
  9. use Symfony\Component\Routing\Annotation\Route;
  10. use Slivki\Entity\Banner;
  11. use Slivki\Entity\Category;
  12. use Slivki\Entity\City;
  13. use Slivki\Entity\GeoLocation;
  14. use Slivki\Entity\User;
  15. use Slivki\Services\CacheService;
  16. use Slivki\Services\SearchService;
  17. use Slivki\Services\SolrIndex;
  18. use Slivki\Util\CommonUtil;
  19. use Symfony\Component\HttpFoundation\JsonResponse;
  20. use Symfony\Component\HttpFoundation\RedirectResponse;
  21. use Symfony\Component\HttpFoundation\Request;
  22. use Symfony\Component\HttpFoundation\Response;
  23. use Symfony\Component\Validator\Constraints\DateTime;
  25. class SearchController extends SiteController {
  26.     const OFFERS_PER_PAGE = 44;
  27.     const ACTIVE_OFFERS_PER_PAGE = 44;
  28.     const PAST_OFFERS_ON_FIRST_PAGE = 4;
  29.     const PAST_OFFERS_PER_PAGE = 44;
  30.     const SUGGEST_MAX_RESULT = 5;
  31.     const CACHE_NAME = 'search-5-';
  32.     const DEBUG_MODE = false;
  33.     const ACTIVE_OFFERS_ROWS_PER_PAGE = 20;
  34.     const ACTIVE_OFFERS_ROWS_PER_PAGE_MOBILE = 8;
  35.     const SEARCH_OFFERS = 0;
  36.     const SEARCH_SALES = 1;
  37.     const SEARCH_PARTNER_OFFERS = 2;
  38.     const SEARCH_INSTALLMENTS = 5;
  39.     const SEARCH_FLIERS = 6;
  40.     const SEARCH_PHOTO_GUIDES = 7;
  42.     /**
  43.      * @Route("/search")
  44.      */
  45.     public function searchAction(
  46.         Request $request,
  47.         SearchService $searchService,
  48.         DeviceTypeService $deviceTypeService
  49.     ): Response {
  50.         ini_set('memory_limit', '2g');
  51.         $isMobileDevice = $deviceTypeService->isMobileDevice($request);
  52.         $searchText = $request->query->get('text');
  53.         $searchText = mb_strtolower(trim($searchText));
  55.         $response = new Response();
  57.         $redirect = $this->checkForRedirect($searchText, $request);
  58.         if ($redirect) {
  59.             return new RedirectResponse($redirect['url']);
  60.         }
  62.         $entityManager = $this->getDoctrine()->getManager();
  63.         $banners = $entityManager->getRepository(Banner::class)->findBy(['typeID' => Banner::TYPE_SEARCH_BANNER, 'active' => true, 'positionRow' => 1]);
  64.         $banner = null;
  65.         if ($banners) {
  66.             $banner = $banners[random_int(0, count($banners) - 1)];
  67.         }
  69.         $secondBanners = $entityManager->getRepository(Banner::class)->findBy(['typeID' => Banner::TYPE_SEARCH_BANNER, 'active' => true, 'positionRow' => 2]);
  70.         $secondBanner = null;
  71.         if ($secondBanners) {
  72.             $secondBanner = $secondBanners[random_int(0, count($secondBanners) - 1)];
  73.         }
  75.         $sortBy = $request->query->get('sortBy', 'default');
  76.         $distance = $request->query->getInt('distance');
  77.         $isVoice = $request->query->getBoolean('isVoice');
  78.         $cityID = null;
  79.         $currentCityID = $request->getSession()->get(City::CITY_ID_SESSION_KEY, City::DEFAULT_CITY_ID);
  80.         $userLocation = $request->cookies->get(User::CURRENT_LOCATION_COOKIE, GeoLocation::DEFAULT_LOCATION);
  82.         if ($this->getUser() && $this->getUser()->hasRole(UserGroup::ROLE_ADS_FREE)) {
  83.             $searchBanner = '';
  84.             $searchBannerSecond = '';
  85.         } else {
  86.             $searchBanner = $this->renderView($isMobileDevice ? 'Slivki/mobile/banner/banner.html.twig' : 'Slivki/banners/search_banner.html.twig', [
  87.                 'banner' => $banner,
  88.                 'additionalClass' => 'd-block d-sm-none',
  89.             ]);
  90.             $searchBannerSecond = $this->renderView($isMobileDevice ? 'Slivki/mobile/banner/banner.html.twig' : 'Slivki/banners/search_banner.html.twig', [
  91.                 'banner' => $secondBanner,
  92.                 'additionalClass' => 'd-block d-sm-none',
  93.             ]);
  94.         }
  96.         $searchResultHtml = str_replace(
  97.             [
  98.                 '<!--::searchBanner::-->',
  99.                 '<!--::searchBannerSecond::-->',
  100.                 '---slivkis---',
  101.             ],
  102.             $currentCityID === City::TASHKENT_CITY_ID
  103.                 ? ['', '', '']
  104.                 : [
  105.                     $searchBanner,
  106.                     $searchBannerSecond,
  107.                     $request->cookies->get('slivkis'),
  108.                 ],
  109.             $searchService->search(
  110.                 $searchText,
  111.                 $sortBy,
  112.                 $distance,
  113.                 $userLocation,
  114.                 $isMobileDevice,
  115.                 true,
  116.                 false,
  117.                 $this->getUser() ? $this->getUser()->getID() : null,
  118.                 $cityID,
  119.                 $currentCityID,
  120.                 $isVoice,
  121.             ),
  122.         );
  124.         if ($isMobileDevice) {
  125.             $searchResultHtml = str_replace(
  126.                 $currentCityID === City::TASHKENT_CITY_ID
  127.                     ? ['', '']
  128.                     : [
  129.                         '<!--::searchBanner2::-->',
  130.                         '<!--::searchBannerSecond2::-->',
  131.                     ],
  132.                 [
  133.                     $this->renderView('Slivki/mobile/banner/banner.html.twig', [
  134.                         'banner' => $banner,
  135.                         'additionalClass' => 'd-none d-sm-block',
  136.                     ]),
  137.                     $this->renderView('Slivki/mobile/banner/banner.html.twig', [
  138.                         'banner' => $secondBanner,
  139.                         'additionalClass' => 'd-none d-sm-block',
  140.                     ]),
  141.                 ],
  142.                 $searchResultHtml,
  143.             );
  144.         }
  146.         $content = $this->renderView($isMobileDevice ? 'Slivki/mobile/search/index.html.twig' : 'Slivki/search/index.html.twig', [
  147.             'searchResultHtml' => $searchResultHtml,
  148.             'searchText' => $searchText,
  149.             'currentLocationCookie' => $request->cookies->get('currentLocation')
  150.         ]);
  151.         $response->setContent($content);
  153.         return $response;
  154.     }
  156.     /** @Route("/search/all_entities_more") */
  157.     public function searchAllEntitiesMoreAction(Request $request, SearchService $searchService, SolrIndex $solrIndex) {
  158.         ini_set('memory_limit', '2G');
  159.         $searchText = $request->query->get('text');
  160.         $searchText = mb_strtolower(trim($searchText));
  161.         $sortBy = $request->query->get('sortBy');
  162.         $page = 1 + $request->query->getInt('page');
  163.         $distance = $request->query->getInt('distance');
  164.         $cityID = $request->query->getInt('cityID');
  165.         $searchResult = $solrIndex->searchAll($searchText, $cityID);
  166.         if ($searchResult['count'] == 0) {
  167.             $searchResult = $solrIndex->searchAll($searchService->transformToCyrillic($searchText), $cityID);
  168.         }
  169.         $userLocation = $request->cookies->get(User::CURRENT_LOCATION_COOKIE, GeoLocation::DEFAULT_LOCATION);
  170.         $isMobileDevice = CommonUtil::isMobileDevice($request);
  171.         $allFoundEntities = $searchService->getAllFoundEntities($userLocation, $searchText, $searchResult, $sortBy, $distance, $isMobileDevice, $page);
  172.         $data['allFoundEntities'] = &$allFoundEntities;
  173.         $data['activeOffers'] = &$allFoundEntities;
  174.         $data['searchText'] = $searchText;
  175.         $data['totalColumnAmount'] = self::getMobileDevice($request) ? 2 : 4;
  176.         $data['cityID'] = $cityID;
  177.         return $this->render($isMobileDevice ? 'Slivki/mobile/search/result.html.twig' : 'Slivki/search/all_results.html.twig', $data);
  178.     }
  180.     public function checkForRedirect($searchText, $request) {
  181.         $data = [];
  182.         switch ($searchText) {
  183.             case "личный кабинет":
  184.                 $url = "/profile";
  185.                 $data['url'] = $url;
  186.                 break;
  188.             case "код":
  189.                 $url = "/profile";
  190.                 if (self::getMobileDevice($request)) {
  191.                     $url = "/profile#profilePromocodeTab";
  192.                 }
  193.                 $data['url'] = $url;
  194.                 break;
  196.             case "коды":
  197.                 $url = "/profile";
  198.                 if (self::getMobileDevice($request)) {
  199.                     $url = "/profile#profilePromocodeTab";
  200.                 }
  201.                 $data['url'] = $url;
  202.                 break;
  204.             case "промокоды":
  205.                 $url = "/profile";
  206.                 if (self::getMobileDevice($request)) {
  207.                     $url = "/profile#profilePromocodeTab";
  208.                 }
  209.                 $data['url'] = $url;
  210.                 break;
  212.             case "мои коды":
  213.                 $url = "/profile";
  214.                 if (self::getMobileDevice($request)) {
  215.                     $url = "/profile#profilePromocodeTab";
  216.                 }
  217.                 $data['url'] = $url;
  218.                 break;
  220.             case "мои промокоды":
  221.                 $url = "/profile";
  222.                 if (self::getMobileDevice($request)) {
  223.                     $url = "/profile#profilePromocodeTab";
  224.                 }
  225.                 $data['url'] = $url;
  226.                 break;
  228.             case "код скидки":
  229.                 $url = "/profile";
  230.                 if (self::getMobileDevice($request)) {
  231.                     $url = "/profile#profilePromocodeTab";
  232.                 }
  233.                 $data['url'] = $url;
  234.                 break;
  236.             case "новые":
  237.                 $url = SeoResourceService::NEW_OFFERS_CATEGORY_URL;
  238.                 $data['url'] = $url;
  239.                 break;
  241.             case "листовки":
  242.                 $url = "/giper-shop?utm_source=main_menu";
  243.                 $data['url'] = $url;
  244.                 break;
  246.             case "гипермаркеты":
  247.                 $url = "/giper-shop?utm_source=main_menu";
  248.                 $data['url'] = $url;
  249.                 break;
  251.             case "торговые сети":
  252.                 $url = "/giper-shop?utm_source=main_menu";
  253.                 $data['url'] = $url;
  254.                 break;
  256.             case "салоны красоты":
  257.                 $url = "/salony-krasoty";
  258.                 $data['url'] = $url;
  259.                 break;
  261.             case "видеогид":
  262.             case "видеогиды":
  263.                 $url = "/videogidy";
  264.                 $data['url'] = $url;
  265.                 break;
  267.         }
  268.         if ($data) {
  269.             return $data;
  270.         }
  271.         return false;
  272.     }
  274.     /** @Route("/search/more") */
  275.     public function moreAction(Request $request, CacheService $cacheService, SearchService $searchService, SolrIndex $solrIndex) {
  276.         $isMobileDevice = CommonUtil::isMobileDevice($request);
  277.         $page = $request->query->get('activeOffersPage', 0) + 1;
  278.         $sortBy = $request->query->get('sortBy', 'default');
  279.         $distance = $request->query->get('distance', 0);
  280.         $searchText = $request->query->get('text');
  281.         $searchText = mb_strtolower(trim($searchText));
  282.         $cityID = $request->query->getInt('cityID');
  283.         $searchResult = $solrIndex->searchOffers($searchText, $cityID);
  284.         $relevantResults = [];
  285.         foreach ($searchResult['allResults'] as $item) {
  286.             $notFound = true;
  287.             foreach ($searchResult['descriptionResults'] as $result) {
  288.                 if ($result['id'] == $item['id']) {
  289.                     $notFound = false;
  290.                     break;
  291.                 }
  292.             }
  293.             if ($notFound) {
  294.                 $relevantResults[] = $item;
  295.             }
  296.         }
  297.         $searchResult = $relevantResults;
  298.         if (count($searchResult) == 0) {
  299.             $searchResult = $solrIndex->searchOffers($searchService->transformToCyrillic($searchText), $cityID, false, $cityID);
  300.             $searchResult = $searchResult['allResults'];
  301.         }
  302.         $offers = ['list' => [], 'page' => $page, 'haveMore' => false];
  303.         foreach ($searchResult as $item) {
  304.             $offers['list'][] = $item['id'];
  305.         }
  306.         $userLocation = $request->cookies->get(User::CURRENT_LOCATION_COOKIE, GeoLocation::DEFAULT_LOCATION);
  307.         if (!is_array($userLocation)) {
  308.             $userLocation = explode(',', $userLocation);
  309.         }
  310.         if ($distance > 0) {
  311.             $this->filterByDistance($offers['list'], $userLocation, $distance);
  312.         }
  313.         if ($sortBy != 'default') {
  314.             $this->sortResults($offers['list'], $sortBy, $userLocation);
  315.         }
  316.         $perPage = self::OFFERS_PER_PAGE;
  317.         $offset =  $perPage * ($page - 1);
  318.         $offers['haveMore'] = count($offers['list']) > $offset + $perPage;
  319.         $offers['page'] = $page;
  320.         $offers['list'] = array_slice($offers['list'], $offset, $perPage + 10);
  321.         $entityManager = $this->getDoctrine()->getManager();
  322.         $offerRepository =  $entityManager->getRepository(Offer::class);
  323.         $offerList = [];
  324.         foreach ($offers['list'] as $offerID) {
  325.             $offer = $cacheService->getTeaser($offerID, $isMobileDevice);
  326.             if (!$offer) {
  327.                 $offer = $offerRepository->getAnyWay($offerID);
  328.             }
  329.             if ($offer) {
  330.                 $offerList[] = $offer;
  331.             }
  332.             if (count($offerList) >= $perPage) {
  333.                 break;
  334.             }
  335.         }
  336.         $offers['list'] = $offerList;
  337.         $data['totalColumnAmount'] = $isMobileDevice ? 2 : 4;
  338.         $data['activeOffers'] = $offers;
  339.         $data['searchText'] = $searchText;
  340.         $data['offset'] = $offset + $perPage;
  341.         $data['cityID'] = $cityID;
  343.         return $this->render($isMobileDevice ? 'Slivki/mobile/search/result.html.twig' : 'Slivki/search/results.html.twig', $data);
  344.     }
  346.     /**
  347.      * @Route("/search/suggest")
  348.      */
  349.     public function suggestAction(Request $request, SearchService $searchService) {
  350.         $response = new JsonResponse();
  351.         $response->setCharset('UTF-8');
  352.         $response->setEncodingOptions(JSON_UNESCAPED_UNICODE);
  353.         $response->setData($searchService->getSuggest($request->get('term', '')));
  354.         return $response;
  355.     }
  357.     public function luceneSearchAction(Request $request) {
  358.         /** @var \Slivki\Util\LuceneIndex  $luceneIndex */
  359.         $luceneIndex = $this->get('slivki.lucene_index');
  360.         $activeOfferList = [];
  361.         $pastOfferList = [];
  362.         $saleList = [];
  363.         $searchText = trim($request->get('text'));
  364.         if ($searchText != '') {
  365.             $result = $luceneIndex->search($searchText);
  366.             foreach ($result as $item) {
  367.                 if ($item['type'] == Category::OFFER_CATEGORY_ID) {
  368.                     /** @var \Slivki\Entity\Offer  $offer */
  369.                     $offer = $this->getOfferRepository()->find($item['id']);
  370.                     if ($offer) {
  371.                         if ($offer->getActiveTill() > new DateTime()) {
  372.                             $activeOfferList[] = $offer;
  373.                         } else {
  374.                             $pastOfferList[] = $offer;
  375.                         }
  376.                     }
  377.                 } else {
  378.                     $sale = $this->getSaleRepository()->find($item['id']);
  379.                     if ($sale) {
  380.                         $saleList[] = $sale;
  381.                     }
  382.                 }
  383.             }
  384.         }
  385.         $data['expanded'] = false;
  386.         $data['offerList'] = $pastOfferList;
  387.         $activeOffers = $this->get('twig')->render('Slivki/offers/teasers.html.twig', $data);
  388.         return new Response($activeOffers);
  389.     }
  391.     private function filterByDistance(&$offerList, $location, $distance) {
  392.         if (count($offerList) == 0) {
  393.             return;
  394.         }
  395.         $sql = "select geo_location_relation.entity_id  from geo_location_relation inner join geo_location on geo_location_relation.location_id = geo_location.id 
  396.           where geo_location.latitude <> '' and geo_location.longitude <> '' and geo_location_relation.entity_id in (" . implode(',', $offerList) . ") 
  397.           and earth_distance(ll_to_earth($location[0], $location[1]), ll_to_earth(latitude::float8, longitude::float8)) * 1.25 <= $distance * 1000";
  398.         $result = $this->getDoctrine()->getConnection()->executeQuery($sql)->fetchAll(\PDO::FETCH_COLUMN);
  399.         $offerListFiltered = [];
  400.         foreach ($offerList as $offerID) {
  401.             if (in_array($offerID, $result)) {
  402.                 $offerListFiltered[] = $offerID;
  403.             }
  404.         }
  405.         $offerList = $offerListFiltered;
  406.     }
  408.     private function sortResults(&$data, $sortBy, $location) {
  409.         if ($sortBy == 'popularity') {
  410.             if (isset($data['list'])) {
  411.                 $this->sortOffersByPopularity($data['list']);
  412.             } else {
  413.                 $this->sortSalesByPopularity($data);
  414.             }
  415.         } else {
  416.             if (isset($data['list'])) {
  417.                 $this->sortOffersByDistance($data['list'], $location);
  418.             } else {
  419.                 $this->sortOffersByDistance($data, $location);
  420.             }
  421.         }
  422.     }
  424.     private function sortOffersByDistance(&$offerList, $location) {
  425.         if (count($offerList) == 0) {
  426.             return;
  427.         }
  428.         $sql = "select geo_location_relation.entity_id 
  429.           from geo_location_relation inner join geo_location on geo_location_relation.location_id = geo_location.id where geo_location.latitude <> '' and geo_location.longitude <> '' 
  430.           and geo_location_relation.entity_id in (" . implode(',', $offerList) . ") order by  earth_distance(ll_to_earth($location[0], $location[1]), ll_to_earth(latitude::float8, longitude::float8))";
  431.         $result = $this->getDoctrine()->getConnection()->executeQuery($sql)->fetchAll(\PDO::FETCH_COLUMN);
  432.         $offerList = array_unique(array_merge($result, array_diff($result, $offerList)));
  433.     }
  435.     private function sortOffersByPopularity(&$offerList) {
  436.         if (count($offerList) == 0) {
  437.             return;
  438.         }
  439.         $sql = 'select entity_id, purchase_count_recent as purchase_count from purchase_count where entity_id in (' . implode(',', $offerList) . ')';
  440.         $result = $this->getDoctrine()->getManager()->getConnection()->executeQuery($sql)->fetchAll(\PDO::FETCH_ASSOC);
  441.         $purchaseCountList = [];
  442.         foreach ($result as $item) {
  443.             $purchaseCountList[$item['entity_id']] = $item['purchase_count'];
  444.         }
  445.         usort($offerList, function($offerID, $offerID1) use(&$purchaseCountList) {
  446.             $purchaseCount = isset($purchaseCountList[$offerID]) ? $purchaseCountList[$offerID] : 0;
  447.             $purchaseCount1 = isset($purchaseCountList[$offerID1]) ? $purchaseCountList[$offerID1] : 0;
  448.             return $purchaseCount > $purchaseCount1 ? -1 : 1;
  449.         });
  450.     }
  452.     private function sortSalesByPopularity(&$saleList) {
  453.         if (count($saleList) == 0) {
  454.             return 0;
  455.         }
  456.         $sql = 'select entity_id, visit_count from visit_count_aggregated where entity_id in (' . implode(',', $saleList) . ') and days_count = 7';
  457.         $result = $this->getDoctrine()->getManager()->getConnection()->executeQuery($sql)->fetchAll(\PDO::FETCH_ASSOC);
  458.         $visitCountList = [];
  459.         foreach ($result as $item) {
  460.             $visitCountList[$item['entity_id']] = $item['visit_count'];
  461.         }
  462.         usort($saleList, function($saleID, $saleID1) use($visitCountList) {
  463.             $visitCount = isset($visitCountList[$saleID]) ? $visitCountList[$saleID] : 0;
  464.             $visitCount1 = isset($visitCountList[$saleID1]) ? $visitCountList[$saleID1] : 0;
  465.             return $visitCount > $visitCount1 ? -1 : 1;
  466.         });
  467.     }
  468. }