src/Repository/Offer/OfferRepository.php line 17

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Slivki\Repository\Offer;
  7. use DateTimeImmutable;
  8. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  9. use Doctrine\Persistence\ManagerRegistry;
  10. use Slivki\Entity\Offer;
  11. use Slivki\Exception\OfferNotFoundException;
  13. use function sprintf;
  15. final class OfferRepository extends ServiceEntityRepository implements OfferRepositoryInterface
  16. {
  17.     public function __construct(ManagerRegistry $registry)
  18.     {
  19.         parent::__construct($registry, Offer::class);
  20.     }
  22.     public function findById(int $id): ?Offer
  23.     {
  24.         $queryBuilder = $this->createQueryBuilder('offer');
  25.         $expr = $queryBuilder->expr();
  27.         return $queryBuilder
  28.             ->andWhere($expr->eq('offer.ID', ':id'))
  29.             ->setParameter('id', $id)
  30.             ->getQuery()
  31.             ->getOneOrNullResult();
  32.     }
  34.     public function getById(int $id): Offer
  35.     {
  36.         $offer = $this->findById($id);
  38.         if (!$offer instanceof Offer) {
  39.             throw OfferNotFoundException::missingId($id);
  40.         }
  42.         return $offer;
  43.     }
  45.     public function getByIdAndDirector(int $id, int $directorId): Offer
  46.     {
  47.         $qb = $this->createQueryBuilder('offer');
  48.         $expr = $qb->expr();
  50.         $offer = $qb
  51.             ->innerJoin('offer.directors', 'director')
  52.             ->andWhere($expr->eq('offer.ID', ':id'))
  53.             ->andWhere($expr->eq('director.ID', ':directorId'))
  54.             ->setParameters([
  55.                 'id' => $id,
  56.                 'directorId' => $directorId,
  57.             ])
  58.             ->getQuery()
  59.             ->getOneOrNullResult();
  61.         if (!$offer instanceof Offer) {
  62.             throw OfferNotFoundException::missingId($id);
  63.         }
  65.         return $offer;
  66.     }
  68.     public function findActiveOffersByIds(array $offerIds): array
  69.     {
  70.         $queryBuilder = $this->createQueryBuilder('offer');
  71.         $expr = $queryBuilder->expr();
  73.         return $queryBuilder
  74.             ->andWhere($expr->in('offer.ID', ':offerIds'))
  75.             ->andWhere($expr->eq('offer.active', ':active'))
  76.             ->andWhere($expr->eq('offer.hidden', ':hidden'))
  77.             ->andWhere($expr->between('current_timestamp()', 'offer.activeSince', 'offer.activeTill'))
  78.             ->setParameters([
  79.                 'offerIds' => $offerIds,
  80.                 'active' => true,
  81.                 'hidden' => false,
  82.             ])
  83.             ->getQuery()
  84.             ->getResult();
  85.     }
  87.     public function clear(): void
  88.     {
  89.         $this->_em->clear(Offer::class);
  90.     }
  92.     public function findAllActiveByDirector(int $directorId): array
  93.     {
  94.         $qb = $this->createQueryBuilder('offer');
  95.         $expr = $qb->expr();
  97.         return $qb
  98.             ->innerJoin('offer.directors', 'director')
  99.             ->andWhere($expr->eq('director.ID', ':directorId'))
  100.             ->andWhere($expr->eq('offer.active', ':active'))
  101.             ->andWhere($expr->eq('offer.hidden', ':hidden'))
  102.             ->andWhere($expr->between('current_timestamp()', 'offer.activeSince', 'offer.activeTill'))
  103.             ->setParameters([
  104.                 'active' => true,
  105.                 'hidden' => false,
  106.                 'directorId' => $directorId,
  107.             ])
  108.             ->getQuery()
  109.             ->getResult();
  110.     }
  112.     public function findWithOnlineOrderAllowed(int $onlineOrderAllowedRemovedAtDaysBefore): array
  113.     {
  114.         $qb = $this->createQueryBuilder('offer');
  115.         $expr = $qb->expr();
  117.         return $qb
  118.             ->andWhere(
  119.                 $expr->orX(
  120.                     $expr->isNotNull('offer.allowedOnlineOrderTypes'),
  121.                     $expr->gt('offer.onlineOrderAllowedRemovedAt', ':onlineOrderAllowedRemovedAt'),
  122.                 )
  123.             )
  124.             ->setParameters([
  125.                 'onlineOrderAllowedRemovedAt' => (new DateTimeImmutable())
  126.                     ->modify(sprintf('-%d days', $onlineOrderAllowedRemovedAtDaysBefore))
  127.                     ->format('Y-m-d H:i:s'),
  128.             ])
  129.             ->getQuery()
  130.             ->getResult();
  131.     }
  132. }