src/Repository/Otpusk/CityRepository.php line 97

Open in your IDE?
  1. <?php
  3. namespace App\Repository\Otpusk;
  5. use App\Entity\Otpusk\City;
  6. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  7. use Doctrine\ORM\EntityRepository;
  8. use Doctrine\ORM\Query\Expr\Join;
  9. use Doctrine\Persistence\ManagerRegistry;
  10. use GeoIp2\Database\Reader;
  11. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  12. use function Doctrine\ORM\QueryBuilder;
  14. class CityRepository extends ServiceEntityRepository
  15. {
  16.     private $imgUrl = 'https://www.otpusk.com/';
  18.     private $dbNormalizer;
  20.     public function __construct(ManagerRegistry $registry, ParameterBagInterface $config)
  21.     {
  22.         parent::__construct($registry, City::class);
  23.         $this->dbNormalizer = $config->get('db_normalizer');
  24.     }
  26.     public function checkDepartureCity($city, $locale = 'ru')
  27.     {
  28.         $name = $this->dbNormalizer['city']['name'][$locale];
  30.         return $this->createQueryBuilder('c')
  31.             ->select('c.id AS id, c.'.$name.'Rd AS nameRd, c.fNameTr AS nameTr')
  32.             ->andWhere('c.fNameTr = :city')
  33.             ->setParameter('city', $city)
  34.             ->getQuery()
  35.             ->getOneOrNullResult()
  36.         ;
  37.     }
  39.     public function getDepartureCitiesForCountrySearchPage($citiesIds, $locale = 'ru', $dbNormalizer)
  40.     {
  41.         $name = $dbNormalizer['city']['name'][$locale];
  43.         $qb = $this->createQueryBuilder('c');
  44.         $qb = $qb
  45.             ->select('c.id, c.'.$name.'Rd AS name, c.fNameTr AS nameTr')
  46.             ->where('c.id IN ('.$citiesIds.')')
  47.             ->getQuery()
  48.         ;
  50.         return $qb->execute();
  51.     }
  53.     public function getTourCitiesForPages($countryId, $cityId = null, $locale = 'ru', $dbNormalizer)
  54.     {
  55.         $name = $dbNormalizer['city']['name'][$locale];
  57.         $qb = $this->createQueryBuilder('c')
  58.             ->select('c.id AS id, c.'.$name.' AS name, c.fNameTr AS nameTr, c.'.$name.'Rd AS nameInGenitiveCase')
  59.             ->leftJoin('c.priceIndex', 'pi');
  60.         if(isset($cityId)){
  61.             $qb->innerJoin('App\Entity\Otpusk\City', 't', \Doctrine\ORM\Query\Expr\Join::WITH, 'c.fCountryID = t.fCountryID')
  62.                 ->where('t.id = :city')
  63.                 ->setParameter('city', $cityId);
  64.         } else {
  65.             $qb->where('c.fCountryID = :country')
  66.                 ->setParameter('country', $countryId);
  67.         }
  69.         $qb->andWhere('pi.id IS NOT NULL')
  70.             ->andWhere('pi.date > :now')
  71.             ->setParameter('now', new \DateTime())
  72.             ->groupBy('c.id')
  73.             ->orderBy('c.fName', 'ASC')
  74.             ->having('COUNT(pi.id) > 0');
  75.         $result = $qb->getQuery()->getArrayResult();
  77.         if (count($result) == 0) {
  78.             $qb = $this->createQueryBuilder('c')
  79.                 ->select('c.id AS id, c.'.$name.' AS name, c.fNameTr AS nameTr, c.'.$name.'Rd AS nameInGenitiveCase');
  80.             if(isset($cityId)){
  81.                 $qb->innerJoin('App\Entity\Otpusk\City', 't', \Doctrine\ORM\Query\Expr\Join::WITH, 'c.fCountryID = t.fCountryID')
  82.                     ->where('t.id = :city')
  83.                     ->setParameter('city', $cityId);
  84.             } else {
  85.                 $qb->where('c.fCountryID = :country')
  86.                     ->setParameter('country', $countryId);
  87.             }
  89.             $qb->groupBy('c.id')
  90.                 ->orderBy('c.fName', 'ASC');
  91.             $result = $qb->getQuery()->getArrayResult();
  92.         }
  94.         return $result;
  95.     }
  97.     public function getPopCities($countryId, $cityId = null, $locale = 'ru', $isDeparture = false, $cityFrom, $dbNormalizer)
  98.     {
  99.         $name = $dbNormalizer['city']['name'][$locale];
  101.         $params = array(
  102.             'baseUrl' => $this->imgUrl,
  103.         );
  105.         $conn = $this->getEntityManager()
  106.             ->getConnection();
  108.         $sql = 'SELECT c.rec_id AS id, c.'.$name.' AS name, c.fNameTr AS nameTr, c.'.$name.'Rd AS nameInGenitiveCase, CONCAT(:baseUrl, "media/city/", LPAD(FLOOR(m.media_id / 100000) + 1, 4, 0), "/", LPAD(FLOOR((m.media_id - (FLOOR(m.media_id / 100000) * 100000))/ 1000) + 1, 2, 0), "/thumb_", m.media_id, "_city_desktop_gallery_2.jpeg") as desktop_gallery, CONCAT(:baseUrl, "media/city/", LPAD(FLOOR(m.media_id / 100000) + 1, 4, 0), "/", LPAD(FLOOR((m.media_id - (FLOOR(m.media_id / 100000) * 100000))/ 1000) + 1, 2, 0), "/thumb_", m.media_id, "_city_mobile_card.jpeg") as mobile_card
  109.                 FROM otpusk.tCities AS c
  110.                 LEFT JOIN otp_tours.media__gallery_media m ON c.gallery_id = m.gallery_id';
  112.         if(isset($cityId)){
  113.             $sql .= ' LEFT JOIN otpusk.tCities AS t ON c.fCountryID = t.fCountryID';
  114.         }
  116.         if ($isDeparture) {
  117.             $sql .= ' '.($isDeparture?'INNER':'LEFT'). ' JOIN otpusk.priceIndex pi ON c.rec_id = pi.cityId';
  118.         }
  120.         if(isset($cityId)){
  121.             $sql .= ' WHERE t.rec_id = :city';
  122.             $params['city'] = $cityId;
  123.         } else {
  124.             $sql .= " WHERE c.fCountryID = :country";
  125.             $params['country'] = $countryId;
  126.         }
  127.         $sql .= " AND c.cityWeight > 0  AND m.position = 1";
  128.         if ($isDeparture) {
  129.             $sql .= " AND c.fPriority = 2 AND pi.fromCityId = :fromCityId";
  130.             $params['fromCityId'] = $cityFrom;
  131.         }
  132.         $sql .= " GROUP BY c.rec_id";
  133.         if (FALSE && $isDeparture) {
  134.             $sql .= " HAVING COUNT(pi.rec_id) > 0";
  135.         }
  136.         $sql .= " ORDER BY c.cityWeight DESC, c.fName LIMIT 6";
  138.         $stmt = $conn->prepare($sql);
  139.         foreach ($params as $index => $param) {
  140.             $stmt->bindValue($index, $param);
  141.         }
  143.         return $stmt->execute()->fetchAll();
  144.     }
  146.     public function getByCategory($market, $category, $locale = 'ru')
  147.     {
  148.         $sql = $this->createQueryBuilder('c')
  149.             ->join('c.cityCategoryValues', 'cv')
  150.             ->leftJoin('cv.category', 'cat')
  151.             ->where('cat.name = :category')
  152.             ->andWhere('cv.market = :marketId')
  153.             ->setParameter('category', $category)
  154.             ->setParameter('marketId', $market['id'])
  155.             ->orderBy('cv.position')
  156.         ;
  158.         return $sql->getQuery()->getResult();
  159.     }
  161.     public function getSimilarById($cityId)
  162.     {
  163.         $params = array(
  164.             'cityId'   => $cityId,
  165.         );
  166.         $conn = $this->getEntityManager()->getConnection();
  167.         $sql = 'SELECT city_similar_in_id as id FROM CitiesSimilar cs WHERE cs.city_similar_id = :cityId ORDER BY cs.priority DESC';
  169.         $stmt = $conn->prepare($sql);
  170.         foreach ($params as $index => $param) {
  171.             $stmt->bindValue($index, $param);
  172.         }
  174.         return $stmt->execute()->fetchAll();
  175.     }
  177.     public function getGuidCitiesByIds($market, $locale = 'ru', $cityId = null, $dbNormalizer)
  178.     {
  179.         $date = new \DateTime();
  180.         $date->add(new \DateInterval('P7D'));
  181.         $nameCity       = $dbNormalizer['city']['name'][$locale];
  182.         $cities = (is_null($cityId)) ? $this->getByCategory($market, 'cities-popular-cities') : $this->getSimilarById($cityId);
  183.         $cityIds = [];
  184.         foreach ($cities as $city) {
  185.             $cityIds[] = (is_null($cityId)) ? $city->getId() : $city['id'];
  186.         }
  187.         foreach ($cityIds as $k => $v) {
  188.             if (empty($v)) unset($cityIds[$k]);
  189.         }
  190.         if ($cityIds) {
  191.             $params = array(
  192.                 'baseUrl'   => $this->imgUrl,
  193.                 'date'      => $date->format('n'),
  194.                 'lang'      => $dbNormalizer['tRefs']['language'][$locale],
  195.             );
  197.             $conn = $this->getEntityManager()
  198.                 ->getConnection();
  200.             $month = strtolower($date->format('M'));
  201.             if ($month == 'dec') $month = 'decm';
  202.             $sql = 'SELECT c.rec_id AS id, c.' . $nameCity . ' AS name, c.fNameTr AS nameTr, co.fNameTr AS countryNameTr, c.' . $nameCity . 'Rd AS nameInGenitiveCase, cw.weight AS seasonWeight, t. ' . $month . ' AS weather, tw. ' . $month . ' AS water, r.fBrief AS text,
  203. CONCAT(:baseUrl, "media/city/", LPAD(FLOOR(m.media_id / 100000) + 1, 4, 0), "/", LPAD(FLOOR((m.media_id - (FLOOR(m.media_id / 100000) * 100000))/ 1000) + 1, 2, 0), "/thumb_", m.media_id, "_city_desktop_gallery_2.jpeg") as desktop_gallery, CONCAT(:baseUrl, "media/city/", LPAD(FLOOR(m.media_id / 100000) + 1, 4, 0), "/", LPAD(FLOOR((m.media_id - (FLOOR(m.media_id / 100000) * 100000))/ 1000) + 1, 2, 0), "/thumb_", m.media_id, "_city_mobile_card.jpeg") as mobile_card
  204.                 FROM otpusk.tCities AS c
  205.                 LEFT JOIN otp_tours.media__gallery_media m ON c.gallery_id = m.gallery_id
  206.                 LEFT JOIN otpusk.citiesWeight cw ON (c.rec_id = cw.cityId AND cw.month = :date)
  207.                 LEFT JOIN otpusk.tCountries co ON (c.fCountryID = co.rec_id)
  208.                 LEFT JOIN otp_misc.temperatures t ON (c.rec_id = t.cityId AND t.temperatureType = "weather")
  209.                 LEFT JOIN otp_misc.temperatures tw ON (c.rec_id = tw.cityId AND tw.temperatureType = "water")
  210.                 LEFT JOIN otpusk.tRefs r ON (c.rec_id = r.fBindID AND r.fRefTypeID = 94 AND r.fLang = :lang)
  211.                 WHERE c.rec_id IN (' . implode(',', $cityIds) . ')
  212.                 GROUP BY c.rec_id 
  213.                 ORDER BY FIELD(c.rec_id, ' . implode(',', $cityIds) . ')';
  215.             $stmt = $conn->prepare($sql);
  216.             foreach ($params as $index => $param) {
  217.                 $stmt->bindValue($index, $param);
  218.             }
  220.             return $stmt->execute()->fetchAll();
  221.         }
  223.         return [];
  224.     }
  226.     public function getCitiesByIds($dbNormalizer, $locale = 'ru', $cityIdsObject = null)
  227.     {
  228.         $name = $dbNormalizer['city']['name'][$locale];
  229.         $cityIds = [];
  230.         foreach ($cityIdsObject as $city) {
  231.             $cityIds[] = $city->getCity()->getId();
  232.         }
  234.         if ($cityIds) {
  235.             $params = array(
  236.                 'baseUrl' => $this->imgUrl,
  237.             );
  239.             $conn = $this->getEntityManager()
  240.                 ->getConnection();
  242.             $sql = 'SELECT c.rec_id AS id, c.' . $name . ' AS name,
  243. CONCAT(:baseUrl, "media/city/", LPAD(FLOOR(m.media_id / 100000) + 1, 4, 0), "/", LPAD(FLOOR((m.media_id - (FLOOR(m.media_id / 100000) * 100000))/ 1000) + 1, 2, 0), "/thumb_", m.media_id, "_city_desktop_gallery_2.jpeg") as desktop_gallery, CONCAT(:baseUrl, "media/city/", LPAD(FLOOR(m.media_id / 100000) + 1, 4, 0), "/", LPAD(FLOOR((m.media_id - (FLOOR(m.media_id / 100000) * 100000))/ 1000) + 1, 2, 0), "/thumb_", m.media_id, "_city_mobile_card.jpeg") as mobile_card
  244.                 FROM otpusk.tCities AS c
  245.                 LEFT JOIN otp_tours.media__gallery_media m ON c.gallery_id = m.gallery_id
  246.                 WHERE c.rec_id IN (' . implode(',', $cityIds) . ')
  247.                 GROUP BY c.rec_id 
  248.                 ORDER BY FIELD(c.rec_id, ' . implode(',', $cityIds) . ')';
  250.             $stmt = $conn->prepare($sql);
  251.             foreach ($params as $index => $param) {
  252.                 $stmt->bindValue($index, $param);
  253.             }
  255.             $cities = $stmt->execute()->fetchAll();
  256.             $results = [];
  257.             foreach ($cities as $city) {
  258.                 $results[$city['id']] = $city;
  259.             }
  261.             return $results;
  262.         }
  264.         return [];
  265.     }
  267.     public function getByCityAliases($dbNormalizer, $locale, string $cityAlias)
  268.     {
  269.         $name = $dbNormalizer['city']['name'][$locale];
  271.         $city =  $this->createQueryBuilder('city')
  272.             ->select('city.'.$name.'Rd as name')
  273.             ->where('city.fNameTr = :cityAlias')
  274.             ->orWhere('city.fNameTr = :cityAliasChanged')
  275.             ->orWhere('city.fNameTr = :cityAliasChangedA')
  276.             ->setParameter('cityAlias', $cityAlias)
  277.             ->setParameter('cityAliasChanged', $cityAlias)
  278.             ->setParameter('cityAliasChangedA', str_replace('_', ' ', $cityAlias))
  279.             ->getQuery()
  280.             ->getOneOrNullResult();
  282.         return $city;
  283.     }
  285.     public function getCityInfo($cityId, $locale = 'ru', $dbNormalizer)
  286.     {
  287.         $nameCountry    = $dbNormalizer['country']['name'][$locale];
  288.         $nameCase       = $dbNormalizer['country']['case'][$locale];
  289.         $nameCity       = $dbNormalizer['city']['name'][$locale];
  290.         $nameCurrency   = $dbNormalizer['country']['currency'][$locale];
  291.         $nameLanguage   = $dbNormalizer['country']['language'][$locale];
  293.         $sql = $this->createQueryBuilder('c')
  294.             ->select('c.id AS id, c.'.$nameCity.' AS name, c.'.$nameCity.'Rd AS nameRd, c.'.$nameCity.'Vn AS nameVn, c.'.$nameCity.'Pr AS namePr, c.'.$nameCity.'Dt AS nameDt, c.fNameTr AS nameTr, country.fNameTr AS countryTr, country.'.$nameCountry.' AS countryName, country.'.$nameCase.'Vn AS countryNameVn, country.foodCost as foodCostCountry, country.coffeeCost as coffeeCostCountry, c.foodCost, c.coffeeCost, country.'.$nameCurrency.' as currencyName, country.'.$nameLanguage.' as language, c.timeLocal, c.timeZone, country.timeLocal as timeLocalCounty, country.timeZone as timeZoneCounty, c.flightTime, country.flightTime as flightTimeCountry')
  295.             ->leftJoin('c.country', 'country', Join::WITH, 'country.id = c.fCountryID')
  296.             ->where('c.id = :city')
  297.             ->setParameter('city', $cityId)
  298.             ->getQuery();
  300.         return $sql->getOneOrNullResult();
  301.     }
  303.     public function getCityFaq($cityId, $type, $locale = 'ru', $dbNormalizer)
  304.     {
  305.         $sql = $this->createQueryBuilder('c')
  306.             ->select('f.fTitle AS title, f.fText AS text, f.fLang AS lang')
  307.             ->leftJoin('c.faqText', 'f')
  308.             ->leftJoin('f.fRefTypeID', 'fb')
  309.             ->where('c.id = :city')
  310.             ->andWhere('f.fLang = :lang')
  311.             ->andWhere('fb.fName = :type')
  312.             ->andWhere('fb.fBindType = :bind')
  313.             ->setParameters(array('city' => $cityId, 'type' => $type, 'bind' => 'city', 'lang' => $dbNormalizer['tRefs']['language'][$locale]))
  314.             ->orderBy('f.fSort', 'DESC')
  315.         ;
  317.         return $sql->getQuery()->getArrayResult();
  318.     }
  320.     public function getCityFaqNew($cityId, $locale = 'ru', $season = null, $month = null, $isDeparture = false, $cityFrom, $dbNormalizer)
  321.     {
  322.         $code = 'citytours';
  323.         if ($isDeparture) $code .= 'departurecity';
  324.         if (!is_null($season)) $code .= $season;
  325.         if (!is_null($month)) $code .= $month;
  326.         $sql = $this->createQueryBuilder('c')
  327.             ->select('f.fTitle AS title, f.fText AS text')
  328.             ->leftJoin('c.faqText', 'f')
  329.             ->leftJoin('f.fRefTypeID', 'fb')
  330.             ->where('c.id = :city')
  331.             ->andWhere('f.fLang = :lang')
  332.             ->andWhere('fb.fCode = :code');
  333.         if ($isDeparture) {
  334.             $sql
  335.                 ->andWhere('f.fFromCityId = :cityFrom')
  336.                 ->setParameter('cityFrom', $cityFrom);
  337.         }
  338.         $sql
  339.             ->setParameter('city', $cityId)
  340.             ->setParameter('code', $code)
  341.             ->setParameter('lang', $dbNormalizer['tRefs']['language'][$locale])
  342.             ->orderBy('f.fSort', 'DESC');
  344.         $result = $sql->getQuery()->getOneOrNullResult();
  345.         if (!is_null($result) && is_resource($result['text'])) {
  346.             rewind($result['text']);
  347.             $result['text'] = stream_get_contents($result['text']);
  348.         }
  349.         return $result;
  350.     }
  352.     public function getWeather($cityId, $lang = 'rus')
  353.     {
  354.         $params = array(
  355.             'city'   => $cityId,
  356.             'lang'   => $lang,
  357.         );
  359.         $conn = $this->getEntityManager()
  360.             ->getConnection();
  362.         $sql = 'SELECT t.temperatureType AS lang, t.jan AS january, t.feb AS february, t.mar AS march, t.apr AS april, t.may AS may, t.jun AS june, t.jul AS july, t.aug AS august, t.sep AS september, t.oct AS october, t.nov AS november, t.decm AS december
  363.                 FROM otp_misc.temperatures t
  364.                 WHERE t.cityId = :city AND t.temperatureType = :lang';
  366.         $stmt = $conn->prepare($sql);
  367.         foreach ($params as $index => $param) {
  368.             $stmt->bindValue($index, $param);
  369.         }
  371.         return $stmt->execute()->fetchAll();
  372.     }
  374.     /**
  375.      * @param int|null $cityId
  376.      * @param string $type
  377.      * @return array
  378.      */
  379.     public function getTemperaturesByCity($cityId)
  380.     {
  381.         $params = array(
  382.             'cityId'   => $cityId,
  383.         );
  385.         $conn = $this->getEntityManager()
  386.             ->getConnection();
  388.         $sql = 'SELECT t.temperatureType as type, t.jan as Jan, t.feb as Feb, t.mar as Mar, t.apr as Apr, t.may as May, t.jun as Jun, t.jul as Jul, t.aug as Aug, t.sep as Sep, t.oct as Oct, t.nov as Nov, t.decm as "Dec"
  389.                 FROM otp_misc.temperatures t
  390.                 WHERE t.cityId = :cityId';
  392.         $stmt = $conn->prepare($sql);
  393.         foreach ($params as $index => $param) {
  394.             $stmt->bindValue($index, $param);
  395.         }
  397.         return $stmt->execute()->fetchAll();
  398.     }
  400.     public function getCityNames($market)
  401.     {
  402.         $conn = $this->getEntityManager()
  403.             ->getConnection();
  404.         $topIds = [];
  405.         foreach ($market['mainCities'] as $mainCity) {
  406.             if (!is_null($mainCity['id'])) $topIds[] = $mainCity['id'];
  407.         }
  408.         $sql = 'select d.fDeptCity as id, c.fName as name, c.fNameRd as nameRd 
  409.             from otp_tours.tOpDeptHotel d 
  410.             left join otpusk.tCities c ON d.fDeptCity=c.rec_id 
  411.             where c.fCountryID in ('.implode(',', $market['mainCountries']).')
  412.             group by d.fDeptCity';
  414.         $stmt = $conn->prepare($sql);
  415.         $data = $stmt->execute()->fetchAll();
  417.         $results = [];
  418.         foreach ($data as $one) {
  419.             $results[$one['id']] = array(
  420.                 'name' => !empty($one['name']) ? $one['name'] : 'любой город',
  421.                 'nameRd' => !empty($one['nameRd']) ? $one['nameRd'] : 'любого города',
  422.                 'priority' => (in_array($one['id'], $topIds) ? true : false)
  423.             );
  424.         }
  426.         return $results;
  427.     }
  429.     public function getCityByIp($ip = null)
  430.     {
  431.         if (empty($ip)){
  432.             $ip = $_SERVER['REMOTE_ADDR'];
  433.         }
  435.         $project_dir = dirname($_SERVER['DOCUMENT_ROOT']);
  436.         if (!is_dir($project_dir)) $project_dir = '/app';
  437.         $reader = new Reader($project_dir.'/public/upload/GeoLite2/GeoLite2-City/GeoLite2-City.mmdb');
  439.         $record = $reader->city($ip);
  441.         $subdivisions = [];
  442.         foreach ($record->subdivisions AS $subdivision) $subdivisions[] = [$subdivision->names['ru'],$subdivision->names['en'],$subdivision->isoCode];
  443.         $this->res = [
  444.             $record->location->latitude, $record->location->longitude,
  445.             [$record->continent->names['ru'],$record->continent->names['en'], $record->continent->code],
  446.             [$record->country->names['ru'], $record->country->names['en'], $record->country->isoCode],
  447.             $subdivisions,
  448.             [$record->city->names['ru'], $record->city->names['en']]
  449.         ];
  451.         return $this->getIdByCityName(
  452.             $record->city->names['ru'],
  453.             $record->city->names['en'],
  454.             $record->location->latitude,
  455.             $record->location->longitude
  456.         );
  457.     }
  459.     public function getIdByCityName($name, $nameEng, $lat, $long)
  460.     {
  461.         $sql = $this->createQueryBuilder('c')
  462.             ->select('c.id AS cityId')
  463.             ->where('c.fNameEng = :name')
  464.             ->orWhere('c.fName = :nameEng')
  465.             ->orWhere('c.fSouthWest >= :latStart AND c.fSouthWest <= :latEnd AND c.fNorthEast >= :longStart AND c.fNorthEast <= :longEnd')
  466.             ->setParameter('name', $name)
  467.             ->setParameter('nameEng', $nameEng)
  468.             ->setParameter('latStart', $lat-0.1)
  469.             ->setParameter('latEnd', $lat+0.1)
  470.             ->setParameter('longStart', $long-0.1)
  471.             ->setParameter('longEnd', $long+0.1)
  472.         ;
  473.         $result = $sql->getQuery()->getResult();
  475.         return isset($result[0]['cityId'])?$result[0]['cityId']:null;
  476.     }
  478.     public function getRes(){
  479.         return $this->res;
  480.     }
  481. }