custom/plugins/SwagB2bPlatform/components/Order/BridgePlatform/OrderTransitionSubscriber.php line 48

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\B2B\Order\BridgePlatform;
  5. use Shopware\B2B\Common\IdValue;
  6. use Shopware\B2B\Common\Repository\NotFoundException;
  7. use Shopware\B2B\Order\Framework\OrderContext;
  8. use Shopware\B2B\Order\Framework\OrderContextRepository;
  9. use Shopware\Core\Checkout\Order\OrderDefinition;
  10. use Shopware\Core\System\StateMachine\Event\StateMachineTransitionEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  14. class OrderTransitionSubscriber implements EventSubscriberInterface
  15. {
  16.     /**
  17.      * @var ShopOrderRepository
  18.      */
  19.     private $shopOrderRepository;
  21.     /**
  22.      * @var OrderContextRepository
  23.      */
  24.     private $orderContextRepository;
  26.     /**
  27.      * @var EventDispatcherInterface
  28.      */
  29.     private $dispatcher;
  31.     public function __construct(
  32.         ShopOrderRepository $shopOrderRepository,
  33.         OrderContextRepository $orderContextRepository,
  34.         EventDispatcherInterface $dispatcher
  35.     ) {
  36.         $this->shopOrderRepository = $shopOrderRepository;
  37.         $this->orderContextRepository = $orderContextRepository;
  38.         $this->dispatcher = $dispatcher;
  39.     }
  41.     public static function getSubscribedEvents()
  42.     {
  43.         return [
  44.             StateMachineTransitionEvent::class => 'onStateChange',
  45.         ];
  46.     }
  48.     public function onStateChange(StateMachineTransitionEvent $event): void
  49.     {
  50.         if ($event->getEntityName() !== OrderDefinition::ENTITY_NAME) {
  51.             return;
  52.         }
  54.         try {
  55.             $orderContext = $this->updateOrderContext($event);
  56.         } catch (NotFoundException $e) {
  57.             return;
  58.         }
  60.         $this->dispatcher->dispatch(
  61.             new OrderContextStateChangedEvent(
  62.                 $event->getFromPlace()->getTechnicalName(),
  63.                 $event->getToPlace()->getTechnicalName(),
  64.                 $orderContext
  65.             )
  66.         );
  67.     }
  69.     /**
  70.      * @internal
  71.      */
  72.     protected function updateOrderContext(StateMachineTransitionEvent $event): OrderContext
  73.     {
  74.         $orderContext = $this->shopOrderRepository
  75.             ->fetchOneOrderContextByShopOrderId(IdValue::create($event->getEntityId()));
  77.         $orderContext->status = $event->getToPlace()->getTechnicalName();
  79.         $this->orderContextRepository
  80.             ->updateContext($orderContext);
  82.         return $orderContext;
  83.     }
  84. }