src/Repository/OrganizationRepository.php line 22

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Harmonizely\Repository;
  7. use Doctrine\Common\Persistence\ManagerRegistry;
  8. use Doctrine\DBAL\LockMode;
  9. use Doctrine\ORM\OptimisticLockException;
  10. use Doctrine\ORM\ORMException;
  11. use Harmonizely\Core\ORM\Tools\Contract\IPaginator;
  12. use Harmonizely\Core\ORM\Tools\Paginator;
  13. use Harmonizely\DTO\SuperAdmin\Organization\Request\GetOrganizationListRequestDTO;
  14. use Harmonizely\Model\DomainAwareInterface;
  15. use Harmonizely\Model\Organization;
  16. use Harmonizely\Repository\Contract\IOrganizationRepository;
  18. class OrganizationRepository extends EntityRepository implements DomainAwareEntityRepositoryInterface, IOrganizationRepository
  19. {
  20.     public function __construct(ManagerRegistry $registry)
  21.     {
  22.         parent::__construct($registry, Organization::class);
  23.     }
  25.     /**
  26.      * @param Organization $organization
  27.      * @return Organization
  28.      * @throws ORMException
  29.      * @throws OptimisticLockException
  30.      */
  31.     public function save(Organization $organization): Organization
  32.     {
  33.         $this->_em->persist($organization);
  34.         $this->_em->flush();
  36.         return $organization;
  37.     }
  40.     public function findOneByDomain(string $domain): ?DomainAwareInterface
  41.     {
  42.         /** @var DomainAwareInterface $object */
  43.         $object = $this->findOneBy(['domain' => $domain]);
  45.         return $object;
  46.     }
  48.     /**
  49.      * @param Organization $organization
  50.      * @return void
  51.      * @throws ORMException
  52.      * @throws OptimisticLockException
  53.      */
  54.     public function delete(Organization $organization): void
  55.     {
  56.         $this->_em->remove($organization);
  57.         $this->_em->flush();
  58.     }
  60.     /**
  61.      * @param Organization $organization
  62.      * @return Organization
  63.      */
  64.     public function findWithBlockTransaction(Organization $organization): Organization
  65.     {
  66.         return $this->find($organization->getId(), LockMode::PESSIMISTIC_WRITE);
  67.     }
  69.     /**
  70.      * @param GetOrganizationListRequestDTO $request
  71.      * @return IPaginator
  72.      */
  73.     public function getOrganizationList(GetOrganizationListRequestDTO $request): IPaginator
  74.     {
  75.         $qb = $this->createQueryBuilder('o');
  77.         switch ($request->getOrderField()) {
  78.             case 'id':
  79.             case 'slug':
  80.             case 'name':
  81.             case 'createdAt':
  82.             case 'domain':
  83.                 $qb->orderBy('o.' . $request->getOrderField(), $request->getOrderDirection());
  84.                 break;
  85.             default:
  86.                 $qb->orderBy('o.createdAt', $request->getOrderDirection());
  87.                 break;
  88.         }
  90.         if ($request->getFilter()) {
  91.             if ($request->getFilter()->getSearch()) {
  92.                 $qb->andWhere('o.name LIKE :search OR o.slug LIKE :search')
  93.                     ->setParameter('search', '%' . $request->getFilter()->getSearch() . '%');
  94.             }
  96.             if ($request->getFilter()->getId()) {
  97.                 $qb->andWhere('o.id = :id')
  98.                     ->setParameter('id', $request->getFilter()->getId());
  99.             }
  101.             if ($request->getFilter()->getCreatedAtFrom()) {
  102.                 $qb
  103.                     ->andWhere('DATE(o.createdAt) >= :createdAtFrom')
  104.                     ->setParameter('createdAtFrom', $request->getFilter()->getCreatedAtFrom());
  105.             }
  106.             if ($request->getFilter()->getCreatedAtTo()) {
  107.                 $qb
  108.                     ->andWhere('DATE(o.createdAt) <= :createdAtTo')
  109.                     ->setParameter('createdAtTo', $request->getFilter()->getCreatedAtTo());
  110.             }
  111.         }
  113.         if (!$request->isSkipPagination()) {
  114.             $qb->setMaxResults($request->getOnPage())
  115.                 ->setFirstResult($request->getOffset());
  116.         }
  118.         return new Paginator($qb->getQuery());
  119.     }
  120. }