custom/plugins/SisiBlog6/src/Storefront/Page/Blog/Products/ProductsLoader.php line 41

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Sisi\Blog6\Storefront\Page\Blog\Products;
  7. use Shopware\Core\Content\Product\Aggregate\ProductVisibility\ProductVisibilityDefinition;
  8. use Shopware\Core\Content\Product\ProductCollection;
  9. use Shopware\Core\Content\Product\SalesChannel\ProductAvailableFilter;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\NotFilter;
  13. use Shopware\Core\System\SalesChannel\Entity\SalesChannelRepositoryInterface;
  14. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  15. use Shopware\Core\System\SystemConfig\SystemConfigService;
  17. class ProductsLoader
  18. {
  19.     /**
  20.      * @var SalesChannelRepositoryInterface
  21.      */
  22.     private $productRepository;
  24.     /**
  25.      * @var SystemConfigService
  26.      */
  27.     private $systemConfigService;
  29.     public function __construct(
  30.         SalesChannelRepositoryInterface $productRepository,
  31.         SystemConfigService $systemConfigService
  32.     ) {
  33.         $this->productRepository = $productRepository;
  34.         $this->systemConfigService = $systemConfigService;
  35.     }
  37.     /**
  38.      * @param ProductCollection<\Shopware\Core\Content\Product\ProductEntity>|null $products
  39.      * @return ProductCollection<\Shopware\Core\Content\Product\ProductEntity>|null
  40.      */
  41.     public function load(?ProductCollection $products, SalesChannelContext $context): ?ProductCollection
  42.     {
  43.         $productsList = new ProductCollection();
  45.         if ($products) {
  46.             $assignedProductsIds = $products->getIds();
  48.             $filter = new ProductAvailableFilter(
  49.                 $context->getSalesChannel()->getId(),
  50.                 ProductVisibilityDefinition::VISIBILITY_LINK
  51.             );
  53.             $criteria = new Criteria($assignedProductsIds);
  54.             $criteria->addAssociation('visibilities');
  55.             $criteria->addFilter($filter);
  57.             if (!count($assignedProductsIds)) {
  58.                 return null;
  59.             }
  61.             $criteria = $this->handleAvailableStock($criteria, $context);
  63.             /**
  64.              * @var ProductCollection<\Shopware\Core\Content\Product\ProductEntity>|null $searchResult
  65.              */
  66.             $searchResult = $this->productRepository->search($criteria, $context);
  68.             foreach ($products->getElements() as $element) {
  69.                 if ($searchResult->has($element->getId())) {
  70.                     $productsList->add($searchResult->get($element->getId()));
  71.                 }
  72.             }
  73.         }
  75.         return $productsList;
  76.     }
  78.     private function handleAvailableStock(Criteria $criteria, SalesChannelContext $context): Criteria
  79.     {
  80.         $salesChannelId = $context->getSalesChannel()->getId();
  81.         $hide = $this->systemConfigService->get('core.listing.hideCloseoutProductsWhenOutOfStock', $salesChannelId);
  83.         if (!$hide) {
  84.             return $criteria;
  85.         }
  87.         $criteria->addFilter(
  88.             new NotFilter(
  89.                 NotFilter::CONNECTION_AND,
  90.                 [
  91.                     new EqualsFilter('product.isCloseout', true),
  92.                     new EqualsFilter('product.available', false),
  93.                 ]
  94.             )
  95.         );
  97.         return $criteria;
  98.     }
  99. }