src/Repository/City/CityRepository.php line 112

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Slivki\Repository\City;
  7. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  8. use Doctrine\ORM\NonUniqueResultException;
  9. use Doctrine\Persistence\ManagerRegistry;
  10. use Slivki\Entity\City;
  11. use Slivki\Exception\CityNotFoundException;
  13. final class CityRepository extends ServiceEntityRepository implements CityRepositoryInterface
  14. {
  15.     public function __construct(ManagerRegistry $registry)
  16.     {
  17.         parent::__construct($registry, City::class);
  18.     }
  20.     /**
  21.      * @return City[]
  22.      */
  23.     public function getActiveCities(): array
  24.     {
  25.         $qb = $this->createQueryBuilder('city');
  26.         $expr = $qb->expr();
  28.         return $qb
  29.             ->andWhere($expr->eq('city.active', ':active'))
  30.             ->setParameter('active', true)
  31.             ->addOrderBy($expr->asc('city.position'))
  32.             ->addOrderBy($expr->asc('city.name'))
  33.             ->getQuery()
  34.             ->getResult();
  35.     }
  37.     public function findById(int $id): ?City
  38.     {
  39.         $qb = $this->createQueryBuilder('c');
  40.         $expr = $qb->expr();
  42.         return $qb
  43.             ->andWhere($expr->eq('c.ID', ':id'))
  44.             ->setParameters([
  45.                 'id' => $id,
  46.             ])
  47.             ->getQuery()
  48.             ->getOneOrNullResult();
  49.     }
  51.     public function getById(int $id): City
  52.     {
  53.         $city = $this->findById($id);
  55.         if (!$city instanceof City) {
  56.             throw new CityNotFoundException();
  57.         }
  59.         return $city;
  60.     }
  62.     public function getByName(string $name): City
  63.     {
  64.         $qb = $this->createQueryBuilder('city');
  65.         $expr = $qb->expr();
  67.         $city = $qb
  68.             ->andWhere($expr->eq('city.name', ':name'))
  69.             ->setParameter('name', $name)
  70.             ->getQuery()
  71.             ->getOneOrNullResult();
  73.         if (!$city instanceof City) {
  74.             throw new CityNotFoundException();
  75.         }
  77.         return $city;
  78.     }
  80.     public function findActiveNearestCity(string $latitude, string $longitude): ?City
  81.     {
  82.         $qb = $this->createQueryBuilder('city');
  83.         $expr = $qb->expr();
  85.         return $qb
  86.             ->andWhere($expr->eq('city.active', ':active'))
  87.             ->addOrderBy($expr->min(
  88.                 \sprintf('ST_Distance(city.point, GeomFromEWKT(\'SRID=4326;POINT(%s)\'))', \implode(' ', [$latitude, $longitude])))
  89.             )
  90.             ->addGroupBy('city.ID')
  91.             ->setParameters([
  92.                 'active' => true,
  93.             ])
  94.             ->setMaxResults(1)
  95.             ->getQuery()
  96.             ->getOneOrNullResult();
  97.     }
  99.     public function findAllSortByName(): array
  100.     {
  101.         $qb = $this->createQueryBuilder('c');
  102.         $expr = $qb->expr();
  103.         
  104.         return $qb
  105.             ->andWhere($expr->eq('c.active', ':active'))
  106.             ->setParameter('active', true)
  107.             ->addOrderBy($expr->asc('c.name'))
  108.             ->getQuery()
  109.             ->getResult();
  110.     }
  112.     public function findActiveByDomain(string $domain): ?City
  113.     {
  114.         $queryBuilder = $this->createQueryBuilder('city');
  115.         $expr = $queryBuilder->expr();
  117.         return $queryBuilder
  118.             ->andWhere($expr->eq('city.active', ':active'))
  119.             ->andWhere($expr->eq('city.domain', ':domain'))
  120.             ->setParameters(
  121.                 [
  122.                     'active' => true,
  123.                     'domain' => $domain,
  124.                 ]
  125.             )
  126.             ->setMaxResults(1)
  127.             ->getQuery()
  128.             ->getOneOrNullResult();
  129.     }
  130. }