custom/static-plugins/GlobusSW6/src/Subscriber/ProductReviewAndRatingSubscriber.php line 42

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace GlobusSW6\Subscriber;
  5. use GlobusSW6\Core\Content\Attributes\Product\Aggregate\ProductReview\ProductReviewAttributesEntity;
  6. use GlobusSW6\Core\Content\ProductRatings\VoteRatingsEntity;
  7. use GlobusSW6\Service\IaneoBusinessExtension;
  8. use GlobusSW6\Service\ProductReviewAndRatingService;
  9. use Shopware\Core\Content\Product\Aggregate\ProductReview\ProductReviewEntity;
  10. use Shopware\Core\Content\Product\ProductCollection;
  11. use Shopware\Core\Framework\Api\Context\AdminApiSource;
  12. use Shopware\Core\Framework\Api\Context\SystemSource;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntitySearchResultLoadedEvent;
  15. use Shopware\Core\Framework\Struct\ArrayStruct;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class ProductReviewAndRatingSubscriber implements EventSubscriberInterface
  19. {
  20.     /** @var ProductReviewAndRatingService */
  21.     private $productReviewAndRatingService;
  23.     /** @var IaneoBusinessExtension */
  24.     private $ianeoBusinessExtensionService;
  27.     public function __construct(ProductReviewAndRatingService $productReviewAndRatingService, IaneoBusinessExtension $ianeoBusinessExtensionService)
  28.     {
  29.         $this->productReviewAndRatingService = $productReviewAndRatingService;
  30.         $this->ianeoBusinessExtensionService = $ianeoBusinessExtensionService;
  32.     }
  34.     public static function getSubscribedEvents()
  35.     {
  36.         return [
  37.             'product.search.result.loaded' => 'onProductLoaded',
  38.             'product_review.loaded' => 'onReviewLoaded'
  39.         ];
  40.     }
  42.     public function onProductLoaded(EntitySearchResultLoadedEvent $event)
  43.     {
  45.         // do not fire event in backend context
  46.         if ($event->getContext()->getSource() instanceof AdminApiSource) {
  47.             if ($event->getContext()->getSource()->isAdmin()) {
  48.                 return;
  49.             }
  50.         }
  52.         if ($event->getContext()->getSource() instanceof SystemSource) {
  53.             return;
  54.         }
  55.         $salesChannelId = $event->getContext()->getSource()->getSalesChannelId();
  57.         /** @var ProductCollection $products */
  58.         $products = $event->getResult()->getEntities();
  60.         if ($products === null) {
  61.             return;
  62.         }
  64.         if ($event->getName() !== 'product.search.result.loaded') {
  65.             return;
  66.         }
  68.         $productReviewCount = $this->productReviewAndRatingService->checkProductReviews($products, $salesChannelId);
  69.         $averageRatings = $this->productReviewAndRatingService->checkAverageRatings($products);
  71.         $productRecommandationCount = $this->productReviewAndRatingService->checkProductRecommandations($products, $salesChannelId);
  73.         $this->ianeoBusinessExtensionService->addAttributes($products, $productReviewCount, 'productReviewCount');
  74.         $this->ianeoBusinessExtensionService->addAttributes($products, $averageRatings, 'averageProductRating');
  75.         $this->ianeoBusinessExtensionService->addAttributes($products, $productRecommandationCount, 'productRecommandationCount');
  76.     }
  78.     /**
  79.      * this method is used to append the customer name and up/down-votes to the ianeoAttributes so that
  80.      * this info is available in the routes
  81.      * (e.g. in  src/Core/Content/Product/SalesChannel/Review/ProductReviewRoute.php
  82.      *   /store-api/product/{productId}/reviews
  83.      * )
  84.      *
  85.      * @param EntityLoadedEvent $event
  86.      * @return void
  87.      */
  88.     public function onReviewLoaded(EntityLoadedEvent $event)
  89.     {
  90.         // do not fire event in backend context
  91.         if ($event->getContext()->getSource() instanceof AdminApiSource) {
  92.             if ($event->getContext()->getSource()->isAdmin()) {
  93.                 return;
  94.             }
  95.         }
  97.         $eventEntity = $event->getEntities();
  99.         /** @var ProductReviewEntity $entity */
  100.         foreach ($eventEntity as $entity) {
  102.             $userInfo = new ArrayStruct();
  103.             $userInfo->set('firstname', $entity->getExternalUser());
  105.             /** @var  VoteRatingsEntity $vote */
  106.             $vote = $entity->getExtension('vote');
  108.             $voteInfo = new ArrayStruct();
  110.             if (is_null($vote)) {
  111.                 $voteInfo->set('vote_info', 'no up- and downvotes available');
  112.             } else {
  113.                 $voteInfo->set('vote_id', $vote->getVoteId());
  114.                 $voteInfo->set('upvotes', $vote->getUpvotes());
  115.                 $voteInfo->set('downvotes', $vote->getDownvotes());
  116.             }
  118.             /** @var ProductReviewAttributesEntity $extension */
  119.             $extension = $entity->getExtension('ianeoAttributes');
  121.             if (is_null($extension))
  122.             {
  123.                 //Todo SMN Errorhandling
  124.                 return;
  125.             }
  127.             $extension->addExtension('author_info', $userInfo);
  128.             $extension = $entity->getExtension('ianeoAttributes');
  129.             if (is_null($extension))
  130.             {
  131.                 //Todo SMN Errorhandling
  132.                 return;
  133.             }
  134.             $extension->addExtension('vote_info', $voteInfo);
  136.         }
  137.     }
  138. }