custom/plugins/AcrisProductInfoTextCS/src/Subscriber/ProductLoadedSubscriber.php line 46

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\ProductInfoText\Subscriber;
  5. use Acris\ProductInfoText\Components\ProductInfoText\InfoTextGateway;
  6. use Acris\ProductInfoText\Components\ProductInfoText\InfoTextService;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  8. use Shopware\Core\Framework\Struct\ArrayEntity;
  9. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class ProductLoadedSubscriber implements EventSubscriberInterface
  13. {
  14.     public const ACRIS_STREAM_IDS_EXTENSION = 'acrisStreamIds';
  16.     /**
  17.      * @var EntityRepositoryInterface
  18.      */
  19.     private $productRepository;
  20.     /**
  21.      * @var InfoTextService
  22.      */
  23.     private $infoTextService;
  24.     /**
  25.      * @var InfoTextGateway
  26.      */
  27.     private $infoTextGateway;
  29.     public function __construct(
  30.         EntityRepositoryInterface $productRepository,
  31.         InfoTextService $infoTextService,
  32.         InfoTextGateway $infoTextGateway
  33.     ) {
  34.         $this->productRepository = $productRepository;
  35.         $this->infoTextService = $infoTextService;
  36.         $this->infoTextGateway = $infoTextGateway;
  37.     }
  39.     public static function getSubscribedEvents()
  40.     {
  41.         return [
  42.             ProductPageLoadedEvent::class => ['productLoaded', 200]
  43.         ];
  44.     }
  46.     public function productLoaded(ProductPageLoadedEvent $event): void
  47.     {
  48.         $product = $event->getPage()->getProduct();
  50.         if ($product->hasExtension(self::ACRIS_STREAM_IDS_EXTENSION) && !empty($product->getExtension(self::ACRIS_STREAM_IDS_EXTENSION))) {
  51.             $productStreamIds = $product->getExtension(self::ACRIS_STREAM_IDS_EXTENSION)->get('ids');
  52.         } else {
  53.             $productStreamIds = $this->infoTextGateway->getProductStreamIds([$product->getId()], $event->getSalesChannelContext()->getContext());
  54.             $product->addExtension(self::ACRIS_STREAM_IDS_EXTENSION, new ArrayEntity(['ids' => $productStreamIds]));
  55.         }
  57.         if (empty($productStreamIds)) return;
  59.         $infoTextResult = $this->infoTextGateway->getProductDetailInfoText($productStreamIds, $event->getSalesChannelContext());
  60.         if(empty($infoTextResult) || $infoTextResult->count() === 0) {
  61.             return;
  62.         }
  63.         $infoTexts = $this->infoTextService->getInfoTextsForProduct($infoTextResult->getEntities());
  64.         $product->addExtension('acrisInfoText', new ArrayEntity([
  65.             'texts' => $infoTexts
  66.         ]));
  67.     }
  68. }