custom/plugins/NetzpBlog6/src/Subscriber/FrontendSubscriber.php line 39

  1. <?php declare(strict_types=1);
  3. namespace NetzpBlog6\Subscriber;
  5. use NetzpBlog6\Core\SearchResult;
  6. use NetzpBlog6\Helper\BlogHelper;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\ContainsFilter;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  11. use Shopware\Core\Framework\Struct\ArrayStruct;
  12. use Shopware\Core\Framework\Struct\StructCollection;
  13. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  14. use Shopware\Core\System\SystemConfig\SystemConfigService;
  15. use Shopware\Storefront\Page\Product\ProductPageCriteriaEvent;
  16. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\DependencyInjection\ContainerInterface;
  19. use Symfony\Contracts\EventDispatcher\Event;
  21. class FrontendSubscriber implements EventSubscriberInterface
  22. {
  23.     final public const SEARCH_TYPE_BLOG = 10;
  25.     public function __construct(private readonly ContainerInterface $container,
  26.                                 private readonly SystemConfigService $config,
  27.                                 private readonly BlogHelper $helper) {
  28.     }
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             ProductPageCriteriaEvent::class    => 'onProductCriteriaLoaded',
  34.             ProductPageLoadedEvent::class      => 'loadProductPage',
  35.             'netzp.search.register'            => 'registerSearchProvider'
  36.         ];
  37.     }
  39.     public function onProductCriteriaLoaded(ProductPageCriteriaEvent $event): void
  40.     {
  41.         $this->addBlogCriteria($event->getCriteria(), $event->getSalesChannelContext()->getSalesChannelId());
  42.     }
  44.     private function addBlogCriteria(Criteria $criteria, string $salesChannelId)
  45.     {
  46.         $criteria->addAssociation('blogs');
  47.         $blogAssociation = $criteria->getAssociation('blogs');
  48.         $blogAssociation->addAssociation('tags');
  49.         $blogAssociation->addAssociation('items');
  50.         $blogAssociation->addAssociation('blogmedia');
  52.         $this->helper->addBlogDateFilterAndSorting($blogAssociation, true);
  54.         $blogAssociation->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, [
  55.             new EqualsFilter('category.saleschannelid', null),
  56.             new EqualsFilter('category.saleschannelid', '00000000000000000000000000000000'),
  57.             new EqualsFilter('category.saleschannelid', $salesChannelId),
  58.         ]));
  59.     }
  61.     public function loadProductPage(ProductPageLoadedEvent $event): void
  62.     {
  63.         $product = $event->getPage()->getProduct();
  64.         $productBlogs = $product->getExtension('blogs');
  65.         $parentId = $product->getParentId();
  67.         if($parentId) {
  68.             $repo = $this->container->get('product.repository');
  69.             $criteria = new Criteria([$parentId]);
  70.             $this->addBlogCriteria($criteria, $event->getSalesChannelContext()->getSalesChannelId());
  71.             $parentProduct = $repo->search($criteria, $event->getContext())->getEntities()->first();
  72.             $parentBlogs = $parentProduct->getExtension('blogs');
  74.             if($parentBlogs->count() > 0) {
  75.                 $product->addExtension('blogs',
  76.                     new StructCollection(array_merge($parentBlogs->getElements(), $productBlogs->getElements()))
  77.                 );
  78.             }
  79.         }
  81.         $event->getPage()->assign([
  82.             'netzp_blogposts' => []
  83.         ]);
  84.     }
  86.     public function registerSearchProvider(Event $event)
  87.     {
  88.         $pluginConfig = $this->config->get('NetzpBlog6.config');
  89.         if((bool)$pluginConfig['searchBlog'] === false) {
  90.             return;
  91.         }
  93.         $event->setData([
  94.             'key'      => 'blog',
  95.             'label'    => 'netzp.blog.searchLabel',
  96.             'function' => [$this, 'doSearch']
  97.         ]);
  98.     }
  100.     public function doSearch(string $query, SalesChannelContext $salesChannelContext, bool $isSuggest = false): array
  101.     {
  102.         $results = [];
  103.         $blogEntries = $this->getBlogEntries($query, $salesChannelContext, $isSuggest);
  105.         foreach ($blogEntries->getEntities() as $blogEntry)
  106.         {
  107.             $tmpResult = new SearchResult();
  108.             $tmpResult->setType(static::SEARCH_TYPE_BLOG);
  109.             $tmpResult->setId($blogEntry->getId());
  110.             $tmpResult->setTitle($blogEntry->getTranslated()['title'] ?? '');
  111.             $tmpResult->setDescription($blogEntry->getTranslated()['teaser'] ?? '');
  113.             if($blogEntry->getImagepreview()) {
  114.                 $tmpResult->setMedia($blogEntry->getImagepreview());
  115.             }
  116.             else if($blogEntry->getImage()) {
  117.                 $tmpResult->setMedia($blogEntry->getImage());
  118.             }
  119.             $tmpResult->setTotal($blogEntries->getTotal());
  120.             $tmpResult->addExtension('slug', new ArrayStruct(['value' => $blogEntry->getTranslated()['slug'] ?? '']));
  121.             $results[] = $tmpResult;
  122.         }
  124.         return $results;
  125.     }
  127.     private function getBlogEntries($query, SalesChannelContext $salesChannelContext, bool $isSuggest = false)
  128.     {
  129.         $words = $this->explodeSearchQuery($query);
  131.         if (count($words) > 0)
  132.         {
  133.             $repo = $this->container->get('s_plugin_netzp_blog.repository');
  134.             $criteria = new Criteria();
  135.             $criteria->addAssociation('category');
  136.             $criteria->addAssociation('image');
  137.             $criteria->addAssociation('imagepreview');
  139.             $this->helper->addBlogDateFilterAndSorting($criteria, true);
  140.             $this->helper->addRestrictionsFilter($criteria, $salesChannelContext);
  142.             if($isSuggest) {
  143.                 $criteria->setLimit(10);
  144.                 $criteria->setTotalCountMode(Criteria::TOTAL_COUNT_MODE_EXACT);
  145.             }
  147.             $filter = [];
  148.             foreach ($words as $word) {
  149.                 $filter[] = new ContainsFilter('title', $word);
  150.                 $filter[] = new ContainsFilter('teaser', $word);
  151.                 $filter[] = new ContainsFilter('contents', $word);
  152.             }
  153.             $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, $filter));
  155.             return $repo->search($criteria, $salesChannelContext->getContext());
  156.         }
  158.         return null;
  159.     }
  161.     private function explodeSearchQuery(string $query): array
  162.     {
  163.         $query = trim((string)$query);
  164.         if(str_starts_with($query, '"') && str_ends_with($query, '"'))
  165.         {
  166.             return [ trim($query, '"') ];
  167.         }
  169.         return explode(' ', $query);
  170.     }
  171. }