src/Repository/Offer/OfferRepository.php line 15

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Slivki\Repository\Offer;
  7. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  8. use Doctrine\Persistence\ManagerRegistry;
  9. use Slivki\Entity\Category;
  10. use Slivki\Entity\Offer;
  11. use Slivki\Exception\OfferNotFoundException;
  13. final class OfferRepository extends ServiceEntityRepository implements OfferRepositoryInterface
  14. {
  15.     public function __construct(ManagerRegistry $registry)
  16.     {
  17.         parent::__construct($registry, Offer::class);
  18.     }
  20.     public function findById(int $id): ?Offer
  21.     {
  22.         $queryBuilder = $this->createQueryBuilder('offer');
  23.         $expr = $queryBuilder->expr();
  25.         return $queryBuilder
  26.             ->andWhere($expr->eq('offer.ID', ':id'))
  27.             ->setParameter('id', $id)
  28.             ->getQuery()
  29.             ->getOneOrNullResult();
  30.     }
  32.     public function getById(int $id): Offer
  33.     {
  34.         $offer = $this->findById($id);
  36.         if (!$offer instanceof Offer) {
  37.             throw OfferNotFoundException::missingId($id);
  38.         }
  40.         return $offer;
  41.     }
  43.     public function getByIdAndDirector(int $id, int $directorId): Offer
  44.     {
  45.         $qb = $this->createQueryBuilder('offer');
  46.         $expr = $qb->expr();
  48.         $offer = $qb
  49.             ->innerJoin('offer.directors', 'director')
  50.             ->andWhere($expr->eq('offer.ID', ':id'))
  51.             ->andWhere($expr->eq('director.ID', ':directorId'))
  52.             ->setParameters([
  53.                 'id' => $id,
  54.                 'directorId' => $directorId,
  55.             ])
  56.             ->getQuery()
  57.             ->getOneOrNullResult();
  59.         if (!$offer instanceof Offer) {
  60.             throw OfferNotFoundException::missingId($id);
  61.         }
  63.         return $offer;
  64.     }
  66.     public function findActiveOffersByIds(array $offerIds): array
  67.     {
  68.         $queryBuilder = $this->createQueryBuilder('offer');
  69.         $expr = $queryBuilder->expr();
  71.         return $queryBuilder
  72.             ->andWhere($expr->in('offer.ID', ':offerIds'))
  73.             ->andWhere($expr->eq('offer.active', ':active'))
  74.             ->andWhere($expr->eq('offer.hidden', ':hidden'))
  75.             ->andWhere($expr->between('current_timestamp()', 'offer.activeSince', 'offer.activeTill'))
  76.             ->setParameters([
  77.                 'offerIds' => $offerIds,
  78.                 'active' => true,
  79.                 'hidden' => false,
  80.             ])
  81.             ->getQuery()
  82.             ->getResult();
  83.     }
  85.     public function clear(): void
  86.     {
  87.         $this->_em->clear(Offer::class);
  88.     }
  90.     public function findAllActiveByDirector(int $directorId): array
  91.     {
  92.         $qb = $this->createQueryBuilder('offer');
  93.         $expr = $qb->expr();
  95.         return $qb
  96.             ->innerJoin('offer.directors', 'director')
  97.             ->andWhere($expr->eq('director.ID', ':directorId'))
  98.             ->andWhere($expr->eq('offer.active', ':active'))
  99.             ->andWhere($expr->eq('offer.hidden', ':hidden'))
  100.             ->andWhere($expr->between('current_timestamp()', 'offer.activeSince', 'offer.activeTill'))
  101.             ->setParameters([
  102.                 'active' => true,
  103.                 'hidden' => false,
  104.                 'directorId' => $directorId,
  105.             ])
  106.             ->getQuery()
  107.             ->getResult();
  108.     }
  109. }