custom/static-plugins/GlobusSW6/src/Subscriber/WarrantySubscriber.php line 43

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace GlobusSW6\Subscriber;
  5. use GlobusSW6\Core\Content\Warranty\WarrantyEntity;
  6. use GlobusSW6\Service\IaneoBusinessExtension;
  7. use GlobusSW6\Service\WarrantyService;
  8. use Shopware\Core\Content\Product\ProductEntity;
  9. use Shopware\Core\Framework\Api\Context\AdminApiSource;
  10. use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
  11. use Shopware\Core\Framework\Api\Context\SystemSource;
  12. use Shopware\Core\Framework\Struct\ArrayStruct;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntitySearchResultLoadedEvent;
  16. class WarrantySubscriber implements EventSubscriberInterface
  17. {
  19.     /** @var WarrantyService */
  20.     private $warrantyService;
  22.     /** @var IaneoBusinessExtension */
  23.     private $ianeoBusinessExtension;
  25.     /**
  26.      * WarrantySubscriber constructor.
  27.      * @param WarrantyService $warrantyService
  28.      * @param IaneoBusinessExtension $ianeoBusinessExtension
  29.      */
  30.     public function __construct(WarrantyService $warrantyService, IaneoBusinessExtension $ianeoBusinessExtension)
  31.     {
  32.         $this->warrantyService = $warrantyService;
  33.         $this->ianeoBusinessExtension = $ianeoBusinessExtension;
  34.     }
  36.     public static function getSubscribedEvents()
  37.     {
  38.         return [
  39.             'product.search.result.loaded' => ['onProduct', 1000]
  40.         ];
  41.     }
  43.     public function onProduct(EntitySearchResultLoadedEvent $event)
  44.     {
  45.         // do not fire event in backend context
  46.         if ($event->getContext()->getSource() instanceof AdminApiSource) {
  47.             if ($event->getContext()->getSource()->isAdmin()) {
  48.                 return;
  49.             }
  50.         }
  52.         if ($event->getContext()->getSource() instanceof SystemSource) {
  53.             return;
  54.         }
  56.         $products = $event->getResult()->getElements();
  58.         if (empty($products)) {
  59.             return;
  60.         }
  62.         // detect warranties
  63.         $warranties = $this->warrantyService->checkWarranty($event->getResult()->getEntities(), $event->getContext()->getSource()->getSalesChannelId());
  65.         foreach ($products as $product) {
  67.             /** @var ProductEntity $product */
  68.             /** @var array $productExtensions */
  69.             $productExtensions = $product->getExtensions();
  70.             if (!array_key_exists('ianeoExtensions', $productExtensions)) {
  71.                 continue;
  72.             }
  73.             /** @var ArrayStruct $ianeoExtensions */
  74.             $ianeoExtensions = $productExtensions['ianeoExtensions'];
  75.             // in case product has warranties, remove potential additionalServiceSets
  76.             if (array_key_exists($product->getId(), $warranties)) {
  77.                 if ($ianeoExtensions->has('additionalServiceSets') && ($ianeoExtensions['additionalServiceSets'] !== null)) {
  78.                     unset($ianeoExtensions['additionalServiceSets']);
  79.                 }
  80.             }
  81.         }
  83.         // add warranties to products
  84.         $this->ianeoBusinessExtension->addAttributes($event->getResult()->getEntities(), $warranties, 'warranty');
  85.     }
  86. }