src/Repository/AffiliateRequestRepository.php line 26

Open in your IDE?
  1. <?php
  3. namespace App\Repository;
  5. use App\Entity\AffiliateRequest;
  6. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  7. use Doctrine\Common\Collections\ArrayCollection;
  8. use Doctrine\Common\Collections\Criteria;
  9. use Doctrine\DBAL\Types\Types;
  10. use Doctrine\ORM\Query;
  11. use Doctrine\ORM\Query\Parameter;
  12. use Doctrine\Persistence\ManagerRegistry;
  13. use Pagerfanta\Doctrine\ORM\QueryAdapter;
  14. use Pagerfanta\Pagerfanta;
  16. /**
  17.  * @extends ServiceEntityRepository<AffiliateRequest>
  18.  *
  19.  * @method AffiliateRequest|null find($id, $lockMode = null, $lockVersion = null)
  20.  * @method AffiliateRequest|null findOneBy(array $criteria, array $orderBy = null)
  21.  * @method AffiliateRequest[]    findAll()
  22.  * @method AffiliateRequest[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
  23.  */
  24. class AffiliateRequestRepository extends ServiceEntityRepository
  25. {
  26.     public function __construct(ManagerRegistry $registry)
  27.     {
  28.         parent::__construct($registry, AffiliateRequest::class);
  29.     }
  31.     public function add(AffiliateRequest $entity, bool $flush = false): void
  32.     {
  33.         $this->getEntityManager()->persist($entity);
  35.         if ($flush) {
  36.             $this->getEntityManager()->flush();
  37.         }
  38.     }
  40.     public function remove(AffiliateRequest $entity, bool $flush = false): void
  41.     {
  42.         $this->getEntityManager()->remove($entity);
  44.         if ($flush) {
  45.             $this->getEntityManager()->flush();
  46.         }
  47.     }
  49.     public function getResults(string $query = null, int $page = 1, int $limit = 20): Pagerfanta
  50.     {
  51.         $qb = $this->createQueryBuilder('ar');
  53.         if ($query) {
  54.             $qb->andWhere($qb->expr()->orX(
  55.                 $qb->expr()->like('ar.firstname', ':query'),
  56.                 $qb->expr()->like('ar.lastname', ':query'),
  57.                 $qb->expr()->like('ar.email', ':query'),
  58.                 $qb->expr()->like('ar.phone', ':query'),
  59.                 $qb->expr()->like('ar.city', ':query'),
  60.             ))->setParameters(new ArrayCollection([
  61.                 new Parameter('query', '%'.$query.'%'),
  62.             ]));
  63.         }
  65.         $qb->orderBy('ar.createdAt', Criteria::DESC);
  67.         $paginator = new Pagerfanta(new QueryAdapter($qb));
  68.         $paginator
  69.             ->setMaxPerPage($limit)
  70.             ->setCurrentPage($page);
  72.         return $paginator;
  73.     }
  75.     public function getExportQuery(\DateTime $dateBegin, \DateTime $dateEnd): Query
  76.     {
  77.         $qb = $this->createQueryBuilder('ar');
  79.         $qb->andWhere($qb->expr()->andX(
  80.             $qb->expr()->gte('ar.createdAt', ':date_begin'),
  81.             $qb->expr()->lte('ar.createdAt', ':date_end'),
  82.         ))->setParameters(new ArrayCollection([
  83.             new Parameter('date_begin', $dateBegin, Types::DATETIME_MUTABLE),
  84.             new Parameter('date_end', $dateEnd, Types::DATETIME_MUTABLE),
  85.         ]));
  87.         $qb->orderBy('ar.createdAt', Criteria::ASC);
  89.         return $qb->getQuery();
  90.     }
  91. }