src/Repository/NotificationReceiptRepository.php line 22

Open in your IDE?
  1. <?php
  3. namespace App\Repository;
  5. use App\Entity\NotificationReceipt;
  6. use App\Entity\User;
  7. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  8. use Doctrine\ORM\NonUniqueResultException;
  9. use Doctrine\ORM\NoResultException;
  10. use Doctrine\Persistence\ManagerRegistry;
  12. /**
  13.  * @extends ServiceEntityRepository<NotificationReceipt>
  14.  *
  15.  * @method NotificationReceipt|null find($id, $lockMode = null, $lockVersion = null)
  16.  * @method NotificationReceipt|null findOneBy(array $criteria, array $orderBy = null)
  17.  * @method NotificationReceipt[]    findAll()
  18.  * @method NotificationReceipt[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
  19.  */
  20. class NotificationReceiptRepository extends ServiceEntityRepository
  21. {
  22.     public function __construct(ManagerRegistry $registry)
  23.     {
  24.         parent::__construct($registry, NotificationReceipt::class);
  25.     }
  27.     public function add(NotificationReceipt $entity, bool $flush = false): void
  28.     {
  29.         $this->getEntityManager()->persist($entity);
  31.         if ($flush) {
  32.             $this->getEntityManager()->flush();
  33.         }
  34.     }
  36.     public function remove(NotificationReceipt $entity, bool $flush = false): void
  37.     {
  38.         $this->getEntityManager()->remove($entity);
  40.         if ($flush) {
  41.             $this->getEntityManager()->flush();
  42.         }
  43.     }
  45.     public function getUnreadNotificationsCount(User $user): int
  46.     {
  47.         $alias = 'notification_receipt';
  48.         $queryBuilder = $this->createQueryBuilder($alias);
  49.         $queryBuilder
  50.             ->select('count('.$alias.'.id)')
  51.             ->andWhere($alias.'.user = :user')
  52.             ->andWhere($queryBuilder->expr()->isNull($alias.'.readAt'))
  53.             ->setParameter('user', $user)
  54.         ;
  56.         try {
  57.             return $queryBuilder->getQuery()->getSingleScalarResult();
  58.         } catch (NoResultException|NonUniqueResultException $e) {
  59.             return 0;
  60.         }
  61.     }
  62. }