vendor/store.shopware.com/acrisproductbadgescs/src/Storefront/Subscriber/ProductBadgeSubscriber.php line 51

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\ProductBadges\Storefront\Subscriber;
  5. use Acris\ProductBadges\Components\ProductBadges\ProductBadgesService;
  6. use Acris\ProductBadges\Components\ProductBadges\Struct\BadgeLoadingAllowedStruct;
  7. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductEntity;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityCollection;
  9. use Shopware\Core\System\SalesChannel\Entity\SalesChannelEntityLoadedEvent;
  10. use Shopware\Core\System\SalesChannel\Event\SalesChannelProcessCriteriaEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class ProductBadgeSubscriber implements EventSubscriberInterface
  14. {
  15.     public const ACRIS_STREAM_IDS_EXTENSION = 'acrisStreamIds';
  17.     public const CRITERIA_TITLE_BLACKLIST = [
  18.         'cart::products'
  19.     ];
  20.     private ProductBadgesService $productBadgeService;
  22.     public function __construct(ProductBadgesService $productBadgeService)
  23.     {
  24.         $this->productBadgeService = $productBadgeService;
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             'sales_channel.product.process.criteria' => 'onProductCriteriaLoaded',
  31.             'sales_channel.product.loaded' => ['onProductLoaded', -60]
  32.         ];
  33.     }
  35.     public function onProductCriteriaLoaded(SalesChannelProcessCriteriaEvent $event): void
  36.     {
  37.         $criteria = $event->getCriteria();
  39.         if(!empty($criteria->getTitle()) && in_array($criteria->getTitle(), self::CRITERIA_TITLE_BLACKLIST)) {
  40.             $event->getContext()->addExtension(BadgeLoadingAllowedStruct::EXTENSION_KEY, new BadgeLoadingAllowedStruct(false));
  41.             return;
  42.         } else {
  43.             $event->getContext()->addExtension(BadgeLoadingAllowedStruct::EXTENSION_KEY, new BadgeLoadingAllowedStruct(true));
  44.         }
  46.         if($criteria->hasAssociation('streams') === false) {
  47.             $criteria->addAssociation('streams');
  48.         }
  49.     }
  51.     public function onProductLoaded(SalesChannelEntityLoadedEvent $event): void
  52.     {
  53.         if($event->getContext()->hasExtension(BadgeLoadingAllowedStruct::EXTENSION_KEY) && $event->getContext()->getExtension(BadgeLoadingAllowedStruct::EXTENSION_KEY)->isAllowed() !== true) {
  54.             return;
  55.         }
  57.         $productCollection = new EntityCollection();
  58.         foreach ($event->getEntities() as $product) {
  59.             if ($product instanceof SalesChannelProductEntity) {
  60.                 $productCollection->add($product);
  61.             }
  62.         }
  64.         $this->productBadgeService->addBadgesToProducts($productCollection, $event->getSalesChannelContext());
  65.     }
  66. }