custom/plugins/SwagB2bPlatform/components/Cart/BridgePlatform/CartFinishSubscriber.php line 47

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\B2B\Cart\BridgePlatform;
  5. use Shopware\B2B\Order\BridgePlatform\OrderContextCreatedEvent;
  6. use Shopware\B2B\Order\Framework\OrderContext;
  7. use Shopware\Core\Checkout\Cart\Cart;
  8. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  9. use Shopware\Core\Checkout\Cart\Order\CartConvertedEvent;
  10. use Shopware\Core\Checkout\Order\OrderEntity;
  11. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  12. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. abstract class CartFinishSubscriber implements EventSubscriberInterface
  16. {
  17.     private const PRIORITY_EARLY = 10;
  19.     /**
  20.      * @var CartConvertedEvent
  21.      */
  22.     protected $cartConvertedEvent;
  24.     /**
  25.      * @var EventDispatcherInterface
  26.      */
  27.     protected $eventDispatcher;
  29.     public function __construct(EventDispatcherInterface $eventDispatcher)
  30.     {
  31.         $this->eventDispatcher = $eventDispatcher;
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             CartConvertedEvent::class => ['initializeState', self::PRIORITY_EARLY],
  38.             CheckoutOrderPlacedEvent::class => ['handleCreatedOrder', self::PRIORITY_EARLY],
  39.         ];
  40.     }
  42.     public function initializeState(CartConvertedEvent $event): void
  43.     {
  44.         $this->cartConvertedEvent = $event;
  45.     }
  47.     public function handleCreatedOrder(CheckoutOrderPlacedEvent $event): void
  48.     {
  49.         $this->testStateValid($event);
  51.         $orderContext = $this->onCartFinish(
  52.             $this->cartConvertedEvent->getCart(),
  53.             $event->getOrder(),
  54.             $this->cartConvertedEvent->getSalesChannelContext()
  55.         );
  57.         if ($orderContext) {
  58.             $this->eventDispatcher->dispatch(new OrderContextCreatedEvent($orderContext));
  59.         }
  61.         $this->reset();
  62.     }
  64.     abstract protected function onCartFinish(Cart $cart, OrderEntity $orderEntity, SalesChannelContext $salesChannelContext): ?OrderContext;
  66.     protected function getCartState(): CartState
  67.     {
  68.         return $this
  69.             ->cartConvertedEvent
  70.             ->getCart()
  71.             ->getExtension(CartState::NAME);
  72.     }
  74.     /**
  75.      * @internal
  76.      */
  77.     protected function testStateValid(CheckoutOrderPlacedEvent $orderPlacedEvent): void
  78.     {
  79.         if (!$this->cartConvertedEvent) {
  80.             throw new CartFinishException('Placing order without dispatching cart converted');
  81.         }
  83.         $orderNumber = $this->cartConvertedEvent->getConvertedCart()['orderNumber'];
  85.         if ($orderNumber !== $orderPlacedEvent->getOrder()->getOrderNumber()) {
  86.             throw new CartFinishException('CheckoutOrderPlacedEvent contains different order number than CartConvertedEvent');
  87.         }
  89.         $salesChannelContext = $this->cartConvertedEvent->getSalesChannelContext();
  91.         if ($salesChannelContext->getSalesChannel()->getId() !== $orderPlacedEvent->getSalesChannelId()) {
  92.             throw new CartFinishException('SalesChannel id differs between events');
  93.         }
  94.     }
  96.     private function reset(): void
  97.     {
  98.         $this->cartConvertedEvent = null;
  99.     }
  100. }