custom/plugins/NetzpSearchAdvanced6/src/Subscriber/SearchSubscriber.php line 85

  1. <?php declare(strict_types=1);
  2. namespace NetzpSearchAdvanced6\Subscriber;
  4. use NetzpSearchAdvanced6\Components\SearchInterface;
  5. use NetzpSearchAdvanced6\Core\Content\SearchLog\SearchLogDefinition;
  6. use Shopware\Core\Content\Product\Events\ProductListingCriteriaEvent;
  7. use Shopware\Core\Content\Product\SalesChannel\ProductAvailableFilter;
  8. use Shopware\Core\Framework\Struct\ArrayStruct;
  9. use Shopware\Core\System\SystemConfig\SystemConfigService;
  10. use Shopware\Storefront\Page\PageLoadedEvent;
  11. use Shopware\Storefront\Page\Search\SearchPageLoadedEvent;
  12. use Shopware\Storefront\Page\Suggest\SuggestPageLoadedEvent;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\HttpKernel\Event\RequestEvent;
  16. class SearchSubscriber implements EventSubscriberInterface
  17. {
  18.     public function __construct(private readonly SearchInterface $searchService,
  19.                                 private readonly SystemConfigService $systemConfigService)
  20.     {
  21.     }
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             SearchPageLoadedEvent::class        => 'doSearch',
  27.             SuggestPageLoadedEvent::class       => 'doSearchSuggest',
  28.             RequestEvent::class                 => 'onKernelRequest',
  29.             ProductListingCriteriaEvent::class  => 'loadProductListingCriteria',
  30.         ];
  31.     }
  33.     public function onKernelRequest(RequestEvent $event)
  34.     {
  35.         $salesChannelId = $event->getRequest()->attributes->get('sw-sales-channel-id') ?? null;
  36.         $pluginConfig = $this->systemConfigService->get('NetzpSearchAdvanced6.config', $salesChannelId);
  37.         $useSynonyms = (bool)$pluginConfig['useSynonyms'];
  39.         $request = $event->getRequest();
  40.         if(! $useSynonyms || ! $request->query->has('search')) {
  41.             return;
  42.         }
  44.         $query = $this->searchService->replaceSynonyms($request->query->get('search'));
  45.         $request->query->set('search', $query);
  46.     }
  48.     public function doSearch(PageLoadedEvent $event)
  49.     {
  50.         $pluginConfig = $this->systemConfigService->get(
  51.             'NetzpSearchAdvanced6.config',
  52.             $event->getSalesChannelContext()->getSalesChannelId() ?? null
  53.         );
  54.         $logQueries = array_key_exists('logQueries', $pluginConfig) ? $pluginConfig['logQueries'] : 0;
  56.         $query = $event->getPage()->getSearchTerm();
  57.         $searchResults = $this->searchService->doSearch($query, $event->getSalesChannelContext());
  59.         if($logQueries == 1 || $logQueries == 2)
  60.         {
  61.             $this->searchService->logQuery($query, $event, $searchResults, SearchLogDefinition::ORIGIN_SEARCH);
  62.         }
  64.         $firstTabWithResults = '';
  65.         if($event->getPage()->getListing()->getTotal() == 0)
  66.         {
  67.             foreach($searchResults as $searchCategory => $searchCategoryResults)
  68.             {
  69.                 if(($searchCategoryResults['total'] ?? 0) > 0)
  70.                 {
  71.                     $firstTabWithResults = $searchCategory;
  72.                     break;
  73.                 }
  74.             }
  75.         }
  77.         if($firstTabWithResults != '')
  78.         {
  79.             $event->getRequest()->attributes->set('tab', $firstTabWithResults);
  80.         }
  82.         $event->getPage()->addExtension('netzpSearch', new ArrayStruct($searchResults));
  83.     }
  85.     public function doSearchSuggest(SuggestPageLoadedEvent $event)
  86.     {
  87.         $pluginConfig = $this->systemConfigService->get(
  88.             'NetzpSearchAdvanced6.config',
  89.             $event->getSalesChannelContext()->getSalesChannelId() ?? null
  90.         );
  91.         $logQueries = array_key_exists('logQueries', $pluginConfig) ? $pluginConfig['logQueries'] : 0;
  93.         $query = $event->getPage()->getSearchTerm();
  94.         $searchResults = $this->searchService->doSearch($query, $event->getSalesChannelContext(), true);
  96.         if($logQueries == 2) {
  97.             $this->searchService->logQuery($query, $event, $searchResults, SearchLogDefinition::ORIGIN_AJAX);
  98.         }
  100.         $firstTabWithResults = '';
  101.         if($event->getPage()->getSearchResult()->getTotal() == 0)
  102.         {
  103.             foreach($searchResults as $searchCategory => $searchCategoryResults)
  104.             {
  105.                 if(($searchCategoryResults['total'] ?? 0) > 0)
  106.                 {
  107.                     $firstTabWithResults = $searchCategory;
  108.                     break;
  109.                 }
  110.             }
  111.         }
  113.         if($firstTabWithResults != '')
  114.         {
  115.             $event->getRequest()->attributes->set('tab', $firstTabWithResults);
  116.         }
  118.         $event->getPage()->addExtension('netzpSearch', new ArrayStruct($searchResults));
  119.     }
  121.     public function loadProductListingCriteria(ProductListingCriteriaEvent $event): void
  122.     {
  123.         $pluginConfig = $this->systemConfigService->get(
  124.             'NetzpSearchAdvanced6.config',
  125.             $event->getSalesChannelContext()->getSalesChannelId() ?? null
  126.         );
  127.         $manufacturerCmsPage = $pluginConfig['searchManufacturerCmsPage'] ?? '';
  129.         if($manufacturerCmsPage != "" &&
  130.             $event->getRequest()->attributes->get('navigationId', '') == $manufacturerCmsPage)
  131.         {
  132.             $event->getCriteria()->resetFilters();
  133.             $event->getCriteria()->addFilter(new ProductAvailableFilter($event->getSalesChannelContext()->getSalesChannel()->getId()));
  134.         }
  135.     }
  136. }