src/Program/Doctrine/Repository/ProgramRepository.php line 25

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Program\Doctrine\Repository;
  7. use App\Point\Form\DataTransferObject\DashboardFilter;
  8. use App\Program\Doctrine\Entity\Program;
  9. use App\Program\Form\DataTransferObject\ProgramsFilter;
  10. use App\Program\Gateway\ProgramGateway;
  11. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  12. use Doctrine\ORM\Tools\Pagination\Paginator;
  13. use Doctrine\Persistence\ManagerRegistry;
  14. use Symfony\Component\Security\Core\Exception\UserNotFoundException;
  15. use Symfony\Component\Security\Core\User\UserInterface;
  17. /**
  18.  * @template T
  19.  *
  20.  * @extends ServiceEntityRepository<Program>
  21.  *
  22.  * @method findOneBy(array $criteria, ?array $orderBy = null) ?Program
  23.  * @method findAll()                                          array<int, Program>
  24.  */
  25. final class ProgramRepository extends ServiceEntityRepository implements ProgramGateway
  26. {
  27.     public function __construct(ManagerRegistry $registry)
  28.     {
  29.         parent::__construct($registry, Program::class);
  30.     }
  32.     /**
  33.      * @return array<array-key, Program>
  34.      */
  35.     public function getPointToCurrency(DashboardFilter $filter): array
  36.     {
  37.         $queryBuilder = $this->createQueryBuilder('p')
  38.             ->addSelect('c')
  39.             ->join('p.client', 'c');
  41.         if (null !== $filter->getClient()) {
  42.             $queryBuilder->andWhere('c = :client')->setParameter('client', $filter->getClient());
  43.         }
  45.         if (null !== $filter->getProgram()) {
  46.             $queryBuilder->andWhere('p = :program')->setParameter('program', $filter->getProgram());
  47.         }
  49.         if (null !== $filter->getProfile()) {
  50.             $queryBuilder
  51.                 ->andWhere('p = :profile')
  52.                 ->setParameter('profile', $filter->getProfile());
  53.         }
  55.         return $queryBuilder->getQuery()->getResult();
  56.     }
  58.     public function loadUserByUsername(string $username): ?Program
  59.     {
  60.         $user = $this->findOneBy(['apiKey' => $username]);
  62.         if (null === $user) {
  63.             throw new UserNotFoundException();
  64.         }
  66.         return $user;
  67.     }
  69.     public function loadUserByIdentifier(string $identifier): ?UserInterface
  70.     {
  71.         return $this->loadUserByUsername($identifier);
  72.     }
  74.     public function update(Program $program): void
  75.     {
  76.         $this->_em->flush();
  77.     }
  79.     public function create(Program $program): void
  80.     {
  81.         $this->_em->persist($program);
  82.         $this->_em->flush();
  83.     }
  85.     public function delete(Program $program): void
  86.     {
  87.         $this->_em->remove($program);
  88.         $this->_em->flush();
  89.     }
  91.     public function getPaginatedPrograms(
  92.         int $page,
  93.         int $length,
  94.         string $column,
  95.         string $direction,
  96.         ProgramsFilter $filter
  97.     ): Paginator {
  98.         $queryBuilder = $this->createQueryBuilder('p')
  99.             ->addSelect('c')
  100.             ->join('p.client', 'c')
  101.             ->orderBy($column, $direction)
  102.             ->setMaxResults($length)
  103.             ->setFirstResult($page * $length - $length);
  105.         if (null !== $filter->getClient()) {
  106.             $queryBuilder
  107.                 ->andWhere('c = :client')
  108.                 ->setParameter('client', $filter->getClient());
  109.         }
  111.         if (null !== $filter->getSearch()) {
  112.             $queryBuilder
  113.                 ->andWhere('p.name LIKE :search')
  114.                 ->setParameter('search', '%'.$filter->getSearch().'%');
  115.         }
  117.         if (1 === $filter->getStatus()) {
  118.             $queryBuilder
  119.                 ->andWhere('p.startedAt <= NOW()')
  120.                 ->andWhere(
  121.                     $queryBuilder->expr()->orX(
  122.                         $queryBuilder->expr()->lte('p.endedAt', 'NOW()'),
  123.                         $queryBuilder->expr()->isNull('p.endedAt')
  124.                     )
  125.                 );
  126.         }
  128.         if (2 === $filter->getStatus()) {
  129.             $queryBuilder->andWhere('p.startedAt > NOW()');
  130.         }
  132.         if (3 === $filter->getStatus()) {
  133.             $queryBuilder->andWhere('p.endedAt <= NOW()');
  134.         }
  136.         return new Paginator($queryBuilder, true);
  137.     }
  138. }