custom/plugins/System4Configurator/src/Subscriber/ProductSubscriber.php line 53

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace System4Configurator\Subscriber;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  9. use Shopware\Core\Content\Product\ProductEvents;
  10. use Shopware\Core\Content\Product\Events\ProductListingCriteriaEvent;
  11. use Shopware\Core\Content\Product\Events\ProductSearchCriteriaEvent;
  12. use Shopware\Core\Content\Product\Events\ProductSuggestCriteriaEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  14. use Shopware\Storefront\Page\Product\ProductPageCriteriaEvent;
  15. use Shopware\Core\Content\Product\Events\ProductCrossSellingIdsCriteriaEvent;
  16. use Shopware\Core\Content\Product\Events\ProductCrossSellingStreamCriteriaEvent;
  17. use Symfony\Component\HttpFoundation\Session\Session;
  19. class ProductSubscriber implements EventSubscriberInterface
  20. {
  21.     private $session;
  22.     private $sessionId;
  24.     public function __construct(
  25.         Session $session
  26.     ) {
  27.         $this->session = $session;
  28.         $this->sessionId = $this->session->get("productAddSessionId");
  29.     }
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             ProductListingCriteriaEvent::class => 'onProductListingCriteria',
  35.             ProductSearchCriteriaEvent::class => 'onProductListingCriteria',
  36.             ProductPageCriteriaEvent::class => 'onProductCriteriaLoaded',
  37.             ProductEvents::PRODUCT_SUGGEST_CRITERIA => 'productSuggestCriteria',
  38.             ProductCrossSellingStreamCriteriaEvent::class => 'crossSellingProductStreamCriteria',
  39.             ProductCrossSellingIdsCriteriaEvent::class => 'crossSellingProductListCriteria'
  40.         ];
  41.     }
  43.     public function onProductListingCriteria(ProductListingCriteriaEvent $event)
  44.     {
  45.         $this->criteria($event);
  46.     }
  48.     public function onProductCriteriaLoaded(ProductPageCriteriaEvent $event): void
  49.     {
  50.         $this->criteria($event);
  51.     }
  53.     public function crossSellingProductListCriteria(ProductCrossSellingIdsCriteriaEvent $event)
  54.     {
  55.         $this->criteria($event);
  56.     }
  58.     public function crossSellingProductStreamCriteria(ProductCrossSellingStreamCriteriaEvent $event)
  59.     {
  60.         $this->criteria($event);
  61.     }
  63.     public function productSuggestCriteria(ProductSuggestCriteriaEvent $event)
  64.     {
  65.         $this->criteria($event);
  66.     }
  68.     public function getCustomerNumber($event)
  69.     {
  70.         $customer = $event->getSalesChannelContext()->getCustomer();
  71.         $customerNumber = $customer ? $customer->customerNumber : "";
  72.         $customerNumber = trim($customerNumber);
  74.         return $customerNumber;
  75.     }
  77.     public function criteria($event): void
  78.     {
  79.         $customerNumber = $this->getCustomerNumber($event);
  80.         if(!$customerNumber && !$this->sessionId) {
  81.             $event->getCriteria()->addFilter(
  82.                 new MultiFilter(
  83.                     MultiFilter::CONNECTION_AND,
  84.                     [
  85.                         new EqualsFilter('customFields.system4_configurator_customer_number', null),
  86.                         new EqualsFilter('customFields.system4_configurator_session_id', null)
  87.                     ]
  88.                 )
  89.             );
  90.         }
  91.         if($customerNumber && !$this->sessionId) {
  92.             $event->getCriteria()->addFilter(
  93.                 new MultiFilter(
  94.                     MultiFilter::CONNECTION_OR,
  95.                     [
  96.                         new MultiFilter(
  97.                             MultiFilter::CONNECTION_AND,
  98.                             [
  99.                             new EqualsFilter('customFields.system4_configurator_session_id', null),
  100.                             new EqualsFilter('customFields.system4_configurator_customer_number', null)
  101.                         ]
  102.                         ),
  103.                         new EqualsFilter('customFields.system4_configurator_customer_number', $customerNumber)
  104.                     ]
  105.                 )
  106.             );
  107.         }
  108.         if(!$customerNumber && $this->sessionId) {
  109.             $event->getCriteria()->addFilter(
  110.                 new MultiFilter(
  111.                     MultiFilter::CONNECTION_OR,
  112.                     [
  113.                         new MultiFilter(
  114.                             MultiFilter::CONNECTION_AND,
  115.                             [
  116.                                 new EqualsFilter('customFields.system4_configurator_customer_number', null),
  117.                                 new EqualsFilter('customFields.system4_configurator_session_id', null)
  118.                         ]
  119.                         ),
  120.                         new MultiFilter(
  121.                             MultiFilter::CONNECTION_AND,
  122.                             [
  123.                                 new EqualsFilter('customFields.system4_configurator_customer_number', null),
  124.                                 new EqualsFilter('customFields.system4_configurator_session_id', $this->sessionId)
  125.                         ]
  126.                         ),
  127.                     ]
  128.                 )
  129.             );
  130.         }
  131.     }
  133. }