vendor/store.shopware.com/h1webblog/src/Blog/Cms/BlogListingCmsElementResolver.php line 112

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace H1web\Blog\Blog\Cms;
  5. use H1web\Blog\Blog\Events\BlogListingResultEvent;
  6. use H1web\Blog\Blog\Listing\BlogListingFeaturesSubscriber;
  7. use H1web\Blog\Blog\Listing\BlogListingGateway;
  8. use H1web\Blog\Blog\Listing\BlogListingResult;
  9. use H1web\Blog\Blog\SalesChannel\BlogAvailableFilter;
  10. use H1web\Blog\Blog\SalesChannel\SalesChannelBlogDefinition;
  11. use H1web\Blog\Blog\Struct\BlogListingStruct;
  12. use Shopware\Core\Content\Cms\Aggregate\CmsSlot\CmsSlotEntity;
  13. use Shopware\Core\Content\Cms\DataResolver\CriteriaCollection;
  14. use Shopware\Core\Content\Cms\DataResolver\Element\AbstractCmsElementResolver;
  15. use Shopware\Core\Content\Cms\DataResolver\Element\ElementDataCollection;
  16. use Shopware\Core\Content\Cms\DataResolver\ResolverContext\ResolverContext;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Search\Aggregation\Bucket\TermsAggregation;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  19. use Shopware\Core\Framework\DataAbstractionLayer\Search\EntitySearchResult;
  20. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  21. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  22. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  24. class BlogListingCmsElementResolver extends AbstractCmsElementResolver
  25. {
  26.     /**
  27.      * @var BlogListingGateway
  28.      */
  29.     private $listingGateway;
  31.     /**
  32.      * @var BlogListingFeaturesSubscriber
  33.      */
  34.     private $listingSubscriber;
  36.     /**
  37.      * @var EventDispatcherInterface
  38.      */
  39.     private $dispatcher;
  41.     public function __construct(BlogListingGateway $listingGateway, BlogListingFeaturesSubscriber $listingSubscriber, EventDispatcherInterface $dispatcher)
  42.     {
  43.         $this->listingGateway = $listingGateway;
  44.         $this->listingSubscriber = $listingSubscriber;
  45.         $this->dispatcher = $dispatcher;
  46.     }
  48.     public function getType(): string
  49.     {
  50.         return 'h1webblog-listing';
  51.     }
  53.     public function collect(CmsSlotEntity $slot, ResolverContext $resolverContext): ?CriteriaCollection
  54.     {
  55.         $config = $slot->getFieldConfig();
  56.         $onlyRecentConfig = $config->get('onlyRecent');
  57.         $filterTagsConfig = $config->get('filterTags');
  59.         if (
  60.             (!$filterTagsConfig || empty($filterTagsConfig->getValue()))
  61.             && (!$onlyRecentConfig || intval($onlyRecentConfig->getValue()) === 0)
  62.         ) {
  63.             return null;
  64.         }
  66.         $criteria = new Criteria();
  67.         $criteria->addFilter(new BlogAvailableFilter($resolverContext->getSalesChannelContext()->getSalesChannelId()))
  68.             ->addAssociation('tags')
  69.             ->addAssociation('properties')
  70.             ->addAssociation('options')
  71.             ->addAssociation('visibilities')
  72.             ->addSorting(new FieldSorting('publishedAt', FieldSorting::DESCENDING));
  74.         $criteria->addAggregation(new TermsAggregation('properties', 'h1webblog_blog.properties.id'));
  75.         $criteria->addAggregation(new TermsAggregation('options', 'h1webblog_blog.options.id'));
  77.         if (intval($onlyRecentConfig->getValue()) !== 0) {
  78.             $criteria->setLimit(intval($onlyRecentConfig->getValue()));
  79.         }
  81.         if (!$criteria->getLimit()) {
  82.             $criteria->setLimit($this->listingSubscriber->getDefaultPageSize());
  83.         }
  85.         if ($filterTagsConfig && !empty($filterTagsConfig->getValue())) {
  86.             $criteria->addFilter(new EqualsAnyFilter('tagIds', $filterTagsConfig->getValue()));
  87.         }
  89.         $criteriaCollection = new CriteriaCollection();
  90.         $criteriaCollection->add('blog_slot_' . $slot->getUniqueIdentifier(), SalesChannelBlogDefinition::class, $criteria);
  92.         return $criteriaCollection;
  93.     }
  95.     public function enrich(CmsSlotEntity $slot, ResolverContext $resolverContext, ElementDataCollection $result): void
  96.     {
  97.         $data = new BlogListingStruct();
  98.         $slot->setData($data);
  100.         /** @var EntitySearchResult|null $searchResult */
  101.         $searchResult = $result->get('blog_slot_' . $slot->getUniqueIdentifier());
  102.         if ($searchResult) {
  103.             $this->dispatchListingEvent($resolverContext, $searchResult);
  104.         }
  106.         $listing = $searchResult ??
  107.             $this->listingGateway->search($resolverContext->getRequest(), $resolverContext->getSalesChannelContext());
  109.         $data->setListing($listing);
  110.     }
  112.     private function dispatchListingEvent(ResolverContext $resolverContext, EntitySearchResult $result): void
  113.     {
  114.         $this->dispatcher->dispatch(
  115.             new BlogListingResultEvent(
  116.                 $resolverContext->getRequest(),
  117.                 BlogListingResult::createFrom($result),
  118.                 $resolverContext->getSalesChannelContext()
  119.             )
  120.         );
  121.     }
  122. }