custom/plugins/PickwareErpStarter/src/Stock/WarehouseStockUpdater.php line 38

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\PickwareErpStarter\Stock\Model\StockMovementDefinition;
  16. use Shopware\Core\Defaults;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  18. use Shopware\Core\Framework\Uuid\Uuid;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class WarehouseStockUpdater implements EventSubscriberInterface
  22. {
  23.     /**
  24.      * @var Connection
  25.      */
  26.     private $db;
  28.     public function __construct(Connection $db)
  29.     {
  30.         $this->db = $db;
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [StockMovementDefinition::ENTITY_WRITTEN_EVENT => 'stockMovementWritten'];
  36.     }
  38.     public function stockMovementWritten(EntityWrittenEvent $entityWrittenEvent): void
  39.     {
  40.         if ($entityWrittenEvent->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  41.             return;
  42.         }
  44.         $stockMovementIds = [];
  45.         foreach ($entityWrittenEvent->getWriteResults() as $writeResult) {
  46.             if ($writeResult->getExistence()->exists()) {
  47.                 // Updating stock movements is not supported yet
  48.                 // In case a stock location is deleted, this code path is also reached. This is because an
  49.                 // EntityWrittenEvent is triggered when an entity field gets null-ed because of a SET NULL constraint
  50.                 // of a FK.
  51.                 continue;
  52.             }
  53.             $payload = $writeResult->getPayload();
  54.             $stockMovementIds[] = $payload['id'];
  55.         }
  57.         $this->indexStockMovements($stockMovementIds);
  58.     }
  60.     public function indexStockMovements(array $stockMovementIds): void
  61.     {
  62.         $stockMovementIds = array_values(array_unique($stockMovementIds));
  63.         $stockMovements = $this->db->fetchAllAssociative(
  64.             'SELECT
  65.                 LOWER(HEX(product_id)) AS productId,
  66.                 LOWER(HEX(product_version_id)) AS productVersionId,
  67.                 quantity,
  68.                 LOWER(HEX(COALESCE(
  69.                     source_warehouse_id,
  70.                     sourceStockContainer.warehouse_id,
  71.                     sourceBinLocation.warehouse_id
  72.                 ))) AS sourceWarehouseId,
  73.                 LOWER(HEX(COALESCE(
  74.                     destination_warehouse_id,
  75.                     destinationStockContainer.warehouse_id,
  76.                     destinationBinLocation.warehouse_id
  77.                 ))) AS destinationWarehouseId
  78.             FROM pickware_erp_stock_movement stockMovement
  79.             LEFT JOIN pickware_erp_stock_container sourceStockContainer ON sourceStockContainer.id = stockMovement.source_stock_container_id
  80.             LEFT JOIN pickware_erp_bin_location sourceBinLocation ON sourceBinLocation.id = stockMovement.source_bin_location_id
  81.             LEFT JOIN pickware_erp_stock_container destinationStockContainer ON destinationStockContainer.id = stockMovement.destination_stock_container_id
  82.             LEFT JOIN pickware_erp_bin_location destinationBinLocation ON destinationBinLocation.id = stockMovement.destination_bin_location_id
  83.             WHERE stockMovement.id IN (:stockMovementIds) AND product_version_id = :liveVersionId',
  84.             [
  85.                 'stockMovementIds' => array_map('hex2bin', $stockMovementIds),
  86.                 'liveVersionId' => hex2bin(Defaults::LIVE_VERSION),
  87.             ],
  88.             [
  89.                 'stockMovementIds' => Connection::PARAM_STR_ARRAY,
  90.             ],
  91.         );
  93.         // Update warehouse stocks if stock was moved to or from a warehouse or bin location (in that warehouse) or
  94.         // stock container (in that warehouse).
  95.         foreach ($stockMovements as $stockMovement) {
  96.             if ($stockMovement['sourceWarehouseId']) {
  97.                 $this->persistWarehouseStockChange([
  98.                     'productId' => $stockMovement['productId'],
  99.                     'productVersionId' => $stockMovement['productVersionId'],
  100.                     'warehouseId' => $stockMovement['sourceWarehouseId'],
  101.                     'changeAmount' => -1 * $stockMovement['quantity'],
  102.                 ]);
  103.             }
  104.             if ($stockMovement['destinationWarehouseId']) {
  105.                 $this->persistWarehouseStockChange([
  106.                     'productId' => $stockMovement['productId'],
  107.                     'productVersionId' => $stockMovement['productVersionId'],
  108.                     'warehouseId' => $stockMovement['destinationWarehouseId'],
  109.                     'changeAmount' => 1 * $stockMovement['quantity'],
  110.                 ]);
  111.             }
  112.         }
  113.     }
  115.     private function persistWarehouseStockChange(array $payload): void
  116.     {
  117.         $this->db->executeStatement(
  118.             'INSERT INTO pickware_erp_warehouse_stock (
  119.                 id,
  120.                 product_id,
  121.                 product_version_id,
  122.                 quantity,
  123.                 warehouse_id,
  124.                 created_at
  125.             ) VALUES (
  126.                 :id,
  127.                 :productId,
  128.                 :productVersionId,
  129.                 :changeAmount,
  130.                 :warehouseId,
  131.                 NOW(3)
  132.             ) ON DUPLICATE KEY UPDATE
  133.                 quantity = quantity + VALUES(quantity),
  134.                 updated_at = NOW(3)',
  135.             [
  136.                 'id' => Uuid::randomBytes(),
  137.                 'productId' => hex2bin($payload['productId']),
  138.                 'productVersionId' => hex2bin($payload['productVersionId']),
  139.                 'warehouseId' => hex2bin($payload['warehouseId']),
  140.                 'changeAmount' => $payload['changeAmount'],
  141.             ],
  142.         );
  143.     }
  144. }