custom/static-plugins/GlobusSW6/src/Subscriber/DepositSubscriber.php line 39

Open in your IDE?
  1. <?php
  3. namespace GlobusSW6\Subscriber;
  5. use GlobusSW6\Service\Deposit\DepositService;
  6. use Shopware\Core\Content\Product\ProductCollection;
  7. use Shopware\Core\Framework\Api\Context\AdminApiSource;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use GlobusSW6\Service\IaneoBusinessExtension;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntitySearchResultLoadedEvent;
  12. class DepositSubscriber implements EventSubscriberInterface
  13. {
  15.     /** @var IaneoBusinessExtension */
  16.     private $ianeoBusinessExtension;
  18.     /** @var DepositService */
  19.     private $depositService;
  21.     /**
  22.      * @param IaneoBusinessExtension $ianeoBusinessExtension
  23.      * @param DepositService $depositService
  24.      */
  25.     public function __construct(IaneoBusinessExtension $ianeoBusinessExtension, DepositService $depositService)
  26.     {
  27.         $this->ianeoBusinessExtension = $ianeoBusinessExtension;
  28.         $this->depositService = $depositService;
  29.     }
  31.     public static function getSubscribedEvents()
  32.     {
  33.         return [
  34.             'product.search.result.loaded' => 'onProductLoaded',
  35.         ];
  36.     }
  38.     // Check if product contains deposits and add the deposits into extension IaneoExtensions
  39.     public function onProductLoaded(EntitySearchResultLoadedEvent $event)
  40.     {
  41.         // do not fire event in backend context
  42.         if ($event->getContext()->getSource() instanceof AdminApiSource) {
  43.             if ($event->getContext()->getSource()->isAdmin()) {
  44.                 return;
  45.             }
  46.         }
  48.         /** @var ProductCollection $products */
  49.         $products = $event->getResult()->getEntities();
  51.         if (is_null($products)){
  52.             return;
  53.         }
  55.         $deposits = $this->depositService->collectDeposits($products);
  56.         
  57.         // Add deposits into extension
  58.         $this->ianeoBusinessExtension->addAttributes($event->getResult()->getEntities(), $deposits, 'deposits');
  59.     }
  61. }