src/WebBundle/Repository/ReviewsCacheRepository.php line 94

Open in your IDE?
  1. <?php
  3. namespace WebBundle\Repository;
  5. use DateTime;
  6. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  7. use Doctrine\ORM\NonUniqueResultException;
  8. use Doctrine\ORM\NoResultException;
  9. use Doctrine\Persistence\ManagerRegistry;
  10. use FlexApp\Constant\TimeConstant;
  11. use WebBundle\Entity\ReviewsCache;
  12. use WebBundle\Helper\App;
  13. use WebBundle\Traits\RepoTrait;
  15. class ReviewsCacheRepository extends ServiceEntityRepository
  16. {
  17.     use RepoTrait;
  19.     public function __construct(ManagerRegistry $registry)
  20.     {
  21.         parent::__construct($registry, ReviewsCache::class);
  22.     }
  24.     public function getReview(int $id): ?ReviewsCache
  25.     {
  26.         $q = $this->createQueryBuilder('r')
  27.             ->select('r')
  28.             ->andWhere('r.id = :id')
  29.             ->setParameter('id', $id)
  30.             ->setMaxResults(1)
  31.             ->getQuery();
  33.         try {
  34.             return $q->getSingleResult();
  35.         } catch (NoResultException|NonUniqueResultException $e) {
  36.             return null;
  37.         }
  38.     }
  40.     /**
  41.      * @param DateTime $start
  42.      * @param DateTime|null $end
  43.      * @return array|null
  44.      */
  45.     public function getReviewsPeriod($start, $end = null): array
  46.     {
  47.         $q = $this->createQueryBuilder('r')
  48.             ->select('r')
  49.             ->andWhere('r.date >= :start')
  50.             ->setParameter('start', $start->getTimestamp());
  52.         if ($end) {
  53.             $q->andWhere('r.date <= :end')
  54.                 ->setParameter('end', $end->getTimestamp());
  55.         }
  57.         $r = $q->getQuery()->enableResultCache(TimeConstant::HOUR);
  59.         return $r->getArrayResult();
  60.     }
  62.     public function getReviews($param = []): array
  63.     {
  64.         $q = $this->createQueryBuilder('r')
  65.             ->select('r')
  66.             ->andWhere("r.star IN(4,5)")
  67.             ->andWhere('r.id NOT IN(535,1271)');
  69.         if (App::getCurLocale() != 'ru') {
  70.             $q->andWhere('r.country != \'RU\'');
  71.         }
  73.         if (!empty($param['order'])) {
  74.             $q->orderBy($param['order']);
  75.         } else {
  76.             $q->orderBy('r.date', 'DESC');
  77.         }
  79.         if (!empty($param['limit'])) {
  80.             $q->setMaxResults($param['limit']);
  81.         }
  83.         if (!empty($param['start_with'])) {
  84.             $q->setFirstResult($param['start_with']);
  85.         }
  87.         if (!empty($param['lang'])) {
  88.             $q->andWhere('r.language = :lang')
  89.                 ->setParameter('lang', $param['lang']);
  90.         }
  92.         $r = $q->getQuery()->enableResultCache(TimeConstant::HOUR);
  94.         return $r->getArrayResult();
  95.     }
  97.     /**
  98.      * @return int|null
  99.      */
  100.     public function getReviewsCount(): ?int
  101.     {
  102.         $q = $this->createQueryBuilder('r')
  103.             ->select('count(r.id)')
  104.             ->andWhere("r.star IN(4,5)")
  105.             ->andWhere('r.id NOT IN(535,1271)');
  107.         if (App::getCurLocale() != 'ru') {
  108.             $q->andWhere('r.country != \'RU\'');
  109.         }
  111.         $r = $q->getQuery()->enableResultCache(TimeConstant::HOUR);
  113.         try {
  114.             return $r->getSingleScalarResult();
  115.         } catch (NonUniqueResultException $e) {
  116.             return null;
  117.         }
  118.     }
  119. }