src/Repository/CityRepository.php line 36

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 ofUriIdentity(string $uriIdentity): ?City
  25.     {
  26.         $qb = $this->createQueryBuilder('city')
  27.             ->andWhere('city.uriIdentity = :uri')
  28.             ->setParameter('uri', $uriIdentity)
  29.             ->setMaxResults(1)
  30.         ;
  31.         $query = $qb->getQuery()
  32.             ->useResultCache(true)
  33.             ->setResultCacheLifetime(3600)
  34.         ;
  36.         return  $query->getOneOrNullResult();
  37.     }
  39.     public function ofName(string $name, string $locale = 'ru'): ?City
  40.     {
  41.         $qb = $this->createQueryBuilder('city')
  42.             ->andWhere('JSON_EXTRACT(city.name, :json_path) = :name')
  43.             ->setParameter('json_path', '$.'.$locale)
  44.             ->setParameter('name', $name)
  45.             ->setMaxResults(1)
  46.         ;
  47.         $query = $qb->getQuery();
  49.         return $query->getOneOrNullResult();
  50.     }
  52.     public function cityCountries(): array
  53.     {
  54.         $qb = $this->createQueryBuilder('city')
  55.             ->distinct(true)
  56.             ->select('city.countryCode')
  57.         ;
  58.         $query = $qb->getQuery()
  59.             ->useResultCache(true)
  60.             ->setResultCacheLifetime(3600)
  61.         ;
  62.         $result = $query->getScalarResult();
  64.         return array_column($result, 'countryCode');
  65.     }
  67.     public function getAll(): array
  68.     {
  69.         $qb = $this->createQueryBuilder('city')
  70.             ->select('city.id, city.name, city.uriIdentity, city.countryCode')
  71.         ;
  73.         $result = array_map(function($profile): CityReadModel {
  74.             return $this->hydrateCityRow($profile);
  75.         }, $qb->getQuery()->getResult());
  77.         return $result;
  78.     }
  80.     private function hydrateCityRow(array $row): CityReadModel
  81.     {
  82.         $view = new CityReadModel();
  83.         $view->id = $row['id'];
  84.         $view->name = $row['name'];
  85.         $view->uriIdentity = $row['uriIdentity'];
  86.         $view->countryCode = $row['countryCode'];
  88.         return $view;
  89.     }
  90. }