custom/plugins/SwagCommercial/src/MultiWarehouse/Subscriber/CheckoutOrderPlacedSubscriber.php line 46

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Commercial\MultiWarehouse\Subscriber;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Commercial\Licensing\License;
  7. use Shopware\Commercial\MultiWarehouse\Domain\Order\MultiWarehouseStockUpdater;
  8. use Shopware\Commercial\MultiWarehouse\Domain\Product\MultiWarehouseProductFilter;
  9. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  10. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  11. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemEntity;
  12. use Shopware\Core\Framework\Context;
  13. use Shopware\Core\Framework\Uuid\Uuid;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. /**
  17.  * @internal
  18.  *
  19.  * @package inventory
  20.  */
  21. class CheckoutOrderPlacedSubscriber implements EventSubscriberInterface
  22. {
  23.     private MultiWarehouseStockUpdater $stockUpdater;
  25.     private MultiWarehouseProductFilter $productFilter;
  27.     private Connection $connection;
  29.     public function __construct(
  30.         MultiWarehouseStockUpdater $stockUpdater,
  31.         MultiWarehouseProductFilter $productFilter,
  32.         Connection $connection
  33.     ) {
  34.         $this->stockUpdater = $stockUpdater;
  35.         $this->productFilter = $productFilter;
  36.         $this->connection = $connection;
  37.     }
  39.     public static function getSubscribedEvents(): array
  40.     {
  41.         return [
  42.             CheckoutOrderPlacedEvent::class => 'onOrderPlaced',
  43.         ];
  44.     }
  46.     public function onOrderPlaced(CheckoutOrderPlacedEvent $event): void
  47.     {
  48.         if (!License::get('MULTI_INVENTORY-3749997')) {
  49.             return;
  50.         }
  52.         $lineItems = $event->getOrder()->getLineItems();
  53.         if ($lineItems === null || $lineItems->count() <= 0) {
  54.             return;
  55.         }
  57.         $groupIds = $this->getOrderWarehouseGroups($event->getContext(), $event->getOrder()->getId());
  58.         if (empty($groupIds)) {
  59.             return;
  60.         }
  62.         /** @var list<string> $lineItemRefIds */
  63.         $lineItemRefIds = $lineItems->fmap(static function (OrderLineItemEntity $orderLineItem) {
  64.             if ($orderLineItem->getType() !== LineItem::PRODUCT_LINE_ITEM_TYPE) {
  65.                 return null;
  66.             }
  68.             return $orderLineItem->getReferencedId();
  69.         });
  71.         $warehouseLineItemIds = $this->productFilter->filterProductIdsWithWarehouses($lineItemRefIds);
  72.         if (empty($warehouseLineItemIds)) {
  73.             return;
  74.         }
  76.         $ids = [];
  78.         /** @var OrderLineItemEntity $lineItem */
  79.         foreach ($lineItems as $lineItem) {
  80.             if (!\in_array($lineItem->getReferencedId(), $warehouseLineItemIds, true)) {
  81.                 continue;
  82.             }
  84.             if (!\array_key_exists($lineItem->getReferencedId(), $ids)) {
  85.                 $ids[$lineItem->getReferencedId()] = 0;
  86.             }
  88.             $ids[$lineItem->getReferencedId()] += $lineItem->getQuantity();
  89.         }
  91.         $this->stockUpdater->update(
  92.             $event->getContext(),
  93.             $event->getOrderId(),
  94.             $groupIds,
  95.             $ids
  96.         );
  97.     }
  99.     /**
  100.      * @return list<string>
  101.      */
  102.     private function getOrderWarehouseGroups(Context $context, string $orderId): array
  103.     {
  104.         /** @var list<string> $groups */
  105.         $groups = $this->connection->fetchFirstColumn(
  106.             'SELECT LOWER(HEX(warehouse_group_id)) FROM order_warehouse_group WHERE order_id = :orderId AND order_version_id = :versionId',
  107.             [
  108.                 'orderId' => Uuid::fromHexToBytes($orderId),
  109.                 'versionId' => Uuid::fromHexToBytes($context->getVersionId()),
  110.             ]
  111.         );
  113.         return $groups;
  114.     }
  115. }