src/Repository/Comment/CommentRepository.php line 19

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Slivki\Repository\Comment;
  7. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  8. use Doctrine\ORM\Query\Expr\Join;
  9. use Doctrine\Persistence\ManagerRegistry;
  10. use Slivki\Entity\City;
  11. use Slivki\Entity\Comment;
  12. use Slivki\Entity\Offer;
  13. use Slivki\Exception\Comment\CommentNotFountException;
  15. final class CommentRepository extends ServiceEntityRepository implements CommentRepositoryInterface
  16. {
  17.     public function __construct(ManagerRegistry $registry)
  18.     {
  19.         parent::__construct($registry, Comment::class);
  20.     }
  22.     public function getById(int $id): Comment
  23.     {
  24.         $comment = $this->findById($id);
  26.         if (!$comment instanceof Comment) {
  27.             throw new CommentNotFountException();
  28.         }
  30.         return $comment;
  31.     }
  33.     public function findById(int $id): ?Comment
  34.     {
  35.         $qb = $this->createQueryBuilder('c');
  36.         $expr = $qb->expr();
  38.         return $qb
  39.             ->andWhere($expr->eq('c.ID', ':id'))
  40.             ->setParameters([
  41.                 'id' => $id,
  42.             ])
  43.             ->getQuery()
  44.             ->getOneOrNullResult();
  45.     }
  47.     public function getLastOfferComments(int $limit): array
  48.     {
  49.         $qb = $this->createQueryBuilder('comment');
  50.         $expr = $qb->expr();
  52.         return $qb
  53.             ->innerJoin(Offer::class, 'offer', Join::WITH, $expr->eq('offer.ID', 'comment.entityID'))
  54.             ->andWhere($expr->eq('comment.hidden', ':hidden'))
  55.             ->andWhere($expr->eq('comment.confirmedPhone', ':confirmedPhone'))
  56.             ->andWhere($expr->neq('offer.defaultCity', ':tashkentCityId'))
  57.             ->setParameters([
  58.                 'hidden' => false,
  59.                 'confirmedPhone' => true,
  60.                 'tashkentCityId' => City::TASHKENT_CITY_ID,
  61.             ])
  62.             ->addOrderBy($expr->desc('comment.createdOn'))
  63.             ->setMaxResults($limit)
  64.             ->getQuery()
  65.             ->getResult();
  66.     }
  68.     public function getOfferCommentByIdAndOfferDirector(int $commentId, int $offerDirectorId): Comment
  69.     {
  70.         $qb = $this->createQueryBuilder('comment');
  71.         $expr = $qb->expr();
  73.         $comment = $qb
  74.             ->innerJoin(Offer::class, 'offer', Join::WITH, $expr->eq('offer.ID', 'comment.entityID'))
  75.             ->innerJoin('offer.directors', 'director')
  76.             ->andWhere($expr->eq('comment.ID', ':commentId'))
  77.             ->andWhere($expr->eq('director', ':directorId'))
  78.             ->setParameters([
  79.                 'commentId' => $commentId,
  80.                 'directorId' => $offerDirectorId,
  81.             ])
  82.             ->getQuery()
  83.             ->getOneOrNullResult();
  85.         if (!$comment instanceof Comment) {
  86.             throw new CommentNotFountException();
  87.         }
  89.         return $comment;
  90.     }
  92.     public function save(Comment $comment): void
  93.     {
  94.         $entityManager = $this->getEntityManager();
  95.         $entityManager->persist($comment);
  96.         $entityManager->flush($comment);
  97.     }
  98. }