src/Contact/Repository/DoctrineContactAccessRepository.php line 43

  1. <?php
  3. declare(strict_types=1);
  4. /**
  5.  * Copyright (c) 2019 TECLA Consulting Group oü.
  6.  * All rights reserved.
  7.  *
  8.  * This unpublished material is proprietary to TECLA Consulting Group oü.
  9.  * All rights reserved. The methods and
  10.  * techniques described herein are considered trade secrets
  11.  * and/or confidential. Reproduction or distribution, in whole
  12.  * or in part, is forbidden except by express written permission
  13.  * of TECLA Consulting Group oü.
  14.  *
  15.  * @author    Matúš Sýkorjak <matus@tecla.no>
  16.  * @copyright 2019 TECLA Consulting Group oü
  17.  */
  19. namespace App\Contact\Repository;
  21. use App\Contact\Doctrine\DBAL\Types\ContactAccessRoleType;
  22. use App\Contact\Doctrine\DBAL\Types\ContactIdType;
  23. use App\Contact\Enum\ContactAccessRole;
  24. use App\Contact\Model\ContactAccess;
  25. use App\Contact\Model\ContactAccessInterface;
  26. use App\Contact\Model\ContactInterface;
  27. use App\Contact\Model\Identity\ContactIdInterface;
  28. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  29. use Doctrine\ORM\Query\Expr\Join;
  30. use Doctrine\ORM\QueryBuilder;
  31. use Doctrine\Persistence\ManagerRegistry;
  33. class DoctrineContactAccessRepository extends ServiceEntityRepository
  34. {
  35.     public function __construct(ManagerRegistry $registry)
  36.     {
  37.         parent::__construct($registry, ContactAccess::class);
  38.     }
  40.     /**
  41.      * @return ContactAccessInterface[]
  42.      */
  43.     public function findAllAccessors(ContactIdInterface $contactId, array $criteria = null, array $orderBy = null, int $limit = null, int $offset = null): ?array
  44.     {
  45.         return $this
  46.             ->createAllQueryBuilder($contactId, false, $criteria, $orderBy, $limit, $offset)
  47.             ->getQuery()
  48.             ->getResult()
  49.         ;
  50.     }
  52.     public function countAllAccessors(ContactIdInterface $contactId, array $criteria = null): int
  53.     {
  54.         return (int) ($this
  55.             ->createAllQueryBuilder($contactId, true, $criteria)
  56.             ->getQuery()
  57.             ->getSingleScalarResult())
  58.         ;
  59.     }
  61.     private function createAllQueryBuilder(ContactIdInterface $contactId, bool $isCount, array $criteria = null, array $orderBy = null, int $limit = null, int $offset = null): QueryBuilder
  62.     {
  63.         $addContactQuery = false;
  64.         $addContactFullNameQuery = false;
  65.         $addContactEmailQuery = false;
  67.         $qb = $this->createQueryBuilder('ca');
  69.         if (true === $isCount) {
  70.             $qb->select($qb->expr()->count('ca.id'));
  71.         } else {
  72.             if (null !== $limit) {
  73.                 $qb->setMaxResults($limit);
  74.             }
  76.             if (null !== $offset) {
  77.                 $qb->setFirstResult($offset);
  78.             }
  80.             $addContactQuery = true;
  81.             $addContactEmailQuery = true;
  82.         }
  84.         $qb
  85.             ->where($qb->expr()->eq('ca.contact', ':contact'))
  86.             ->setParameter('contact', $contactId, ContactIdType::NAME)
  87.         ;
  89.         if (false === empty($criteria)) {
  90.             foreach ($criteria as $criterion => $values) {
  91.                 if (true === empty($values)) {
  92.                     continue;
  93.                 }
  95.                 if ('search' === $criterion) {
  96.                     if (true === $isCount) {
  97.                         $qb
  98.                             ->andWhere(
  99.                                 $qb->expr()->orX(
  100.                                     $qb->expr()->like('c.name', ':search'),
  101.                                     $qb->expr()->like("CONCAT(c.lastName, ' ', c.firstName)", ':search'),
  102.                                     $qb->expr()->like('ce.email', ':search')
  103.                                 )
  104.                             )
  105.                         ;
  106.                     } else {
  107.                         $qb
  108.                             ->having(
  109.                                 $qb->expr()->orX(
  110.                                     $qb->expr()->like('fullName', ':search'),
  111.                                     $qb->expr()->like('ce.email', ':search')
  112.                                 )
  113.                             )
  114.                         ;
  115.                     }
  117.                     $qb->setParameter('search', '%' . $values . '%');
  118.                     $addContactFullNameQuery = true;
  119.                     $addContactEmailQuery = true;
  120.                 }
  122.                 if ('role' === $criterion) {
  123.                     if (true === \is_array($values)) {
  124.                         $qb->andWhere($qb->expr()->in('ca.role', ':role'));
  125.                         foreach ($values as $k => $v) {
  126.                             $values[$k] = ContactAccessRoleType::transformToDatabaseValue(ContactAccessRole::tryFrom($v));
  127.                         }
  128.                     } else {
  129.                         $values = ContactAccessRoleType::transformToDatabaseValue(ContactAccessRole::tryFrom($values));
  130.                         $qb->andWhere($qb->expr()->eq('ca.role', ':role'));
  131.                     }
  133.                     $qb->setParameter('role', $values);
  134.                 }
  135.             }
  136.         }
  138.         if (false === $isCount) {
  139.             if (false === empty($orderBy)) {
  140.                 foreach ($orderBy as $column => $direction) {
  141.                     if ('fullName' === $column) {
  142.                         $qb->addOrderBy('fullName', $direction);
  143.                         $addContactFullNameQuery = true;
  144.                     }
  146.                     if ('email' === $column) {
  147.                         $qb->addOrderBy('ce.email', $direction);
  148.                         $addContactEmailQuery = true;
  149.                     }
  151.                     if ('role' === $column) {
  152.                         $qb->addOrderBy('ca.role', $direction);
  153.                     }
  154.                 }
  155.             }
  156.         }
  158.         if (true === $addContactQuery || true === $addContactFullNameQuery || true === $addContactEmailQuery) {
  159.             if (false === $isCount) {
  160.                 $qb->addSelect('c');
  161.             }
  163.             $qb
  164.                 ->innerJoin('ca.accessor', 'c', Join::WITH, $qb->expr()->eq('c.id', 'ca.accessor'))
  165.             ;
  167.             if (true === $addContactFullNameQuery && false === $isCount) {
  168.                 $qb
  169.                     ->addSelect(
  170.                         "CASE WHEN c.type = 1 THEN c.name WHEN c.type = 2 THEN CONCAT(c.lastName, ' ', c.firstName) ELSE '' END AS HIDDEN fullName"
  171.                     )
  172.                 ;
  173.             }
  175.             if (true === $addContactEmailQuery) {
  176.                 if (false === $isCount) {
  177.                     $qb->addSelect('ce');
  178.                 }
  180.                 $qb
  181.                     ->innerJoin('c.contactEmail', 'ce', Join::WITH, $qb->expr()->eq('ce.id', 'c.contactEmail'))
  182.                 ;
  183.             }
  184.         }
  186.         return $qb;
  187.     }
  188. }