custom/static-plugins/GlobusSW6/src/Subscriber/ArticleDocuments/HandleArticleDocuments.php line 46

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace GlobusSW6\Subscriber\ArticleDocuments;
  5. use GlobusSW6\Service\ArticleDocumentsService;
  6. use Psr\Log\LoggerInterface;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntitySearchResultLoadedEvent;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use GlobusSW6\Service\IaneoBusinessExtension;
  10. use Shopware\Core\Framework\Api\Context\AdminApiSource;
  11. use Shopware\Core\Content\Product\ProductCollection;
  12. use Symfony\Component\HttpFoundation\RequestStack;
  14. class HandleArticleDocuments implements EventSubscriberInterface
  15. {
  17.     private ArticleDocumentsService $articleDocumentsService;
  18.     private LoggerInterface $logger;
  19.     private IaneoBusinessExtension $IaneoBusinessExtension;
  20.     private RequestStack $requestStack;
  21.     public const WHITELIST_ROUTES = [
  22.         'frontend.detail.page',
  23.         'store-api.product.detail',
  24.     ];
  26.     public function __construct(
  27.         ArticleDocumentsService $articleDocumentsService,
  28.         LoggerInterface $logger,
  29.         IaneoBusinessExtension $IaneoBusinessExtension,
  30.         RequestStack $requestStack
  31.     ) {
  32.         $this->articleDocumentsService = $articleDocumentsService;
  33.         $this->logger = $logger;
  34.         $this->IaneoBusinessExtension = $IaneoBusinessExtension;
  35.         $this->requestStack = $requestStack;
  36.     }
  38.     public static function getSubscribedEvents(): array
  39.     {
  40.         return [
  41. //            ProductPageLoadedEvent::class => 'onProductPageLoadedEvent'
  42.             'product.search.result.loaded' => 'onProductLoaded'
  43.         ];
  44.     }
  46.     public function onProductLoaded(EntitySearchResultLoadedEvent $event)
  47.     {
  48.         // do not fire event in backend context
  49.         if ($event->getContext()->getSource() instanceof AdminApiSource) {
  50.             if ($event->getContext()->getSource()->isAdmin()) {
  51.                 return;
  52.             }
  53.         }
  55.         if(!$this->shouldAttachDocuments()) {
  56.             return;
  57.         }
  59.         /** @var ProductCollection $products */
  60.         $products = $event->getResult()->getEntities();
  62.         if($products === null){
  63.             return;
  64.         }
  66.         foreach ($products as $product) {
  67.             try {
  68.                 $articleDocuments = $this->articleDocumentsService->getProductDocumentRelations($product->getId(), $event->getContext());
  70.                 if($articleDocuments->has('documents')) {
  71.                     $this->IaneoBusinessExtension->addSingleAttributeToProduct($product, $articleDocuments->get('documents'), 'articleDocuments');
  72.                 }
  73.             } catch(\Exception $exception) {
  74.                 $this->logger->error(__CLASS__ . ":" . __FUNCTION__ . ":" . __LINE__ . ":\$exception->getMessage(): " . $exception->getMessage());
  75.             }
  76.         }
  77.     }
  79.     private function shouldAttachDocuments(): bool
  80.     {
  81.         $currentRequest = $this->requestStack->getCurrentRequest();
  83.         if ($currentRequest) {
  84.             $requestRoute = $currentRequest->attributes?->get('_route') ?? '';
  86.             foreach (self::WHITELIST_ROUTES as $WHITELIST_ROUTE) {
  87.                 if (str_contains($requestRoute, $WHITELIST_ROUTE)) {
  88.                     return true;
  89.                 }
  90.             }
  91.         }
  93.         return false;
  94.     }
  96. }