custom/plugins/EsmComputer/src/Storefront/Subscriber/OtherProductVotesSubscriber.php line 38

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  4. namespace EsmComputer\Storefront\Subscriber;
  6. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductEntity;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  10. use Shopware\Core\System\SalesChannel\Entity\SalesChannelRepositoryInterface;
  11. use Shopware\Storefront\Page\Product\Review\ProductReviewsLoadedEvent;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use function array_key_exists;
  15. class OtherProductVotesSubscriber implements EventSubscriberInterface
  16. {
  17.     protected EntityRepository $productReviewRepository;
  18.     protected SalesChannelRepositoryInterface $salesChannelProductRepository;
  20.     public function __construct(
  21.         EntityRepository $productReviewRepository,
  22.         SalesChannelRepositoryInterface $salesChannelProductRepository
  23.     )
  24.     {
  25.         $this->productReviewRepository = $productReviewRepository;
  26.         $this->salesChannelProductRepository = $salesChannelProductRepository;
  27.     }
  29.     public static function getSubscribedEvents()
  30.     {
  31.         return [
  32.             ProductReviewsLoadedEvent::class => [[
  33.                 'onProductReviewsLoaded', 150
  34.             ]]
  35.         ];
  36.     }
  38.     public function onProductReviewsLoaded(ProductReviewsLoadedEvent $event): void
  39.     {
  40.         $request = $event->getRequest();
  41.         $productId = $request->get('parentId') ?? $request->get('productId');
  43.         $criteria = new Criteria([$productId]);
  44.         /** @var SalesChannelProductEntity $product */
  45.         $product = $this->salesChannelProductRepository->search($criteria, $event->getSalesChannelContext())->getEntities()->first();
  47.         if(!array_key_exists('custom_product_model', $product->getCustomFields())) {
  48.             return;
  49.         }
  51.         $model = $product->getCustomFields()['custom_product_model'];
  52.         if(!$model) {
  53.             return;
  54.         }
  56.         $criteria = $event->getSearchResult()->getCriteria();
  57.         $criteria->resetFilters();
  58.         $criteria->addAssociation('product');
  59.         $criteria->addFilter(new EqualsFilter('status', true));
  60.         $criteria->addFilter(new EqualsFilter('product.customFields.custom_product_model', $model));
  62.         $allReviews = $this->productReviewRepository->search($criteria, $event->getContext());
  64.         $event->getSearchResult()->merge($allReviews->getEntities());
  65.         $event->getSearchResult()->getAggregations()->set('ratingMatrix', $allReviews->getAggregations()->get('ratingMatrix'));
  66.     }
  67. }