vendor/store.shopware.com/swagb2bplatform/components/InStock/BridgePlatform/InStockCheckoutSubscriber.php line 41

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\B2B\InStock\BridgePlatform;
  5. use Shopware\B2B\Common\IdValue;
  6. use Shopware\B2B\InStock\Framework\InStockRepository;
  7. use Shopware\B2B\InStock\Framework\InStockSearchStruct;
  8. use Shopware\B2B\StoreFrontAuthentication\Framework\AuthenticationService;
  9. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  10. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  11. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemCollection;
  12. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemEntity;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use function array_flip;
  16. class InStockCheckoutSubscriber implements EventSubscriberInterface
  17. {
  18.     private AuthenticationService $authenticationService;
  20.     private InStockRepository $inStockRepository;
  22.     private InStockBridgeRepository $inStockBridgeRepository;
  24.     public function __construct(
  25.         AuthenticationService $authenticationService,
  26.         InStockRepository $inStockRepository,
  27.         InStockBridgeRepository $inStockBridgeRepository
  28.     ) {
  29.         $this->authenticationService = $authenticationService;
  30.         $this->inStockRepository = $inStockRepository;
  31.         $this->inStockBridgeRepository = $inStockBridgeRepository;
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             CheckoutOrderPlacedEvent::class => 'updateInStockAfterOrderPlaced',
  38.         ];
  39.     }
  41.     public function updateInStockAfterOrderPlaced(CheckoutOrderPlacedEvent $event): void
  42.     {
  43.         if (!$this->authenticationService->isB2b()) {
  44.             return;
  45.         }
  47.         /** @var OrderLineItemCollection $lineItems */
  48.         $lineItems = $event->getOrder()->getLineItems();
  49.         $productIds = $lineItems->fmap(function (OrderLineItemEntity $lineItem) {
  50.             if ($lineItem->getType() !== LineItem::PRODUCT_LINE_ITEM_TYPE) {
  51.                 return null;
  52.             }
  54.             return $lineItem->getReferencedId();
  55.         });
  57.         $inStocks = $this->inStockBridgeRepository->fetchInStocksByProductIds(
  58.             IdValue::fromHexToBytesList($productIds),
  59.             $this->authenticationService->getIdentity(),
  60.             new InStockSearchStruct()
  61.         );
  63.         $lineItemIds = array_flip($productIds);
  65.         $matchedInStocks = [];
  66.         foreach ($inStocks as $productId => $inStock) {
  67.             $lineItem = $lineItems->get($lineItemIds[$productId]);
  69.             $inStock->inStock -= $lineItem->getQuantity();
  70.             $matchedInStocks[] = $inStock;
  71.         }
  73.         if (!$matchedInStocks) {
  74.             return;
  75.         }
  77.         $this->inStockRepository->updateMultipleInStocks($matchedInStocks);
  78.     }
  79. }