custom/plugins/PickwareErpStarter/src/Stock/ProductAvailableStockUpdater.php line 71

Open in your IDE?
  1. <?php
  2. /*
  3.  * Copyright (c) Pickware GmbH. All rights reserved.
  4.  * This file is part of software that is released under a proprietary license.
  5.  * You must not copy, modify, distribute, make publicly available, or execute
  6.  * its contents or parts thereof without express permission by the copyright
  7.  * holder, unless otherwise permitted by law.
  8.  */
  10. declare(strict_types=1);
  12. namespace Pickware\PickwareErpStarter\Stock;
  14. use Doctrine\DBAL\Connection;
  15. use Pickware\DalBundle\RetryableTransaction;
  16. use Pickware\PickwareErpStarter\Product\PickwareProductInitializer;
  17. use Shopware\Core\Defaults;
  18. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class ProductAvailableStockUpdater implements EventSubscriberInterface
  22. {
  23.     private Connection $db;
  24.     private PickwareProductInitializer $pickwareProductInitializer;
  25.     private EventDispatcherInterface $eventDispatcher;
  27.     public function __construct(
  28.         Connection $db,
  29.         PickwareProductInitializer $pickwareProductInitializer,
  30.         EventDispatcherInterface $eventDispatcher
  31.     ) {
  32.         $this->db = $db;
  33.         $this->pickwareProductInitializer = $pickwareProductInitializer;
  34.         $this->eventDispatcher = $eventDispatcher;
  35.     }
  37.     /**
  38.      * available stock = product stock - reserved stock - stock not available for sale
  39.      *
  40.      * If any of the 3 stock values on the right changes, we need to recalculate the available stock.
  41.      */
  42.     public static function getSubscribedEvents(): array
  43.     {
  44.         return [
  45.             StockUpdatedForStockMovementsEvent::class => 'productStockUpdated',
  46.             ProductReservedStockUpdatedEvent::class => 'productReservedStockUpdated',
  47.             StockNotAvailableForSaleUpdatedEvent::class => 'stockNotAvailableForSaleUpdated',
  48.             StockNotAvailableForSaleUpdatedForAllProductsInWarehousesEvent::class => 'stockNotAvailableForSaleUpdatedForAllProductsInWarehouses',
  49.         ];
  50.     }
  52.     public function productStockUpdated(StockUpdatedForStockMovementsEvent $event): void
  53.     {
  54.         $productIds = array_values(array_map(
  55.             fn (array $stockMovement) => $stockMovement['productId'],
  56.             $event->getStockMovements(),
  57.         ));
  58.         $this->recalculateProductAvailableStock($productIds);
  59.     }
  61.     public function productReservedStockUpdated(ProductReservedStockUpdatedEvent $event): void
  62.     {
  63.         $this->recalculateProductAvailableStock($event->getProductIds());
  64.     }
  66.     public function stockNotAvailableForSaleUpdated(StockNotAvailableForSaleUpdatedEvent $event): void
  67.     {
  68.         $this->recalculateProductAvailableStock($event->getProductIds());
  69.     }
  71.     public function stockNotAvailableForSaleUpdatedForAllProductsInWarehouses(StockNotAvailableForSaleUpdatedForAllProductsInWarehousesEvent $event): void
  72.     {
  73.         if (count($event->getWarehouseIds()) === 0) {
  74.             return;
  75.         }
  77.         $this->db->executeStatement(
  78.             'UPDATE `pickware_erp_warehouse_stock` warehouseStock
  80.             INNER JOIN `product`
  81.             ON `product`.`id` = warehouseStock.`product_id`
  82.             AND `product`.`version_id` = warehouseStock.`product_version_id`
  84.             SET product.`available_stock` = product.`available_stock` + (' . ($event->isStockNotAvailableForSaleIncrease() ? -1 : 1) . ' * warehouseStock.`quantity`)
  86.             WHERE warehouseStock.`warehouse_id` IN (:warehouseIds)
  87.             AND warehouseStock.`quantity` > 0
  88.             AND `product`.`version_id` = :liveVersionId;',
  89.             [
  90.                 'warehouseIds' => array_map('hex2bin', $event->getWarehouseIds()),
  91.                 'liveVersionId' => hex2bin(Defaults::LIVE_VERSION),
  92.             ],
  93.             [
  94.                 'warehouseIds' => Connection::PARAM_STR_ARRAY,
  95.             ],
  96.         );
  97.     }
  99.     public function recalculateProductAvailableStock(array $productIds): void
  100.     {
  101.         if (count($productIds) === 0) {
  102.             return;
  103.         }
  104.         $this->pickwareProductInitializer->ensurePickwareProductsExist($productIds);
  106.         RetryableTransaction::retryable($this->db, function () use ($productIds): void {
  107.             $this->db->executeStatement(
  108.                 'UPDATE `product`
  109.                 LEFT JOIN `pickware_erp_pickware_product` pickwareProduct
  110.                     ON pickwareProduct.`product_id` = `product`.`id`
  111.                     AND pickwareProduct.`product_version_id` = `product`.`version_id`
  112.                 # The available stock can be negative
  113.                 SET `product`.`available_stock` = `product`.`stock` - pickwareProduct.`stock_not_available_for_sale` - pickwareProduct.`reserved_stock`
  114.                 WHERE `product`.`version_id` = :liveVersionId
  115.                   AND `product`.`id` IN (:productIds)',
  116.                 [
  117.                     'liveVersionId' => hex2bin(Defaults::LIVE_VERSION),
  118.                     'productIds' => array_map('hex2bin', $productIds),
  119.                 ],
  120.                 [
  121.                     'productIds' => Connection::PARAM_STR_ARRAY,
  122.                 ],
  123.             );
  124.         });
  126.         $this->eventDispatcher->dispatch(new ProductAvailableStockUpdatedEvent($productIds));
  127.     }
  128. }