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

Open in your IDE?
  1. <?php
  3. namespace GlobusSW6\Subscriber;
  5. use GlobusSW6\Core\IaneoDefaults;
  6. use GlobusSW6\Service\IaneoBusinessExtension;
  7. use GlobusSW6\Service\ShippingCostsService;
  8. use Psr\Log\LoggerInterface;
  9. use Shopware\Core\Content\Product\ProductCollection;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntitySearchResultLoadedEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class ShippingCostsSubscriber implements EventSubscriberInterface
  14. {
  16.     /** @var ShippingCostsService */
  17.     private $shippingCostsService;
  19.     /** @var IaneoBusinessExtension */
  20.     private $ianeoBusinessExtensionService;
  22.     /** @var LoggerInterface */
  23.     private $logger;
  25.     /**
  26.      * @param ShippingCostsService $shippingCostsService
  27.      * @param IaneoBusinessExtension $ianeoBusinessExtensionService
  28.      * @param LoggerInterface $logger
  29.      */
  30.     public function __construct(ShippingCostsService $shippingCostsService, IaneoBusinessExtension $ianeoBusinessExtensionService, LoggerInterface $logger)
  31.     {
  32.         $this->shippingCostsService = $shippingCostsService;
  33.         $this->ianeoBusinessExtensionService = $ianeoBusinessExtensionService;
  34.         $this->logger = $logger;
  35.     }
  38.     public static function getSubscribedEvents()
  39.     {
  40.         return [
  41.             'product.search.result.loaded' => 'onProductLoaded'
  42.         ];
  43.     }
  45.     public function onProductLoaded(EntitySearchResultLoadedEvent $event){
  47.         /** @var ProductCollection $products */
  48.         $products = $event->getResult()->getEntities();
  50.         try {
  51.             $salesChannelId = $event->getContext()->getSource()->getSalesChannelId();
  52.         } catch (\Throwable $t ) {
  53.             $salesChannelId = IaneoDefaults::SALES_CHANNEL_BAUMARKT; // TODO-NGS: find better solution, this is only hotfix
  54.             $this->logger->info('Unable to access salesChannelId - choose default SalesChanelId Baumarkt: ' . $t->getMessage());
  55.         }
  57.         if($products === null){
  58.             return;
  59.         }
  61.         if($event->getName() !== 'product.search.result.loaded'){
  62.             return;
  63.         }
  65.         // Collect shipping costs
  66.         $shippingCosts = $this->shippingCostsService->checkShippingCosts($products, $salesChannelId);
  68.         // add shipping costs flags to product extension
  69.         $this->ianeoBusinessExtensionService->addAttributes($products, $shippingCosts, 'shippingCosts');
  70.     }
  71. }