custom/plugins/SwagB2bPlatform/components/InStock/BridgePlatform/InStockCheckoutSubscriber.php line 50

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.     /**
  19.      * @var AuthenticationService
  20.      */
  21.     private $authenticationService;
  23.     /**
  24.      * @var InStockRepository
  25.      */
  26.     private $inStockRepository;
  28.     /**
  29.      * @var InStockBridgeRepository
  30.      */
  31.     private $inStockBridgeRepository;
  33.     public function __construct(
  34.         AuthenticationService $authenticationService,
  35.         InStockRepository $inStockRepository,
  36.         InStockBridgeRepository $inStockBridgeRepository
  37.     ) {
  38.         $this->authenticationService = $authenticationService;
  39.         $this->inStockRepository = $inStockRepository;
  40.         $this->inStockBridgeRepository = $inStockBridgeRepository;
  41.     }
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             CheckoutOrderPlacedEvent::class => 'updateInStockAfterOrderPlaced',
  47.         ];
  48.     }
  50.     public function updateInStockAfterOrderPlaced(CheckoutOrderPlacedEvent $event): void
  51.     {
  52.         if (!$this->authenticationService->isB2b()) {
  53.             return;
  54.         }
  56.         /** @var OrderLineItemCollection $lineItems */
  57.         $lineItems = $event->getOrder()->getLineItems();
  58.         $productIds = $lineItems->fmap(function (OrderLineItemEntity $lineItem) {
  59.             if ($lineItem->getType() !== LineItem::PRODUCT_LINE_ITEM_TYPE) {
  60.                 return null;
  61.             }
  63.             return $lineItem->getReferencedId();
  64.         });
  66.         $inStocks = $this->inStockBridgeRepository->fetchInStocksByProductIds(
  67.             IdValue::fromHexToBytesList($productIds),
  68.             $this->authenticationService->getIdentity(),
  69.             new InStockSearchStruct()
  70.         );
  72.         $lineItemIds = array_flip($productIds);
  74.         $matchedInStocks = [];
  75.         foreach ($inStocks as $productId => $inStock) {
  76.             $lineItem = $lineItems->get($lineItemIds[$productId]);
  78.             $inStock->inStock -= $lineItem->getQuantity();
  79.             $matchedInStocks[] = $inStock;
  80.         }
  82.         if (!$matchedInStocks) {
  83.             return;
  84.         }
  86.         $this->inStockRepository->updateMultipleInStocks($matchedInStocks);
  87.     }
  88. }