Merge remote-tracking branch 'origin/master' into homepage/rewrite

src/Bundle/ChillMainBundle/Repository/NotificationRepository.php

@@ -13,6 +13,7 @@ namespace Chill\MainBundle\Repository;
 
 use Chill\MainBundle\Entity\Notification;
 use Chill\MainBundle\Entity\User;
+use Doctrine\DBAL\Statement;
 use Doctrine\DBAL\Types\Types;
 use Doctrine\ORM\EntityManagerInterface;
 use Doctrine\ORM\EntityRepository;
@@ -24,6 +25,8 @@ final class NotificationRepository implements ObjectRepository
 {
     private EntityManagerInterface $em;
 
+    private ?Statement $notificationByRelatedEntityAndUserAssociatedStatement = null;
+
     private EntityRepository $repository;
 
     public function __construct(EntityManagerInterface $entityManager)
@@ -48,6 +51,30 @@ final class NotificationRepository implements ObjectRepository
             ->getSingleScalarResult();
     }
 
+    public function countNotificationByRelatedEntityAndUserAssociated(string $relatedEntityClass, int $relatedEntityId, User $user): array
+    {
+        if (null === $this->notificationByRelatedEntityAndUserAssociatedStatement) {
+            $sql =
+                'SELECT
+                   SUM((EXISTS (SELECT 1 AS c FROM chill_main_notification_addresses_unread cmnau WHERE user_id = 1812 and cmnau.notification_id = cmn.id))::int) AS unread,
+                   SUM((cmn.sender_id = 1812)::int) AS sent,
+                   COUNT(cmn.*) AS total
+                FROM chill_main_notification cmn
+                WHERE relatedentityclass = :relatedEntityClass AND relatedentityid = :relatedEntityId AND sender_id IS NOT NULL';
+            $this->notificationByRelatedEntityAndUserAssociatedStatement =
+                $this->em->getConnection()->prepare($sql);
+        }
+
+        $results = $this->notificationByRelatedEntityAndUserAssociatedStatement
+            ->executeQuery(['relatedEntityClass' => $relatedEntityClass, 'relatedEntityId' => $relatedEntityId]);
+
+        $result = $results->fetchAssociative();
+
+        $results->free();
+
+        return $result;
+    }
+
     public function countUnreadByUser(User $user): int
     {
         $sql = 'SELECT count(*) AS c FROM chill_main_notification_addresses_unread WHERE user_id = :userId';
@@ -153,11 +180,29 @@ final class NotificationRepository implements ObjectRepository
      * @return array|Notification[]
      */
     public function findNotificationByRelatedEntityAndUserAssociated(string $relatedEntityClass, int $relatedEntityId, User $user): array
+    {
+        return
+            $this->buildQueryNotificationByRelatedEntityAndUserAssociated($relatedEntityClass, $relatedEntityId, $user)
+                ->select('n')
+                ->getQuery()
+                ->getResult();
+    }
+
+    public function findOneBy(array $criteria, ?array $orderBy = null): ?Notification
+    {
+        return $this->repository->findOneBy($criteria, $orderBy);
+    }
+
+    public function getClassName()
+    {
+        return Notification::class;
+    }
+
+    private function buildQueryNotificationByRelatedEntityAndUserAssociated(string $relatedEntityClass, int $relatedEntityId, User $user): QueryBuilder
     {
         $qb = $this->repository->createQueryBuilder('n');
 
         $qb
-            ->select('n')
             ->where($qb->expr()->eq('n.relatedEntityClass', ':relatedEntityClass'))
             ->andWhere($qb->expr()->eq('n.relatedEntityId', ':relatedEntityId'))
             ->andWhere($qb->expr()->isNotNull('n.sender'))
@@ -174,11 +219,6 @@ final class NotificationRepository implements ObjectRepository
         return $qb->getQuery()->getResult();
     }
 
-    public function findOneBy(array $criteria, ?array $orderBy = null): ?Notification
-    {
-        return $this->repository->findOneBy($criteria, $orderBy);
-    }
-
     /**
      * @return array|Notification[]
      */
@@ -202,11 +242,6 @@ final class NotificationRepository implements ObjectRepository
         return $nq->getResult();
     }
 
-    public function getClassName()
-    {
-        return Notification::class;
-    }
-
     private function queryByAddressee(User $addressee, bool $countQuery = false): QueryBuilder
     {
         $qb = $this->repository->createQueryBuilder('n');

src/Bundle/ChillMainBundle/Repository/Workflow/EntityWorkflowRepository.php

@@ -0,0 +1,137 @@
+<?php
+
+/**
+ * Chill is a software for social workers
+ *
+ * For the full copyright and license information, please view
+ * the LICENSE file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Chill\MainBundle\Repository\Workflow;
+
+use Chill\MainBundle\Entity\User;
+use Chill\MainBundle\Entity\Workflow\EntityWorkflow;
+use Doctrine\ORM\EntityManagerInterface;
+use Doctrine\ORM\EntityRepository;
+use Doctrine\ORM\QueryBuilder;
+use Doctrine\Persistence\ObjectRepository;
+
+class EntityWorkflowRepository implements ObjectRepository
+{
+    private EntityRepository $repository;
+
+    public function __construct(EntityManagerInterface $entityManager)
+    {
+        $this->repository = $entityManager->getRepository(EntityWorkflow::class);
+    }
+
+    public function countByDest(User $user): int
+    {
+        $qb = $this->buildQueryByDest($user)->select('count(ew)');
+
+        return (int) $qb->getQuery()->getSingleScalarResult();
+    }
+
+    public function countBySubscriber(User $user): int
+    {
+        $qb = $this->buildQueryBySubscriber($user)->select('count(ew)');
+
+        return (int) $qb->getQuery()->getSingleScalarResult();
+    }
+
+    public function find($id): ?EntityWorkflow
+    {
+        return $this->repository->find($id);
+    }
+
+    /**
+     * @return array|EntityWorkflow[]
+     */
+    public function findAll(): array
+    {
+        return $this->repository->findAll();
+    }
+
+    /**
+     * @param null|mixed $limit
+     * @param null|mixed $offset
+     *
+     * @return array|EntityWorkflow[]
+     */
+    public function findBy(array $criteria, ?array $orderBy = null, $limit = null, $offset = null): array
+    {
+        return $this->repository->findBy($criteria, $orderBy, $limit, $offset);
+    }
+
+    public function findByDest(User $user, ?array $orderBy = null, $limit = null, $offset = null): array
+    {
+        $qb = $this->buildQueryByDest($user)->select('ew');
+
+        foreach ($orderBy as $key => $sort) {
+            $qb->addOrderBy('ew.' . $key, $sort);
+        }
+
+        $qb->setMaxResults($limit)->setFirstResult($offset);
+
+        return $qb->getQuery()->getResult();
+    }
+
+    public function findBySubscriber(User $user, ?array $orderBy = null, $limit = null, $offset = null): array
+    {
+        $qb = $this->buildQueryBySubscriber($user)->select('ew');
+
+        foreach ($orderBy as $key => $sort) {
+            $qb->addOrderBy('ew.' . $key, $sort);
+        }
+
+        $qb->setMaxResults($limit)->setFirstResult($offset);
+
+        return $qb->getQuery()->getResult();
+    }
+
+    public function findOneBy(array $criteria): ?EntityWorkflow
+    {
+        return $this->repository->findOneBy($criteria);
+    }
+
+    public function getClassName(): string
+    {
+        return EntityWorkflow::class;
+    }
+
+    private function buildQueryByDest(User $user): QueryBuilder
+    {
+        $qb = $this->repository->createQueryBuilder('ew');
+
+        $qb->join('ew.steps', 'step');
+
+        $qb->where(
+            $qb->expr()->andX(
+                $qb->expr()->isMemberOf(':user', 'step.destUser'),
+                $qb->expr()->isNull('step.transitionAfter')
+            )
+        );
+
+        $qb->setParameter('user', $user);
+
+        return $qb;
+    }
+
+    private function buildQueryBySubscriber(User $user): QueryBuilder
+    {
+        $qb = $this->repository->createQueryBuilder('ew');
+
+        $qb->where(
+            $qb->expr()->orX(
+                $qb->expr()->isMemberOf(':user', 'ew.subscriberToStep'),
+                $qb->expr()->isMemberOf(':user', 'ew.subscriberToFinal'),
+            )
+        );
+
+        $qb->setParameter('user', $user);
+
+        return $qb;
+    }
+}