custom/plugins/LeopardSearchExtension/src/Subscriber/AbstractSubscriber.php line 52

Open in your IDE?
  1. <?php /** @noinspection PhpRedundantVariableDocTypeInspection */
  3. /**
  4.  * LeopardSearchExtension
  5.  * Copyright (c) Die Leoparden GmbH
  6.  */
  8. namespace LeopardSearchExtension\Subscriber;
  10. use Shopware\Core\Content\Product\Events\ProductListingCriteriaEvent;
  11. use Shopware\Core\Content\Product\ProductEntity;
  12. use Shopware\Core\Framework\Context;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  17. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  18. use Shopware\Core\System\SystemConfig\SystemConfigService;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. use Symfony\Component\HttpFoundation\Request;
  22. /**
  23.  * Class AbstractSubscriber
  24.  */
  25. abstract class AbstractSubscriber implements EventSubscriberInterface
  26. {
  27.     /**
  28.      * @var SystemConfigService
  29.      */
  30.     private $systemConfigService;
  32.     /**
  33.      * @var EntityRepositoryInterface
  34.      */
  35.     private $productRepository;
  37.     /**
  38.      * AbstractSubscriber constructor.
  39.      *
  40.      * @param SystemConfigService $systemConfigService
  41.      * @param EntityRepositoryInterface $productRepository
  42.      */
  43.     public function __construct(SystemConfigService $systemConfigService, EntityRepositoryInterface $productRepository)
  44.     {
  45.         $this->systemConfigService = $systemConfigService;
  46.         $this->productRepository = $productRepository;
  47.     }
  49.     /**
  50.      * @param ProductListingCriteriaEvent $event
  51.      */
  52.     public function onSearchCriteria(ProductListingCriteriaEvent $event): void
  53.     {
  54.         /** @var array $config */
  55.         $config = $this->getConfig($event->getSalesChannelContext());
  57.         /** @var string[] $searchTerm */
  58.         $filterTargets = $config['filterTargets'];
  59.         if (empty($config['activated']) || empty($filterTargets)) {
  60.             return;
  61.         }
  63.         /** @var Request $request */
  64.         $request = $event->getRequest();
  65.         /** @var string $searchTerm */
  66.         $searchTerm = trim($request->get('search'));
  67.         /** @var ProductEntity|null $productEntity */
  68.         $productEntity = $this->loadProductEntity($filterTargets, $searchTerm, $event->getContext());
  70.         $request->query->set('search', $productEntity ? $productEntity->getProductNumber() : $searchTerm);
  72.         if (!$productEntity instanceof ProductEntity) {
  73.             return;
  74.         }
  76.         $event->getCriteria()->addFilter(
  77.             new EqualsFilter(
  78.                 'productNumber',
  79.                 $productEntity->getProductNumber()
  80.             )
  81.         );
  82.     }
  84.     /**
  85.      * @return SystemConfigService
  86.      */
  87.     protected function getSystemConfigService(): SystemConfigService
  88.     {
  89.         return $this->systemConfigService;
  90.     }
  92.     /**
  93.      * @param SalesChannelContext $salesChannelContext
  94.      *
  95.      * @return array
  96.      */
  97.     protected function getConfig(SalesChannelContext $salesChannelContext): array
  98.     {
  99.         return $this->getSystemConfigService()->get('LeopardSearchExtension.config', $salesChannelContext->getSalesChannel()->getId());
  100.     }
  102.     /**
  103.      * @return EntityRepositoryInterface
  104.      */
  105.     protected function getProductRepository(): EntityRepositoryInterface
  106.     {
  107.         return $this->productRepository;
  108.     }
  110.     /**
  111.      * @param array $filterFields
  112.      * @param string $filterValue
  113.      * @param Context $context
  114.      * @return ProductEntity|null
  115.      */
  116.     protected function loadProductEntity(array $filterFields, string $filterValue, Context $context): ?ProductEntity
  117.     {
  118.         $entitySearchResult = $this->getProductRepository()->search(
  119.             (new Criteria())->addFilter(
  120.                 array_reduce($filterFields, function (MultiFilter $multiFilter, string $field) use ($filterValue) {
  121.                     return $multiFilter->addQuery(new EqualsFilter($field, $filterValue));
  122.                 }, new MultiFilter(MultiFilter::CONNECTION_OR))),
  123.             $context
  124.         );
  126.         if ($entitySearchResult->count() === 1) {
  127.             return $entitySearchResult->first();
  128.         }
  129.         return null;
  130.     }
  131. }