custom/plugins/AcrisCustomerGroupAvailableProductCS/src/Storefront/Subscriber/ProductListingFeaturesSubscriber.php line 69

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\CustomerGroupAvailableProduct\Storefront\Subscriber;
  5. use Acris\CustomerGroupAvailableProduct\Components\DisplayAllowedProductService;
  6. use Shopware\Core\Content\Product\Events\ProductCrossSellingIdsCriteriaEvent;
  7. use Shopware\Core\Content\Product\Events\ProductCrossSellingStreamCriteriaEvent;
  8. use Shopware\Core\Content\Product\Events\ProductListingCriteriaEvent;
  9. use Shopware\Core\Content\Product\Events\ProductSearchCriteriaEvent;
  10. use Shopware\Core\Content\Product\Events\ProductSuggestCriteriaEvent;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  15. use Shopware\Core\Framework\Uuid\Uuid;
  16. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  17. use Shopware\Core\System\SystemConfig\SystemConfigService;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. class ProductListingFeaturesSubscriber implements EventSubscriberInterface
  21. {
  22.     /**
  23.      * @var DisplayAllowedProductService
  24.      */
  25.     private $displayProductService;
  27.     /**
  28.      * @var SystemConfigService
  29.      */
  30.     private $configService;
  32.     public function __construct(DisplayAllowedProductService $displayProductService, SystemConfigService $configService)
  33.     {
  34.         $this->displayProductService = $displayProductService;
  35.         $this->configService = $configService;
  36.     }
  38.     public static function getSubscribedEvents()
  39.     {
  40.         return [
  41.             ProductListingCriteriaEvent::class => [
  42.                 ['handleListingRequest', 200]
  43.             ],
  44.             ProductSuggestCriteriaEvent::class => [
  45.                 ['handleSearchRequest', 200]
  46.             ],
  47.             ProductSearchCriteriaEvent::class => [
  48.                 ['handleSearchRequest', 200]
  49.             ],
  50.             ProductCrossSellingIdsCriteriaEvent::class => [
  51.                 ['handleCrossSellingProductListingRequest', 200]
  52.             ],
  53.             ProductCrossSellingStreamCriteriaEvent::class => [
  54.                 ['handleCrossSellingProductStreamRequest', 200]
  55.             ]
  56.         ];
  57.     }
  59.     public function handleCrossSellingProductStreamRequest(ProductCrossSellingStreamCriteriaEvent $event): void
  60.     {
  61.         $this->addDisplayProductIdsForCriteria($event->getCriteria(), $event->getSalesChannelContext());
  62.     }
  64.     public function handleCrossSellingProductListingRequest(ProductCrossSellingIdsCriteriaEvent $event): void
  65.     {
  66.         $this->addDisplayProductIdsForCriteria($event->getCriteria(), $event->getSalesChannelContext());
  67.     }
  69.     public function handleListingRequest(ProductListingCriteriaEvent $event): void
  70.     {
  71.         $this->addDisplayProductIdsForCriteria($event->getCriteria(), $event->getSalesChannelContext());
  72.     }
  74.     public function handleSearchRequest(ProductListingCriteriaEvent $event): void
  75.     {
  76.         $this->addDisplayProductIdsForCriteria($event->getCriteria(), $event->getSalesChannelContext());
  77.     }
  79.     private function addDisplayProductIdsForCriteria(Criteria $criteria, SalesChannelContext $salesChannelContext)
  80.     {
  82.         $displayProductIds = $this->displayProductService->getDisplayProductIdsForCustomerGroupId($salesChannelContext->getCurrentCustomerGroup()->getId(), $salesChannelContext->getContext());
  83.         if(empty($displayProductIds) === true) {
  84.             if($this->configService->get('AcrisCustomerGroupAvailableProductCS.config.releaseProductsIfNoCustomerGroupAssigned', $salesChannelContext->getSalesChannel()->getId()) === DisplayAllowedProductService::DEFAULT_PLUGIN_CONFIG_RELEASE_PRODUCT_IF_NO_CUSTOMER_GROUPS_ASSIGNED) {
  85.                 $criteria->addAssociation('product.customerGroup');
  87.                 $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, [
  88.                     new EqualsFilter('id', Uuid::randomHex()),
  89.                     new EqualsFilter('product.customerGroup.id', null),
  90.                 ]));
  91.                 return;
  92.             }
  93.             $criteria->addFilter(new EqualsFilter('id', Uuid::randomHex()));
  94.         } else {
  95.             $criteria->addFilter(new EqualsAnyFilter('id', $displayProductIds));
  96.         }
  97.     }
  98. }