src/Service/SearchService.php line 118

Open in your IDE?
  1. <?php
  4. namespace App\Service;
  7. use App\Interfaces\HotelMongoInterface;
  8. use App\Interfaces\SearchInterface;
  9. use App\Vendor\Symfony\HAbstractService;
  10. use App\Vendor\Symfony\UserException;
  11. use Doctrine\ORM\EntityManagerInterface;
  12. use Psr\Log\LoggerInterface;
  13. use Symfony\Component\DependencyInjection\ParameterBag\ContainerBagInterface;
  14. use Symfony\Component\HttpKernel\KernelInterface;
  15. use Symfony\Contracts\Translation\TranslatorInterface;
  17. class SearchService extends HAbstractService implements SearchInterface
  18. {
  19.     private array $guests = [];
  20.     private HotelMongoInterface $hotelMongo;
  21.     private LoggerInterface $zstLogger;
  23.     public function __construct(ContainerBagInterface $bag, EntityManagerInterface $em, KernelInterface $kernel, HotelMongoInterface $hotelMongo, TranslatorInterface $translator, LoggerInterface $zstLogger)
  24.     {
  25.         parent::__construct($bag, $em, $kernel,$translator);
  26.         $this->translator = $translator;
  27.         $this->hotelMongo = $hotelMongo;
  28.         $this->zstLogger = $zstLogger;
  29.     }
  32.     /**
  33.      * @param int $regionId
  34.      * @param string $checkIn
  35.      * @param string $checkOut
  36.      * @param array $gusts
  37.      * @param string $language
  38.      * @param string $currency
  39.      * @param int $hotelsLimit
  40.      * @param string $residency
  41.      * @return array
  42.      */
  43.     public function regionSearch(int $regionId, string $checkIn, string $checkOut, string $language, string $currency = "", int $hotelsLimit = 0, string $residency = ""): array
  44.     {
  45.         $params = get_defined_vars();
  46.         $data = $this->sendData( self::REGION_SEARCH,$params);
  48.         return $data;
  49.     }
  51.     /**
  52.      * @param float $latitude
  53.      * @param float $longitude
  54.      * @param int $radius
  55.      * @param string $checkIn
  56.      * @param string $checkOut
  57.      * @param array $gusts
  58.      * @param string $language
  59.      * @param string $currency
  60.      * @param string $residency
  61.      * @return array
  62.      */
  63.     public function geoSearch(float $latitude, float $longitude, int $radius, string $checkIn, string $checkOut, string $language, string $currency = "", string $residency = ""): array
  64.     {
  65.         $params = get_defined_vars();
  66.         $data = $this->generateSearchQuery( self::GEO_SEARCH,$params);
  67.         return $data;
  68.     }
  70.     /**
  71.      * @param array $ids
  72.      * @param string $checkIn
  73.      * @param string $checkOut
  74.      * @param array $gusts
  75.      * @param string $language
  76.      * @param string $currency
  77.      * @param string $residency
  78.      * @return array
  79.      */
  80.     public function hotelsSearch(array $ids, string $checkIn, string $checkOut, string $language, string $currency = "", string $residency = ""): array
  81.     {
  82.         $params = get_defined_vars();
  83.         $result = $this->sendData( self::HOTELS_SEARCH,$params);
  84.         return $result;
  85.     }
  87.     /**
  88.      * @param string $search
  89.      * @param string $language
  90.      * @return array
  91.      */
  92.     public function hotelSearchAutocomplete(string $search, string $language): array
  93.     {
  94.         return [];
  95.     }
  97.     /**
  98.      * @param string $id
  99.      * @param string $checkIn
  100.      * @param string $checkOut
  101.      * @param array $gusts
  102.      * @param string $language
  103.      * @param string $currency
  104.      * @param string $residency
  105.      * @return array
  106.      */
  107.     public function hotelPage(string $id, string $checkIn, string $checkOut, string $language, string $currency = "", string $residency = ""): array
  108.     {
  109.         return [];
  110.     }
  112.     /**
  113.      * @param array $rooms
  114.      * @throws UserException
  115.      * @throws \Psr\Container\ContainerExceptionInterface
  116.      * @throws \Psr\Container\NotFoundExceptionInterface
  117.      */
  118.     public function setRooms(array $rooms){
  119.         $children = [];
  120.         if(empty($rooms)){
  121.             throw new \Exception("rooms is required");
  122.         }
  123.         if(count($rooms) > (int)$this->bag->get('rooms_count')){
  124.             throw new UserException($this->translator->trans('roomsCount', ['{number}' => $this->bag->get('rooms_count')]));
  125.         }
  126.         foreach ($rooms as $room){
  127.             if(!empty($room["children"])){
  128.                 $children = explode(',', $room["children"][0]);
  129.                 foreach ($children as $key=>&$c){
  130.                     if($c == 'NaN'){
  131.                         unset($children[$key]);
  132.                         continue;
  133.                     }
  134.                     $children[$key] = intval($c);
  135.                 }
  136.             }
  137.             $roomChildrenCount = count($children);
  138.             if($roomChildrenCount > (int)$this->bag->get('children_count')){
  139.                 throw new UserException($this->translator->trans('childrenCount', ['{number}' => $this->bag->get('children_count')]));
  140.             }
  142.             foreach ($children as $child){
  143.                 if((int)$child > (int)$this->bag->get('children_age')){
  144.                     throw new UserException($this->translator->trans('childrenAge', ['{year}' => $this->bag->get('children_age')]));
  145.                 }
  146.             }
  148.             $roomGuests = [
  149.                 "adults" => empty($room["adults"]) ? 2 :(int)$room["adults"],
  150.                 "children" => $children
  151.             ];
  153.             $this->guests[] = $roomGuests;
  154.         }
  155.     }
  157.     public function generateSearchQuery($type, $params = []){
  159.         if(!empty($params["checkIn"])){
  160.             $params["checkin"] = $params["checkIn"];
  161.         }
  162.         if(!empty($params["checkOut"])){
  163.             $params["checkout"] = $params["checkOut"];
  164.         }
  166.         $currentDay = date("Y-m-d");
  167.         $checkIn = empty($params["checkin"]) ? date("Y-m-d", strtotime($currentDay . ' +1 day')) : $params["checkin"];
  168.         $checkOut = empty($params["checkout"]) ? date('Y-m-d', strtotime($checkIn . ' +1 day')) : $params["checkout"];
  169.         $language = empty($params["language"]) ? $this->request->getLocale() : $params["language"];
  171.         if(empty($this->guests)){
  172.             $this->guests = [
  173.                 [
  174.                     "adults" => empty($room["adults"]) ? 2 :(int)$room["adults"],
  175.                     "children" => !empty($room["children"]) ? $room["children"] : []
  176.                 ]
  177.             ];
  178.         }
  179.         $query = [
  180.             "checkin" => $checkIn,
  181.             "checkout" => $checkOut,
  182.             "language" => $language,
  183.             "guests" => $this->guests,
  184.             "residency"=> $params["residency"],
  185.         ];
  186.         if($type == self::REGION_SEARCH){
  187.             $query["region_id"] = $params["regionId"];
  188.         }
  189.         if($type == self::GEO_SEARCH){
  190.             $query["latitude"] = $params["latitude"];
  191.             $query["longitude"] = $params["longitude"];
  192.             $query["radius"] = $params["radius"];
  193.         }
  194.         if($type == self::HOTELS_SEARCH){
  195.             $query["ids"] = $params["ids"];
  196.         }
  197.         if($type == self::HOTEL_PAGE){
  198.             $query['id'] = trim($params["hotelId"]);
  199.         }
  200.         $query["currency"] = empty($params["currency"]) ? "RUB" : $params["currency"];
  202.         if(!empty($hotelsLimit)){
  203.             $query["hotels_limit"] = $hotelsLimit;
  204.         }
  206.         return json_encode($query);
  207.     }
  209.     public function searchAutocomplete($params){
  210.         $search = [
  211.             "query" => $params["search"],
  212.             "language" => $params["lang"],
  213.         ];
  214.         $postData = json_encode($search);
  216.         $curl = curl_init();
  218.         curl_setopt_array($curl, array(
  219.             CURLOPT_URL => 'https://api.worldota.net/api/b2b/v3/search/multicomplete/',
  220.             CURLOPT_USERPWD => $this->bag->get('zstd_user').":".$this->bag->get('zstd_pass'),
  221.             CURLOPT_RETURNTRANSFER => true,
  222.             CURLOPT_ENCODING => '',
  223.             CURLOPT_MAXREDIRS => 10,
  224.             CURLOPT_TIMEOUT => 0,
  225.             CURLOPT_FOLLOWLOCATION => true,
  226.             CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  227.             CURLOPT_CUSTOMREQUEST => 'POST',
  228.             CURLOPT_POSTFIELDS =>$postData,
  229.             CURLOPT_HTTPHEADER => array(
  230.                 'Content-Type: application/json'
  231.             ),
  232.         ));
  234.         $response = curl_exec($curl);
  235.         $error = curl_error($curl);
  236.         $data = json_decode($response, true);
  237.         curl_close($curl);
  239.         if($data["status"] == "ok" && empty($data["error"])){
  240.             return $data["data"];
  241.         } else {
  242.             return $data["error"];
  243.         }
  244.     }
  246.     private function sendData($type, $params){
  247.         $jsonParams = $this->generateSearchQuery($type, $params);
  248.         $curl = curl_init();
  250.         curl_setopt_array($curl, array(
  251.             CURLOPT_URL => 'https://api.worldota.net/api/b2b/v3/search/serp/region/',
  252.             CURLOPT_USERPWD => $this->bag->get('zstd_user').":".$this->bag->get('zstd_pass'),
  253.             CURLOPT_RETURNTRANSFER => true,
  254.             CURLOPT_ENCODING => '',
  255.             CURLOPT_MAXREDIRS => 10,
  256.             CURLOPT_TIMEOUT => 0,
  257.             CURLOPT_FOLLOWLOCATION => true,
  258.             CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  259.             CURLOPT_CUSTOMREQUEST => 'POST',
  260.             CURLOPT_POSTFIELDS =>$jsonParams,
  261.             CURLOPT_HTTPHEADER => array(
  262.                 'Content-Type: application/json'
  263.             ),
  264.         ));
  266.         $response = curl_exec($curl);
  268.         curl_close($curl);
  269.         $respArray = json_decode($response, true);
  270.         if(empty($respArray["data"])){
  271.             return [];
  272.         }
  273.         foreach ($respArray["data"]["hotels"] as $ind=>$datum){
  274.             foreach ($datum["rates"] as $rIndex =>$rate){
  275.                 if($rate["allotment"] == 0){
  276.                     unset($datum["rates"][$rIndex]);
  277.                 }
  278.             }
  279.             if(count($datum["rates"]) < 1){
  280.                 unset($datum["hotels"][$ind]);
  281.             }
  282.         }
  284.         $resp = json_encode($respArray["data"]["hotels"]);
  285.         $session = $this->request->getSession();
  286.         if($session->has("search_result")){
  287.             $session->remove("search_result");
  288.         }
  289.         $session->set("search_result", $resp);
  291.         return $this->getIds();
  292.     }
  294.     private function getIds(){
  295.         $session = $this->request->getSession();
  296.         $regions = json_decode($session->get("search_result"), true);
  297.         $hotels = [];
  298.         $ids = [];
  299.         foreach ($regions as $region){
  300.             if(isset($region["rates"]) && !empty($region["rates"])){
  301.                 $ids[] = $region["id"];
  302.                 $hotels[$region["id"]] = $region;
  303.             }
  304.         }
  306.         return ["ids" => $ids, "hotels" => $hotels];
  307.     }
  308. }