custom/plugins/SwagCommercial/src/MultiWarehouse/Subscriber/ProductLoadedSubscriber.php line 39

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Commercial\MultiWarehouse\Subscriber;
  5. use Shopware\Commercial\Licensing\License;
  6. use Shopware\Commercial\MultiWarehouse\Domain\Product\StockLoader;
  7. use Shopware\Core\Content\Product\AbstractProductMaxPurchaseCalculator;
  8. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductEntity;
  9. use Shopware\Core\System\SalesChannel\Entity\SalesChannelEntityLoadedEvent;
  10. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. /**
  14.  * @internal
  15.  *
  16.  * @package inventory
  17.  */
  18. class ProductLoadedSubscriber implements EventSubscriberInterface
  19. {
  20.     private StockLoader $stockLoader;
  22.     private AbstractProductMaxPurchaseCalculator $maxPurchaseCalculator;
  24.     public function __construct(
  25.         StockLoader $stockLoader,
  26.         AbstractProductMaxPurchaseCalculator $maxPurchaseCalculator
  27.     ) {
  28.         $this->stockLoader = $stockLoader;
  29.         $this->maxPurchaseCalculator = $maxPurchaseCalculator;
  30.     }
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             'sales_channel.product.loaded' => 'onProductLoaded',
  36.         ];
  37.     }
  39.     public function onProductLoaded(SalesChannelEntityLoadedEvent $event): void
  40.     {
  41.         if (!License::get('MULTI_INVENTORY-3749997')) {
  42.             return;
  43.         }
  45.         $products = $this->getCloseoutProducts($event);
  47.         if (!$products) {
  48.             return;
  49.         }
  51.         $this->load(
  52.             $products,
  53.             $event,
  54.         );
  55.     }
  57.     /**
  58.      * @param SalesChannelProductEntity[] $products
  59.      */
  60.     private function load(array $products, SalesChannelEntityLoadedEvent $event): void
  61.     {
  62.         $ids = array_column($products, 'id');
  63.         $context = $event->getSalesChannelContext();
  65.         $warehouseStocks = $this->stockLoader->fetchStocks($ids, $context);
  67.         if (!$warehouseStocks) {
  68.             return;
  69.         }
  71.         foreach ($warehouseStocks as $productId => $stock) {
  72.             /** @var SalesChannelProductEntity[] $entities */
  73.             $entities = $event->getEntities();
  74.             $product = $this->getProductById($productId, $entities);
  76.             if (!$stock['assigned']) {
  77.                 $this->blockProduct($product);
  79.                 continue;
  80.             }
  82.             $this->updateProduct($product, $stock['stock'], $context);
  83.         }
  84.     }
  86.     private function updateProduct(
  87.         SalesChannelProductEntity $product,
  88.         int $stock,
  89.         SalesChannelContext $context
  90.     ): void {
  91.         if ($stock <= 0) {
  92.             $this->blockProduct($product);
  94.             return;
  95.         }
  97.         $product->setStock($stock);
  98.         $product->setAvailableStock($stock);
  99.         $product->setCalculatedMaxPurchase($this->maxPurchaseCalculator->calculate($product, $context));
  101.         $available = $stock >= (int) $product->getMinPurchase();
  103.         $product->setAvailable($available);
  104.     }
  106.     /**
  107.      * @return SalesChannelProductEntity[]
  108.      */
  109.     private function getCloseoutProducts(SalesChannelEntityLoadedEvent $event): array
  110.     {
  111.         /** @var SalesChannelProductEntity[] $products */
  112.         $products = $event->getEntities();
  114.         return \array_filter($products, static fn (SalesChannelProductEntity $product) => $product->getIsCloseout());
  115.     }
  117.     /**
  118.      * @param SalesChannelProductEntity[] $products
  119.      */
  120.     private function getProductById(string $id, array $products): SalesChannelProductEntity
  121.     {
  122.         foreach ($products as $product) {
  123.             if ($product->getId() !== $id) {
  124.                 continue;
  125.             }
  127.             return $product;
  128.         }
  130.         throw new \LogicException('Product with given id not found');
  131.     }
  133.     private function blockProduct(SalesChannelProductEntity $product): void
  134.     {
  135.         $product->setAvailableStock(0);
  136.         $product->setAvailable(false);
  137.         $product->setCalculatedMaxPurchase(0);
  138.     }
  139. }