src/Core/Content/Product/SalesChannel/Listing/ProductListingRoute.php line 38

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Product\SalesChannel\Listing;
  5. use Shopware\Core\Content\Category\CategoryDefinition;
  6. use Shopware\Core\Content\Category\CategoryEntity;
  7. use Shopware\Core\Content\Product\Aggregate\ProductVisibility\ProductVisibilityDefinition;
  8. use Shopware\Core\Content\Product\Events\ProductListingResultEvent;
  9. use Shopware\Core\Content\Product\SalesChannel\ProductAvailableFilter;
  10. use Shopware\Core\Content\ProductStream\Service\ProductStreamBuilderInterface;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  14. use Shopware\Core\Framework\Log\Package;
  15. use Shopware\Core\Framework\Plugin\Exception\DecorationPatternException;
  16. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  17. use Symfony\Component\HttpFoundation\Request;
  18. use Symfony\Component\Routing\Annotation\Route;
  19. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  21. #[Route(defaults: ['_routeScope' => ['store-api']])]
  22. #[Package('inventory')]
  23. class ProductListingRoute extends AbstractProductListingRoute
  24. {
  25.     /**
  26.      * @internal
  27.      */
  28.     public function __construct(private readonly ProductListingLoader $listingLoader, private readonly EventDispatcherInterface $eventDispatcher, private readonly EntityRepository $categoryRepository, private readonly ProductStreamBuilderInterface $productStreamBuilder)
  29.     {
  30.     }
  32.     public function getDecorated(): AbstractProductListingRoute
  33.     {
  34.         throw new DecorationPatternException(self::class);
  35.     }
  37.     #[Route(path: '/store-api/product-listing/{categoryId}', name: 'store-api.product.listing', methods: ['POST'], defaults: ['_entity' => 'product'])]
  38.     public function load(string $categoryId, Request $request, SalesChannelContext $context, Criteria $criteria): ProductListingRouteResponse
  39.     {
  40.         $criteria->addFilter(
  41.             new ProductAvailableFilter($context->getSalesChannel()->getId(), ProductVisibilityDefinition::VISIBILITY_ALL)
  42.         );
  43.         $criteria->setTitle('product-listing-route::loading');
  45.         $categoryCriteria = new Criteria([$categoryId]);
  46.         $categoryCriteria->setTitle('product-listing-route::category-loading');
  48.         /** @var CategoryEntity $category */
  49.         $category = $this->categoryRepository->search($categoryCriteria, $context->getContext())->first();
  51.         $streamId = $this->extendCriteria($context, $criteria, $category);
  53.         $entities = $this->listingLoader->load($criteria, $context);
  55.         $result = ProductListingResult::createFrom($entities);
  56.         $result->addState(...$entities->getStates());
  58.         $result->addCurrentFilter('navigationId', $categoryId);
  60.         $this->eventDispatcher->dispatch(
  61.             new ProductListingResultEvent($request, $result, $context)
  62.         );
  64.         $result->setStreamId($streamId);
  66.         return new ProductListingRouteResponse($result);
  67.     }
  69.     private function extendCriteria(SalesChannelContext $salesChannelContext, Criteria $criteria, CategoryEntity $category): ?string
  70.     {
  71.         if ($category->getProductAssignmentType() === CategoryDefinition::PRODUCT_ASSIGNMENT_TYPE_PRODUCT_STREAM && $category->getProductStreamId() !== null) {
  72.             $filters = $this->productStreamBuilder->buildFilters(
  73.                 $category->getProductStreamId(),
  74.                 $salesChannelContext->getContext()
  75.             );
  77.             $criteria->addFilter(...$filters);
  79.             return $category->getProductStreamId();
  80.         }
  82.         $criteria->addFilter(
  83.             new EqualsFilter('product.categoriesRo.id', $category->getId())
  84.         );
  86.         return null;
  87.     }
  88. }