ProjetNormandie\MessageBundle\Repository\MessageRepository

Complexity

Total Complexity

17

Size/Duplication

Total Lines	155
Duplicated Lines	0 %

Importance

Changes	3
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getSenders()	0	12	1
A	__construct()	0	3	1
A	getNbNewMessage()	0	12	1
A	getRecipients()	0	12	1
A	purge()	0	20	1
B	getOutboxMessages()	0	41	6
B	getInboxMessages()	0	41	6

<?php

declare(strict_types=1);

namespace ProjetNormandie\MessageBundle\Repository;

use DateInterval;
use DateTime;
use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
use Doctrine\ORM\NonUniqueResultException;
use Doctrine\ORM\NoResultException;
use Doctrine\Persistence\ManagerRegistry;
use ProjetNormandie\MessageBundle\Entity\Message;

class MessageRepository  extends ServiceEntityRepository
{
    public function __construct(ManagerRegistry $registry)
    {
        parent::__construct($registry, Message::class);
    }

    public function purge(): void
    {
        //----- delete 1
        $query = $this->_em->createQuery(

The property _em does not exist on ProjetNormandie\MessageBundle\Repository\MessageRepository. Did you maybe forget to declare it?

            'DELETE projetNormandie\MessageBundle\Entity\Message m 
            WHERE m.isDeletedSender = :isDeletedSender
            AND m.isDeletedRecipient = :isDeletedRecipient'
        );
        $query->setParameter('isDeletedSender', true);
        $query->setParameter('isDeletedRecipient', true);
        $query->execute();

        //----- delete 2
        $date = new DateTime();
        $date = $date->sub(DateInterval::createFromDateString('2 years'));
        $query = $this->_em->createQuery(
            'DELETE projetNormandie\MessageBundle\Entity\Message m WHERE m.createdAt < :date'
        );
        $query->setParameter('date', $date->format('Y-m-d'));
        $query->execute();
    }

    public function getRecipients($user)
    {
        $query = $this->createQueryBuilder('m')
            ->join('m.recipient', 'u')
            ->select('DISTINCT u.id,u.username')
            ->where('m.sender = :user')
            ->setParameter('user', $user)
            ->andWhere('m.isDeletedSender = :isDeletedSender')
            ->setParameter('isDeletedSender', false)
            ->orderBy("u.username", 'ASC');

        return $query->getQuery()->getResult();
    }

    public function getSenders($user)
    {
        $query = $this->createQueryBuilder('m')
            ->join('m.sender', 'u')
            ->select('DISTINCT u.id,u.username')
            ->where('m.recipient = :user')
            ->setParameter('user', $user)
            ->andWhere('m.isDeletedRecipient = :isDeletedRecipient')
            ->setParameter('isDeletedRecipient', false)
            ->orderBy("u.username", 'ASC');

        return $query->getQuery()->getResult();
    }

    public function getNbNewMessage($user)
    {
        $qb = $this->createQueryBuilder('m')
            ->select('COUNT(m.id)')
            ->where('m.recipient = :recipient')
            ->andWhere('m.isOpened = :isOpened')
            ->andWhere('m.isDeletedRecipient = :isDeletedRecipient')
            ->setParameter('recipient', $user)
            ->setParameter('isOpened', false)
            ->setParameter('isDeletedRecipient', false);

        return (int) $qb->getQuery()->getSingleScalarResult();
    }

    public function getInboxMessages($user, array $filters = [])
    {
        $qb = $this->createQueryBuilder('m')
            ->leftJoin('m.sender', 's')
            ->leftJoin('m.recipient', 'r')
            ->where('m.recipient = :user')
            ->andWhere('m.isDeletedRecipient = :isDeletedRecipient')
            ->setParameter('user', $user)
            ->setParameter('isDeletedRecipient', false)
            ->orderBy('m.id', 'DESC');

        // Recherche globale
        if (isset($filters['search']) && !empty($filters['search'])) {
            $searchTerm = '%' . $filters['search'] . '%';
            $qb->andWhere(
                $qb->expr()->orX(
                    $qb->expr()->like('m.object', ':search'),
                    $qb->expr()->like('m.message', ':search'),
                    $qb->expr()->like('s.username', ':search'),
                    $qb->expr()->like('r.username', ':search')
                )
            )->setParameter('search', $searchTerm);
        }

        // Appliquer les autres filtres
        if (isset($filters['type'])) {
            $qb->andWhere('m.type = :type')
                ->setParameter('type', $filters['type']);
        }

        if (isset($filters['sender'])) {
            $qb->andWhere('m.sender = :sender')
                ->setParameter('sender', $filters['sender']);
        }

        if (isset($filters['isOpened'])) {
            $qb->andWhere('m.isOpened = :isOpened')
                ->setParameter('isOpened', $filters['isOpened']);
        }

        return $qb;
    }

    public function getOutboxMessages($user, array $filters = [])
    {
        $qb = $this->createQueryBuilder('m')
            ->leftJoin('m.sender', 's')
            ->leftJoin('m.recipient', 'r')
            ->where('m.sender = :user')
            ->andWhere('m.isDeletedSender = :isDeletedSender')
            ->setParameter('user', $user)
            ->setParameter('isDeletedSender', false)
            ->orderBy('m.id', 'DESC');

        // Recherche globale
        if (isset($filters['search']) && !empty($filters['search'])) {
            $searchTerm = '%' . $filters['search'] . '%';
            $qb->andWhere(
                $qb->expr()->orX(
                    $qb->expr()->like('m.object', ':search'),
                    $qb->expr()->like('m.message', ':search'),
                    $qb->expr()->like('s.username', ':search'),
                    $qb->expr()->like('r.username', ':search')
                )
            )->setParameter('search', $searchTerm);
        }

        // Appliquer les autres filtres
        if (isset($filters['type'])) {
            $qb->andWhere('m.type = :type')
                ->setParameter('type', $filters['type']);
        }

        if (isset($filters['recipient'])) {
            $qb->andWhere('m.recipient = :recipient')
                ->setParameter('recipient', $filters['recipient']);
        }

        if (isset($filters['isOpened'])) {
            $qb->andWhere('m.isOpened = :isOpened')
                ->setParameter('isOpened', $filters['isOpened']);
        }

        return $qb;
    }
}