custom/plugins/NrbnSenertec/src/Subscriber/SearchSubscriber.php line 32

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace NrbnSenertec\Subscriber;
  5. use Shopware\Core\Content\Product\Events\ProductSearchCriteriaEvent;
  6. use Shopware\Core\Content\Product\Events\ProductSuggestCriteriaEvent;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Query\ScoreQuery;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class SearchSubscriber implements EventSubscriberInterface{
  14.     /**
  15.      * @var EntityRepository
  16.      */
  17.     protected EntityRepository              $nrbnSearchKeywordRepository;
  19.     public function __construct(
  20.         EntityRepository                     $nrbnSearchKeywordRepository
  21.     ){
  22.         $this->nrbnSearchKeywordRepository = $nrbnSearchKeywordRepository;
  23.     }
  25.     public static function getSubscribedEvents(): array {
  26.         return [
  27.             ProductSearchCriteriaEvent::class => 'searchCriteria',
  28.             ProductSuggestCriteriaEvent::class => 'suggestCriteria'
  29.         ];
  30.     }
  31.     
  32.     public function searchCriteria(ProductSearchCriteriaEvent $event) {
  33.         if(!$event->getSalesChannelContext()->getCustomer()){
  34.             $event->getCriteria()->setLimit(0);
  35.             return;
  36.         }
  38.         if(!$event->getRequest()->query->get("advanced")){
  39.             return;
  40.         }
  42.         return $this->createAdvancedCriteria($event);
  43.     }
  45.     public function suggestCriteria(ProductSuggestCriteriaEvent $event) {
  46.         if(!$event->getSalesChannelContext()->getCustomer()){
  47.             $event->getCriteria()->setLimit(0);
  48.             return;
  49.         }
  51.         if(!$event->getRequest()->query->get("advanced")){
  52.             return;
  53.         }
  55.         return $this->createAdvancedCriteria($event);
  56.     }
  58.     /**
  59.      * @param $event
  60.      * @return mixed
  61.      */
  62.     private function createAdvancedCriteria($event)
  63.     {
  64.         $criteria = $event->getCriteria();
  65.         $productFilters = $criteria->getFilters()[0];
  66.         $searchKeywordFilters = $criteria->getFilters()[1];
  68.         $queries = $criteria->getQueries();
  70.         $criteria->resetFilters();
  71.         $criteria->addFilter($productFilters);
  73.         foreach ($searchKeywordFilters->getQueries() as $filter){
  74.             $values = $filter->getValue();
  75.             $field = str_replace("searchKeywords", "nrbnSearchKeywords", $filter->getField());
  77.             $newFilter = null;
  79.             if($filter instanceof EqualsAnyFilter){
  80.                 $newFilter = new EqualsAnyFilter($field, $values);
  81.             } elseif ($filter instanceof EqualsFilter) {
  82.                 $newFilter = new EqualsFilter($field, $values);
  83.             }
  85.             if($newFilter){
  86.                 $criteria->addFilter($newFilter);
  87.             }
  88.         }
  90.         $criteria->resetQueries();
  92.         foreach ($queries as $query){
  93.             $scoreField = "product.nrbnSearchKeywords.ranking";
  94.             $value = $query->getQuery()->getValue();
  95.             $field = str_replace("searchKeywords", "nrbnSearchKeywords", $query->getQuery()->getField());
  96.             $filter = new EqualsFilter($field, $value);
  98.             $newScoreQuery = new ScoreQuery($filter, $query->getScore(), $scoreField);
  100.             $criteria->addQuery($newScoreQuery);
  101.         }
  103.         return $event;
  104.     }
  105. }