src/Repository/CityRepository.php line 55

Open in your IDE?
  1. <?php
  2. /**
  3.  * Created by simpson <simpsonwork@gmail.com>
  4.  * Date: 2019-03-19
  5.  * Time: 23:05
  6.  */
  8. namespace App\Repository;
  10. use App\Entity\Location\City;
  11. use App\Repository\ReadModel\CityReadModel;
  12. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  13. use Doctrine\Persistence\ManagerRegistry;
  15. class CityRepository extends ServiceEntityRepository
  16. {
  17.     use EntityIteratorTrait;
  19.     public function __construct(ManagerRegistry $registry)
  20.     {
  21.         parent::__construct($registry, City::class);
  22.     }
  24.     public function findExisting(int $id): ?City
  25.     {
  26.         return $this->findExistingByIds([$id])[$id] ?? null;
  27.     }
  29.     public function findExistingByIds(array $ids): array
  30.     {
  31.         if (!$ids) {
  32.             return [];
  33.         }
  35.         return $this->createQueryBuilder('city', 'city.id')
  36.             ->andWhere('city.id IN (:ids)')
  37.             ->setParameter('ids', array_values(array_unique($ids)))
  38.             ->getQuery()
  39.             ->setCacheable(false)
  40.             ->getResult();
  41.     }
  43.     public function ofUriIdentity(string $uriIdentity): ?City
  44.     {
  45.         $qb = $this->createQueryBuilder('city')
  46.             ->andWhere('city.uriIdentity = :uri')
  47.             ->setParameter('uri', $uriIdentity)
  48.             ->setMaxResults(1)
  49.         ;
  50.         $query = $qb->getQuery()
  51.             ->useResultCache(true)
  52.             ->setResultCacheLifetime(3600)
  53.         ;
  55.         return  $query->getOneOrNullResult();
  56.     }
  58.     public function ofName(string $name, string $locale = 'ru'): ?City
  59.     {
  60.         $qb = $this->createQueryBuilder('city')
  61.             ->andWhere('JSON_EXTRACT(city.name, :json_path) = :name')
  62.             ->setParameter('json_path', '$.'.$locale)
  63.             ->setParameter('name', $name)
  64.             ->setMaxResults(1)
  65.         ;
  66.         $query = $qb->getQuery();
  68.         return $query->getOneOrNullResult();
  69.     }
  71.     public function cityCountries(): array
  72.     {
  73.         $qb = $this->createQueryBuilder('city')
  74.             ->distinct(true)
  75.             ->select('city.countryCode')
  76.         ;
  77.         $query = $qb->getQuery()
  78.             ->useResultCache(true)
  79.             ->setResultCacheLifetime(3600)
  80.         ;
  81.         $result = $query->getScalarResult();
  83.         return array_column($result, 'countryCode');
  84.     }
  86.     public function getAll(): array
  87.     {
  88.         $qb = $this->createQueryBuilder('city')
  89.             ->select('city.id, city.name, city.uriIdentity, city.countryCode')
  90.         ;
  92.         $result = array_map(function($profile): CityReadModel {
  93.             return $this->hydrateCityRow($profile);
  94.         }, $qb->getQuery()->getResult());
  96.         return $result;
  97.     }
  99.     public function findAll(?string $region = null): array
  100.     {
  101.         $criteria = [];
  102.         if (null !== $region) {
  103.             $criteria['region'] = $region;
  104.         }
  106.         return $this->findBy($criteria);
  107.     }
  109.     private function hydrateCityRow(array $row): CityReadModel
  110.     {
  111.         $view = new CityReadModel();
  112.         $view->id = $row['id'];
  113.         $view->name = $row['name'];
  114.         $view->uriIdentity = $row['uriIdentity'];
  115.         $view->countryCode = $row['countryCode'];
  117.         return $view;
  118.     }
  119. }