custom/plugins/TigerConnect/src/Core/Content/Flow/Dispatching/Action/OrderExportAction.php line 50

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace TigerMedia\TigerConnect\Core\Content\Flow\Dispatching\Action;
  5. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  6. use Shopware\Core\Content\Flow\Dispatching\Action\FlowAction;
  7. use Shopware\Core\Content\Flow\Dispatching\Aware\OrderTransactionAware;
  8. use Shopware\Core\Framework\Event\FlowEvent;
  9. use Shopware\Core\Framework\Event\OrderAware;
  10. use Symfony\Component\Messenger\MessageBusInterface;
  11. use TigerMedia\TigerConnect\Core\Content\Logger\LoggerDefinition;
  12. use TigerMedia\TigerConnect\Exception\OrderException;
  13. use TigerMedia\TigerConnect\Helper\OrderHelper;
  14. use TigerMedia\TigerConnect\MessageQueue\OrderDataMessage;
  16. class OrderExportAction extends FlowAction
  17. {
  18.     const ACTION_NAME = 'action.tiger_connect.order.export';
  20.     public function __construct(
  21.         private readonly MessageBusInterface $messageBus,
  22.         private readonly OrderHelper $orderHelper
  23.     )
  24.     {
  25.     }
  27.     public function requirements(): array
  28.     {
  29.         return [OrderAware::class, OrderTransactionAware::class];
  30.     }
  32.     public static function getName(): string
  33.     {
  34.         return self::ACTION_NAME;
  35.     }
  37.     /**
  38.      * @inheritDoc
  39.      */
  40.     public static function getSubscribedEvents(): iterable
  41.     {
  42.         return [
  43.             self::getName() => 'handle',
  44.         ];
  45.     }
  47.     /**
  48.      * @throws OrderException
  49.      */
  50.     public function handle(FlowEvent $event): void
  51.     {
  52.         /** @var CheckoutOrderPlacedEvent $orderEvent */
  53.         $orderEvent = $event->getEvent();
  54.         $order = $orderEvent->getOrder();
  55.         $this->orderHelper->addToLogger($order->getOrderNumber(), "Starting flow action for Order [{$order->getOrderNumber()}].", LoggerDefinition::LOG_INFO, $event->getContext());
  56.         $this->orderHelper->addToLogger($order->getOrderNumber(), "Starting dispatch for Order [{$order->getOrderNumber()}].", LoggerDefinition::LOG_INFO, $event->getContext());
  57.         $this->messageBus->dispatch(new OrderDataMessage($order->getOrderNumber(), $event->getContext()));
  58.         $this->orderHelper->addToLogger($order->getOrderNumber(), "Dispatched queue for Order [{$order->getOrderNumber()}].", LoggerDefinition::LOG_INFO, $event->getContext());
  59.     }
  60. }