custom/static-plugins/GlobusSW6/src/Subscriber/Biocide/ProductBiocideExtensionSubscriber.php line 45

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace GlobusSW6\Subscriber\Biocide;
  5. use GlobusSW6\Service\BiocideApi\BiocideApiService;
  6. use Psr\Log\LoggerInterface;
  7. use Shopware\Core\Content\Product\ProductCollection;
  8. use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use GlobusSW6\Service\IaneoBusinessExtension;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntitySearchResultLoadedEvent;
  13. class ProductBiocideExtensionSubscriber implements EventSubscriberInterface
  14. {
  16.     /** @var LoggerInterface  */
  17.     private $logger;
  19.     /** @var IaneoBusinessExtension */
  20.     private $ianeoBusinessExtension;
  22.     /** @var BiocideApiService */
  23.     private $biocideApiService;
  25.     /**
  26.      * ProductBiocideExtensionSubscriber constructor.
  27.      * @param LoggerInterface $logger
  28.      * @param IaneoBusinessExtension $ianeoBusinessExtension
  29.      * @param BiocideApiService $biocideApiService
  30.      */
  31.     public function __construct(LoggerInterface $logger, IaneoBusinessExtension $ianeoBusinessExtension, BiocideApiService $biocideApiService)
  32.     {
  33.         $this->logger = $logger;
  34.         $this->ianeoBusinessExtension = $ianeoBusinessExtension;
  35.         $this->biocideApiService = $biocideApiService;
  36.     }
  38.     public static function getSubscribedEvents(): array
  39.     {
  40.         return [
  41.             'product.search.result.loaded' => 'onProductLoaded'
  42.         ];
  43.     }
  45.     public function onProductLoaded(EntitySearchResultLoadedEvent $event)
  46.     {
  47.         /** @var ProductCollection $products */
  48.         $products = $event->getResult()->getEntities();
  50.         if ($products === null) {
  51.             return;
  52.         }
  54.         if ($event->getContext()->getSource() instanceOf SalesChannelApiSource)
  55.         {
  56.             foreach ($products as $product)
  57.             {
  58.                 try {
  59.                     $biocide = $this->biocideApiService->getBiocideByProductId($product->getId(), $event->getContext());
  61.                     if($biocide) {
  62.                         $this->ianeoBusinessExtension->addSingleAttributeToProduct($product, $biocide, 'biocide');
  63.                     }
  64.                 } catch(\Exception $exception) {
  65.                     $this->logger->error(__CLASS__ . ":" . __FUNCTION__ . ":" . __LINE__ . ":\$exception->getMessage(): " . $exception->getMessage());
  66.                 }
  67.             }
  68.         }
  69.     }
  72. }