custom/plugins/AcrisProductTabCS/src/Storefront/Subscriber/ProductTabSubscriber.php line 78

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\ProductTab\Storefront\Subscriber;
  5. use Acris\ProductTab\Components\ProductTab\ProductTabGateway;
  6. use Acris\ProductTab\Components\ProductTab\ProductTabService;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  9. use Shopware\Core\Framework\Struct\ArrayEntity;
  10. use Shopware\Storefront\Page\Product\ProductPageCriteriaEvent;
  11. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Component\HttpFoundation\RequestStack;
  15. Class ProductTabSubscriber implements EventSubscriberInterface
  16. {
  17.     public const ACRIS_STREAM_IDS_EXTENSION = 'acrisStreamIds';
  18.     public const PRODUCT_TAB_SORT_BY = 'DESC';
  20.     /**
  21.      * @var RequestStack
  22.      */
  23.     private $requestStack;
  25.     /**
  26.      * @var ProductTabGateway
  27.      */
  28.     private $productTabGateway;
  30.     /**
  31.      * @var ProductTabService
  32.      */
  33.     private $productTabService;
  35.     public function __construct(
  36.         RequestStack $requestStack,
  37.         ProductTabGateway $productTabGateway,
  38.         ProductTabService $productTabService
  39.     )
  40.     {
  41.         $this->requestStack = $requestStack;
  42.         $this->productTabGateway = $productTabGateway;
  43.         $this->productTabService = $productTabService;
  44.     }
  46.     public static function getSubscribedEvents(): array
  47.     {
  48.         return [
  49.             ProductPageCriteriaEvent::class => 'onProductPageCriteria',
  50.             ProductPageLoadedEvent::class => 'onProductPageLoaded'
  51.         ];
  52.     }
  54.     public function onProductPageCriteria(ProductPageCriteriaEvent $event): void
  55.     {
  56.         $event->getCriteria()->addAssociation('acrisProductTab')->addAssociation('acrisProductTab.cmsPage')
  57.             ->getAssociation('acrisProductTab')->addSorting(new FieldSorting('priority', self::PRODUCT_TAB_SORT_BY))
  58.             ->addFilter(new EqualsFilter('active', true));
  59.     }
  61.     public function onProductPageLoaded(ProductPageLoadedEvent $event): void
  62.     {
  63.         $request = $this->requestStack->getCurrentRequest();
  64.         if(empty($request) === true) {
  65.             return;
  66.         }
  67.         $product = $event->getPage()->getProduct();
  68.         if (empty($product)) return;
  69.         $productId = $product->getId();
  71.         if ($product->hasExtension(self::ACRIS_STREAM_IDS_EXTENSION) && !empty($product->getExtension(self::ACRIS_STREAM_IDS_EXTENSION))) {
  72.             $productStreamIds = $product->getExtension(self::ACRIS_STREAM_IDS_EXTENSION)->get('ids');
  73.         } else {
  74.             $productStreamIds = $this->productTabGateway->getProductStreamIds([$productId], $event->getSalesChannelContext()->getContext());
  75.             $product->addExtension(self::ACRIS_STREAM_IDS_EXTENSION, new ArrayEntity(['ids' => $productStreamIds]));
  76.         }
  78.         $productTabResult = !empty($product->getParentId()) ? $this->productTabGateway->getProductDetailProductTab($product->getParentId(), $productStreamIds, $event->getSalesChannelContext()) : $this->productTabGateway->getProductDetailProductTab($productId, $productStreamIds, $event->getSalesChannelContext());
  80.         if($productTabResult->count() === 0) {
  81.             if($product->hasExtension('acrisProductTab')){
  82.                 $product->removeExtension('acrisProductTab');
  83.             }
  84.             return;
  85.         }
  87.         $this->productTabService->setCmsPages($productTabResult->getEntities(), $request, $event);
  88.         $product->addExtension('acrisProductTab', $productTabResult->getEntities());
  89.     }
  90. }