custom/static-plugins/GlobusSW6/src/Subscriber/Psa/ProductPsaExtensionSubscriber.php line 47

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace GlobusSW6\Subscriber\Psa;
  5. use Shopware\Core\Content\Product\ProductCollection;
  6. use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntitySearchResultLoadedEvent;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use GlobusSW6\Service\PsaApi\PsaApiService;
  10. use Psr\Log\LoggerInterface;
  11. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  12. use GlobusSW6\Service\IaneoBusinessExtension;
  14. class ProductPsaExtensionSubscriber implements EventSubscriberInterface
  15. {
  18.     /** @var LoggerInterface  */
  19.     private $logger;
  21.     /** @var IaneoBusinessExtension */
  22.     private $ianeoBusinessExtension;
  24.     /** @var PsaApiService */
  25.     private $psaApiService;
  27.     /**
  28.      * ProductPsaExtensionSubscriber constructor.
  29.      * @param LoggerInterface $logger
  30.      * @param IaneoBusinessExtension $ianeoBusinessExtension
  31.      * @param PsaApiService $psaApiService
  32.      */
  33.     public function __construct(LoggerInterface $logger, IaneoBusinessExtension $ianeoBusinessExtension, PsaApiService $psaApiService)
  34.     {
  35.         $this->logger = $logger;
  36.         $this->ianeoBusinessExtension = $ianeoBusinessExtension;
  37.         $this->psaApiService = $psaApiService;
  38.     }
  40.     public static function getSubscribedEvents(): array
  41.     {
  42.         return [
  43.             'product.search.result.loaded' => 'onProductLoaded'
  44.         ];
  45.     }
  47.     public function onProductLoaded(EntitySearchResultLoadedEvent $event)
  48.     {
  49.         /** @var ProductCollection $products */
  50.         $products = $event->getResult()->getEntities();
  52.         if ($products === null) {
  53.             return;
  54.         }
  56.         if ($event->getContext()->getSource() instanceOf SalesChannelApiSource)
  57.         {
  58.             foreach ($products as $product) {
  59.                 try {
  60.                     $psa = $this->psaApiService->getPsaByProductId($product->getId(), $event->getContext());
  62.                     if($psa) {
  63.                         $this->ianeoBusinessExtension->addSingleAttributeToProduct($product, $psa, 'psa');
  64.                     }
  65.                 } catch(\Exception $exception) {
  66.                     $this->logger->error(__CLASS__ . ":" . __FUNCTION__ . ":" . __LINE__ . ":\$exception->getMessage(): " . $exception->getMessage());
  67.                 }
  68.             }
  69.         }
  70.     }
  71. }