vendor/shopware/core/Content/Product/SalesChannel/Listing/ProductListingRoute.php line 75

Open in your IDE?
  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\EntityRepositoryInterface;
  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\Framework\Routing\Annotation\Entity;
  17. use Shopware\Core\Framework\Routing\Annotation\RouteScope;
  18. use Shopware\Core\Framework\Routing\Annotation\Since;
  19. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  20. use Symfony\Component\HttpFoundation\Request;
  21. use Symfony\Component\Routing\Annotation\Route;
  22. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  24. /**
  25.  * @Route(defaults={"_routeScope"={"store-api"}})
  26.  */
  27. #[Package('inventory')]
  28. class ProductListingRoute extends AbstractProductListingRoute
  29. {
  30.     /**
  31.      * @var ProductListingLoader
  32.      */
  33.     private $listingLoader;
  35.     /**
  36.      * @var EventDispatcherInterface
  37.      */
  38.     private $eventDispatcher;
  40.     /**
  41.      * @var EntityRepositoryInterface
  42.      */
  43.     private $categoryRepository;
  45.     /**
  46.      * @var ProductStreamBuilderInterface
  47.      */
  48.     private $productStreamBuilder;
  50.     /**
  51.      * @internal
  52.      */
  53.     public function __construct(
  54.         ProductListingLoader $listingLoader,
  55.         EventDispatcherInterface $eventDispatcher,
  56.         EntityRepositoryInterface $categoryRepository,
  57.         ProductStreamBuilderInterface $productStreamBuilder
  58.     ) {
  59.         $this->eventDispatcher = $eventDispatcher;
  60.         $this->listingLoader = $listingLoader;
  61.         $this->categoryRepository = $categoryRepository;
  62.         $this->productStreamBuilder = $productStreamBuilder;
  63.     }
  65.     public function getDecorated(): AbstractProductListingRoute
  66.     {
  67.         throw new DecorationPatternException(self::class);
  68.     }
  70.     /**
  71.      * @Since("6.2.0.0")
  72.      * @Entity("product")
  73.      * @Route("/store-api/product-listing/{categoryId}", name="store-api.product.listing", methods={"POST"})
  74.      */
  75.     public function load(string $categoryId, Request $request, SalesChannelContext $context, Criteria $criteria): ProductListingRouteResponse
  76.     {
  77.         $criteria->addFilter(
  78.             new ProductAvailableFilter($context->getSalesChannel()->getId(), ProductVisibilityDefinition::VISIBILITY_ALL)
  79.         );
  80.         $criteria->setTitle('product-listing-route::loading');
  82.         $categoryCriteria = new Criteria([$categoryId]);
  83.         $categoryCriteria->setTitle('product-listing-route::category-loading');
  85.         /** @var CategoryEntity $category */
  86.         $category = $this->categoryRepository->search($categoryCriteria, $context->getContext())->first();
  88.         $streamId = $this->extendCriteria($context, $criteria, $category);
  90.         $entities = $this->listingLoader->load($criteria, $context);
  92.         /** @var ProductListingResult $result */
  93.         $result = ProductListingResult::createFrom($entities);
  94.         $result->addState(...$entities->getStates());
  96.         $result->addCurrentFilter('navigationId', $categoryId);
  98.         $this->eventDispatcher->dispatch(
  99.             new ProductListingResultEvent($request, $result, $context)
  100.         );
  102.         $result->setStreamId($streamId);
  104.         return new ProductListingRouteResponse($result);
  105.     }
  107.     private function extendCriteria(SalesChannelContext $salesChannelContext, Criteria $criteria, CategoryEntity $category): ?string
  108.     {
  109.         if ($category->getProductAssignmentType() === CategoryDefinition::PRODUCT_ASSIGNMENT_TYPE_PRODUCT_STREAM && $category->getProductStreamId() !== null) {
  110.             $filters = $this->productStreamBuilder->buildFilters(
  111.                 $category->getProductStreamId(),
  112.                 $salesChannelContext->getContext()
  113.             );
  115.             $criteria->addFilter(...$filters);
  117.             return $category->getProductStreamId();
  118.         }
  120.         $criteria->addFilter(
  121.             new EqualsFilter('product.categoriesRo.id', $category->getId())
  122.         );
  124.         return null;
  125.     }
  126. }