vendor/shopware/storefront/Page/Product/Review/ProductReviewLoader.php line 55

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Storefront\Page\Product\Review;
  5. use Shopware\Core\Content\Product\Aggregate\ProductReview\ProductReviewEntity;
  6. use Shopware\Core\Content\Product\SalesChannel\Review\AbstractProductReviewRoute;
  7. use Shopware\Core\Content\Product\SalesChannel\Review\RatingMatrix;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Aggregation\Bucket\FilterAggregation;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Aggregation\Bucket\TermsAggregation;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\AggregationResult\Bucket\TermsResult;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\RangeFilter;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  17. use Shopware\Core\Framework\Log\Package;
  18. use Shopware\Core\Framework\Routing\Exception\MissingRequestParameterException;
  19. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  20. use Shopware\Storefront\Framework\Page\StorefrontSearchResult;
  21. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  22. use Symfony\Component\HttpFoundation\Request;
  24. #[Package('storefront')]
  25. class ProductReviewLoader
  26. {
  27.     private const LIMIT = 10;
  28.     private const DEFAULT_PAGE = 1;
  29.     private const FILTER_LANGUAGE = 'filter-language';
  31.     /**
  32.      * @internal
  33.      */
  34.     public function __construct(private readonly AbstractProductReviewRoute $route, private readonly EventDispatcherInterface $eventDispatcher)
  35.     {
  36.     }
  38.     /**
  39.      * load reviews for one product. The request must contain the productId
  40.      * otherwise MissingRequestParameterException is thrown
  41.      *
  42.      * @throws MissingRequestParameterException
  43.      * @throws InconsistentCriteriaIdsException
  44.      */
  45.     public function load(Request $request, SalesChannelContext $context): ReviewLoaderResult
  46.     {
  47.         $productId = $request->get('parentId') ?? $request->get('productId');
  48.         if (!$productId) {
  49.             throw new MissingRequestParameterException('productId');
  50.         }
  52.         $criteria = $this->createCriteria($request, $context);
  54.         $reviews = $this->route
  55.             ->load($productId, $request, $context, $criteria)
  56.             ->getResult();
  58.         $reviews = StorefrontSearchResult::createFrom($reviews);
  60.         $this->eventDispatcher->dispatch(new ProductReviewsLoadedEvent($reviews, $context, $request));
  62.         $reviewResult = ReviewLoaderResult::createFrom($reviews);
  63.         $reviewResult->setProductId($request->get('productId'));
  64.         $reviewResult->setParentId($request->get('parentId'));
  66.         $aggregation = $reviews->getAggregations()->get('ratingMatrix');
  67.         $matrix = new RatingMatrix([]);
  69.         if ($aggregation instanceof TermsResult) {
  70.             $matrix = new RatingMatrix($aggregation->getBuckets());
  71.         }
  72.         $reviewResult->setMatrix($matrix);
  73.         $reviewResult->setCustomerReview($this->getCustomerReview($productId, $context));
  74.         $reviewResult->setTotalReviews($matrix->getTotalReviewCount());
  76.         return $reviewResult;
  77.     }
  79.     private function createCriteria(Request $request, SalesChannelContext $context): Criteria
  80.     {
  81.         $limit = (int) $request->get('limit', self::LIMIT);
  82.         $page = (int) $request->get('p', self::DEFAULT_PAGE);
  83.         $offset = $limit * ($page - 1);
  85.         $criteria = new Criteria();
  86.         $criteria->setLimit($limit);
  87.         $criteria->setOffset($offset);
  88.         $criteria->setTotalCountMode(Criteria::TOTAL_COUNT_MODE_EXACT);
  90.         $sorting = new FieldSorting('createdAt', 'DESC');
  91.         if ($request->get('sort', 'createdAt') === 'points') {
  92.             $sorting = new FieldSorting('points', 'DESC');
  93.         }
  95.         $criteria->addSorting($sorting);
  97.         if ($request->get('language') === self::FILTER_LANGUAGE) {
  98.             $criteria->addPostFilter(
  99.                 new EqualsFilter('languageId', $context->getContext()->getLanguageId())
  100.             );
  101.         }
  103.         $this->handlePointsAggregation($request, $criteria, $context);
  105.         return $criteria;
  106.     }
  108.     /**
  109.      * get review by productId and customer
  110.      * a customer should only create one review per product, so if there are more than one
  111.      * review we only take one
  112.      *
  113.      * @throws InconsistentCriteriaIdsException
  114.      */
  115.     private function getCustomerReview(string $productId, SalesChannelContext $context): ?ProductReviewEntity
  116.     {
  117.         $customer = $context->getCustomer();
  119.         if (!$customer) {
  120.             return null;
  121.         }
  123.         $criteria = new Criteria();
  124.         $criteria->setLimit(1);
  125.         $criteria->setOffset(0);
  126.         $criteria->addFilter(new EqualsFilter('customerId', $customer->getId()));
  128.         $customerReviews = $this->route
  129.             ->load($productId, new Request(), $context, $criteria)
  130.             ->getResult();
  132.         return $customerReviews->first();
  133.     }
  135.     private function handlePointsAggregation(Request $request, Criteria $criteria, SalesChannelContext $context): void
  136.     {
  137.         $reviewFilters = [];
  138.         $points = $request->get('points', []);
  140.         if (\is_array($points) && \count($points) > 0) {
  141.             $pointFilter = [];
  142.             foreach ($points as $point) {
  143.                 $pointFilter[] = new RangeFilter('points', [
  144.                     'gte' => $point - 0.5,
  145.                     'lt' => $point + 0.5,
  146.                 ]);
  147.             }
  149.             $criteria->addPostFilter(new MultiFilter(MultiFilter::CONNECTION_OR, $pointFilter));
  150.         }
  152.         $reviewFilters[] = new EqualsFilter('status', true);
  153.         if ($context->getCustomer() !== null) {
  154.             $reviewFilters[] = new EqualsFilter('customerId', $context->getCustomer()->getId());
  155.         }
  157.         $criteria->addAggregation(
  158.             new FilterAggregation(
  159.                 'customer-login-filter',
  160.                 new TermsAggregation('ratingMatrix', 'points'),
  161.                 [
  162.                     new MultiFilter(MultiFilter::CONNECTION_OR, $reviewFilters),
  163.                 ]
  164.             )
  165.         );
  166.     }
  167. }