src/WebBundle/Repository/ProductReviewsCacheRepository.php line 84

Open in your IDE?
  1. <?php
  3. namespace WebBundle\Repository;
  5. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  6. use Doctrine\ORM\NonUniqueResultException;
  7. use Doctrine\ORM\NoResultException;
  8. use Doctrine\ORM\UnexpectedResultException;
  9. use Doctrine\Persistence\ManagerRegistry;
  10. use FlexApp\Constant\TimeConstant;
  11. use WebBundle\Entity\ProductReviewsCache;
  12. use WebBundle\Traits\RepoTrait;
  14. /**
  15.  * @method ProductReviewsCache|null find($id, $lockMode = null, $lockVersion = null)
  16.  */
  17. class ProductReviewsCacheRepository extends ServiceEntityRepository
  18. {
  19.     use RepoTrait;
  21.     public function __construct(ManagerRegistry $registry)
  22.     {
  23.         parent::__construct($registry, ProductReviewsCache::class);
  24.     }
  26.     /**
  27.      * @param int $id
  28.      * @return null
  29.      * @throws NonUniqueResultException
  30.      */
  31.     public function getReview(int $id)
  32.     {
  33.         $q = $this->createQueryBuilder('r')
  34.             ->select('r')
  35.             ->where('r.id = :id')
  36.             ->setParameter('id', $id)
  37.             ->setMaxResults(1)
  38.             ->getQuery()
  39.             ->enableResultCache(TimeConstant::HOUR);
  41.         try {
  42.             return $q->getSingleResult();
  43.         } catch (NoResultException $e) {
  44.             return null;
  45.         }
  46.     }
  48.     /**
  49.      * @param null $param
  50.      * @return array|null
  51.      */
  52.     public function getReviews($param = null): ?array
  53.     {
  54.         $q = $this->createQueryBuilder('r')
  55.             ->select('r');
  57.         if (!empty($param['referenceId'])) {
  58.             $q->andWhere('r.referenceId = \'' . $param['referenceId'] . '\'');
  59.         }
  61.         if (!empty($param['conversationId'])) {
  62.             if (!is_array($param['conversationId'])) {
  63.                 $param['conversationId'] = [$param['conversationId']];
  64.             }
  66.             $q->andWhere('r.conversationId IN (:conversationId)')
  67.                 ->setParameter('conversationId', $param['conversationId']);
  68.         }
  70.         if (!empty($param['productId'])) {
  71.             $q->andWhere('r.p_id = \'' . $param['productId'] . '\'');
  72.         }
  74.         if (!empty($param['sku'])) {
  75.             if (!is_array($param['sku'])) {
  76.                 $param['sku'] = [$param['sku']];
  77.             }
  78.             $q->andWhere('r.sku IN (\'' . join('\',\'', $param['sku']) . '\')');
  79.         }
  81.         $r = $q->getQuery()
  82.             ->enableResultCache(TimeConstant::HOUR);
  84.         return $r->getArrayResult();
  85.     }
  87.     public function getReviewsForReviewsReport($offset = null, $limit = null): iterable
  88.     {
  89.         $q = $this->createQueryBuilder('r')
  90.             ->select('r')
  91.             ->leftJoin('r.collection', 'c')
  92.             ->leftJoin('r.order', 'o')
  93.             ->addSelect('c')
  94.             ->addSelect('o')
  95.             ->leftJoin('o.mailing', 'm')
  96.             ->addSelect('m')
  97.             ->orderBy('r.id', 'DESC')
  98.         ;
  100.         if (null !== $offset) {
  101.             $q->setFirstResult($offset);
  102.         }
  104.         if (null !== $limit) {
  105.             $q->setMaxResults($limit);
  106.         }
  108.         return $q->getQuery()->getResult();
  109.     }
  111.     public function getReviewsTotalCount()
  112.     {
  113.         try {
  114.             $result = $this->createQueryBuilder('r')
  115.                 ->select('count(r.id)')
  116.                 ->getQuery()
  117.                 ->getSingleScalarResult();
  118.         } catch (UnexpectedResultException $e) {
  119.             $result = 0;
  120.         }
  122.         return $result;
  123.     }
  125.     public function save(ProductReviewsCache $productReview, bool $flush = true): void
  126.     {
  127.         $this->getEntityManager()->persist($productReview);
  129.         if ($flush) {
  130.             $this->getEntityManager()->flush();
  131.         }
  132.     }
  134.     public function getReviewsForFeeds(): array
  135.     {
  136.         try {
  137.             $query = $this->createQueryBuilder('r')
  138. //                ->where('r.collection IS NOT NULL')
  139.                 ->where('r.collection <> 0')
  140.                 ->orderBy('r.collection', 'ASC')
  141.                 ->getQuery()
  142.                 ;
  143.             $sql = $query->getSQL();
  144.             $result = $query->getResult();
  145.         } catch (UnexpectedResultException $e) {
  146.             $result = [];
  147.         }
  149.         return $result;
  150.     }
  151. }