custom/plugins/SasBlogModule/src/Content/Blog/Subscriber/BlogSubscriber.php line 28

  1. <?php declare(strict_types=1);
  3. namespace Sas\BlogModule\Content\Blog\Subscriber;
  5. use Sas\BlogModule\Content\Blog\BlogEntriesDefinition;
  6. use Sas\BlogModule\Content\Blog\BlogListingFilterBuildEvent;
  7. use Sas\BlogModule\Content\Blog\Events\BlogMainFilterEvent;
  8. use Shopware\Core\Content\Cms\DataResolver\CriteriaCollection;
  9. use Shopware\Core\Content\Product\SalesChannel\Listing\Filter;
  10. use Shopware\Core\Content\Product\SalesChannel\Listing\FilterCollection;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Aggregation\Bucket\FilterAggregation;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Aggregation\Metric\EntityAggregation;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\RangeFilter;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\HttpFoundation\Request;
  19. class BlogSubscriber implements EventSubscriberInterface
  20. {
  21.     public static function getSubscribedEvents(): array
  22.     {
  23.         return [
  24.             BlogListingFilterBuildEvent::BLOG_MAIN_FILTER_EVENT => 'onBlogMainFilter',
  25.         ];
  26.     }
  28.     public function onBlogMainFilter(BlogMainFilterEvent $event): void
  29.     {
  30.         $dateTime = new \DateTime();
  32.         $criteria = $event->getCriteria();
  33.         $criteria->addFilter(
  34.             new EqualsFilter('active', true),
  35.             new RangeFilter('publishedAt', [RangeFilter::LTE => $dateTime->format(\DATE_ATOM)])
  36.         );
  38.         $criteriaCollection = new CriteriaCollection();
  39.         $criteriaCollection->add(
  40.             'sas_blog',
  41.             BlogEntriesDefinition::class,
  42.             $criteria
  43.         );
  45.         $request = $event->getRequest();
  47.         $filters = $this->getFilters($request);
  48.         $aggregations = $this->getAggregations($request, $filters);
  50.         foreach ($aggregations as $aggregation) {
  51.             $criteria->addAggregation($aggregation);
  52.         }
  54.         foreach ($filters as $filter) {
  55.             if ($filter->isFiltered()) {
  56.                 $criteria->addPostFilter($filter->getFilter());
  57.             }
  58.         }
  60.         $criteria->addExtension('filters', $filters);
  61.     }
  63.     private function getAggregations(Request $request, FilterCollection $filters): array
  64.     {
  65.         $aggregations = [];
  67.         if ($request->get('reduce-aggregations', null) === null) {
  68.             foreach ($filters as $filter) {
  69.                 $aggregations = array_merge($aggregations, $filter->getAggregations());
  70.             }
  72.             return $aggregations;
  73.         }
  75.         foreach ($filters as $filter) {
  76.             $excluded = $filters->filtered();
  78.             if ($filter->exclude()) {
  79.                 $excluded = $excluded->blacklist($filter->getName());
  80.             }
  82.             foreach ($filter->getAggregations() as $aggregation) {
  83.                 if ($aggregation instanceof FilterAggregation) {
  84.                     $aggregation->addFilters($excluded->getFilters());
  86.                     $aggregations[] = $aggregation;
  88.                     continue;
  89.                 }
  91.                 $aggregation = new FilterAggregation(
  92.                     $aggregation->getName() . '-filtered',
  93.                     $aggregation,
  94.                     $excluded->getFilters()
  95.                 );
  97.                 $aggregations[] = $aggregation;
  98.             }
  99.         }
  101.         return $aggregations;
  102.     }
  104.     private function getFilters(Request $request): FilterCollection
  105.     {
  106.         $filters = new FilterCollection();
  107.         $filters->add($this->getCategoriesFilter($request));
  108.         $filters->add($this->getAuthorsFilter($request));
  110.         return $filters;
  111.     }
  113.     private function getCategoriesFilter(Request $request): Filter
  114.     {
  115.         $ids = $this->getFilterByCustomIds('categories', $request);
  117.         return new Filter(
  118.             'categories',
  119.             !empty($ids),
  120.             [
  121.                 new EntityAggregation('blogCategories', 'blogCategories.id', 'sas_blog_category'),
  122.             ],
  123.             new EqualsAnyFilter('blogCategories.id', $ids),
  124.             $ids
  125.         );
  126.     }
  128.     private function getAuthorsFilter(Request $request): Filter
  129.     {
  130.         $ids = $this->getFilterByCustomIds('authors', $request);
  132.         return new Filter(
  133.             'authors',
  134.             !empty($ids),
  135.             [
  136.                 new EntityAggregation('authors', 'authorId', 'sas_blog_author'),
  137.             ],
  138.             new EqualsAnyFilter('authorId', $ids),
  139.             $ids
  140.         );
  141.     }
  143.     private function getFilterByCustomIds(string $input, Request $request): array
  144.     {
  145.         $ids = $request->query->get($input, '');
  147.         if ($request->isMethod(Request::METHOD_POST)) {
  148.             $ids = $request->request->get($input, '');
  149.         }
  151.         if (!\is_string($ids)) {
  152.             return [];
  153.         }
  155.         $ids = explode('|', $ids);
  157.         return array_filter($ids);
  158.     }
  159. }