custom/plugins/PickwareErpStarter/src/Stock/ContainerOverride/StockUpdaterOverride.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\ContainerOverride;
  14. use Doctrine\DBAL\Connection;
  15. use Pickware\PickwareErpStarter\Stock\ProductSalesUpdater;
  16. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  17. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  18. use Shopware\Core\Checkout\Order\OrderDefinition;
  19. use Shopware\Core\Content\Product\DataAbstractionLayer\StockUpdater;
  20. use Shopware\Core\Defaults;
  21. use Shopware\Core\Framework\Context;
  22. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  23. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PreWriteValidationEvent;
  24. use Shopware\Core\System\StateMachine\Event\StateMachineTransitionEvent;
  26. /**
  27.  * Override for \Shopware\Core\Content\Product\DataAbstractionLayer\StockUpdater to disable all
  28.  * of its functionality except the updating of product.sales. Stock will be updated by our indexers.
  29.  *
  30.  * The product.sales update is kept in this subscriber. See this issue: https://github.com/pickware/shopware-plugins/issues/2852
  31.  * The update itself is done asynchronously and periodically in a scheduled task. See this isse: https://github.com/pickware/shopware-plugins/issues/3408
  32.  */
  33. class StockUpdaterOverride extends StockUpdater
  34. {
  35.     private ?Connection $connection;
  36.     private ?ProductSalesUpdater $productSalesUpdater;
  38.     /**
  39.      * @internal
  40.      * @deprecated next major version: Both arguments will be non-optional
  41.      */
  42.     public function __construct(
  43.         ?Connection $connection = null,
  44.         $productSalesUpdater = null
  45.     ) {
  46.         $this->connection = $connection;
  48.         if ($productSalesUpdater instanceof ProductSalesUpdater) {
  49.             // Backwards compatibility: the second parameter of this subscriber (override) changed to ProductSalesUpdater
  50.             $this->productSalesUpdater = $productSalesUpdater;
  51.         } else {
  52.             $this->productSalesUpdater = null;
  53.         }
  54.     }
  56.     public static function getSubscribedEvents(): array
  57.     {
  58.         return [
  59.             StateMachineTransitionEvent::class => 'stateChanged',
  60.         ];
  61.     }
  63.     public function triggerChangeSet(PreWriteValidationEvent $event): void
  64.     {
  65.     }
  67.     public function lineItemWritten(EntityWrittenEvent $event): void
  68.     {
  69.     }
  71.     public function stateChanged(StateMachineTransitionEvent $event): void
  72.     {
  73.         if (!$this->connection || !$this->productSalesUpdater) {
  74.             return;
  75.         }
  77.         if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  78.             return;
  79.         }
  80.         if ($event->getEntityName() !== OrderDefinition::ENTITY_NAME) {
  81.             return;
  82.         }
  84.         $productIds = $this->connection->fetchFirstColumn(
  85.             'SELECT HEX(`product_id`) FROM `order_line_item`
  86.             WHERE
  87.                 `order_line_item`.`type` = :lineItemType
  88.                 AND `order_line_item`.`version_id` = :liveVersionId
  89.                 AND `order_line_item`.`order_id` = :orderId
  90.                 AND `order_line_item`.`product_id` IS NOT NULL;',
  91.             [
  92.                 'orderId' => hex2bin($event->getEntityId()),
  93.                 'liveVersionId' => hex2bin(Defaults::LIVE_VERSION),
  94.                 'lineItemType' => LineItem::PRODUCT_LINE_ITEM_TYPE,
  95.             ],
  96.         );
  98.         $this->productSalesUpdater->addProductsToUpdateQueue($productIds);
  99.     }
  101.     public function update(array $ids, Context $context): void
  102.     {
  103.     }
  105.     public function orderPlaced(CheckoutOrderPlacedEvent $event): void
  106.     {
  107.     }
  108. }