custom/plugins/MolliePayments/src/Compatibility/Bundles/FlowBuilder/Actions/ShipOrderAction.php line 87

Open in your IDE?
  1. <?php
  3. namespace Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Actions;
  5. use Kiener\MolliePayments\Components\ShipmentManager\ShipmentManagerInterface;
  6. use Kiener\MolliePayments\Service\OrderServiceInterface;
  7. use Psr\Log\LoggerInterface;
  8. use Shopware\Core\Content\Flow\Dispatching\Action\FlowAction;
  9. use Shopware\Core\Content\Flow\Dispatching\StorableFlow;
  10. use Shopware\Core\Framework\Context;
  11. use Shopware\Core\Framework\Event\FlowEvent;
  12. use Shopware\Core\Framework\Event\OrderAware;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class ShipOrderAction extends FlowAction implements EventSubscriberInterface
  16. {
  17.     /**
  18.      * @var LoggerInterface
  19.      */
  20.     private $logger;
  22.     /**
  23.      * @var OrderServiceInterface
  24.      */
  25.     private $orderService;
  27.     /**
  28.      * @var ShipmentManagerInterface
  29.      */
  30.     private $shipment;
  33.     /**
  34.      * @param OrderServiceInterface $orderService
  35.      * @param ShipmentManagerInterface $shipment
  36.      * @param LoggerInterface $logger
  37.      */
  38.     public function __construct(OrderServiceInterface $orderService, ShipmentManagerInterface $shipment, LoggerInterface $logger)
  39.     {
  40.         $this->orderService = $orderService;
  41.         $this->shipment = $shipment;
  42.         $this->logger = $logger;
  43.     }
  45.     /**
  46.      * @return string
  47.      */
  48.     public static function getName(): string
  49.     {
  50.         return 'action.mollie.order.ship';
  51.     }
  53.     /**
  54.      * @return string[]
  55.      */
  56.     public static function getSubscribedEvents(): array
  57.     {
  58.         return [
  59.             self::getName() => 'handle',
  60.         ];
  61.     }
  63.     /**
  64.      * @return string[]
  65.      */
  66.     public function requirements(): array
  67.     {
  68.         return [OrderAware::class];
  69.     }
  71.     /**
  72.      * @param StorableFlow $flow
  73.      * @throws \Exception
  74.      * @return void
  75.      */
  76.     public function handleFlow(StorableFlow $flow): void
  77.     {
  78.         $orderId = $flow->getStore('orderId');
  80.         $this->shipOrder($orderId, $flow->getContext());
  81.     }
  83.     /**
  84.      * @param FlowEvent $event
  85.      * @throws \Exception
  86.      */
  87.     public function handle(FlowEvent $event): void
  88.     {
  89.         $config = $event->getConfig();
  91.         if (empty($config)) {
  92.             return;
  93.         }
  95.         $baseEvent = $event->getEvent();
  97.         if (!$baseEvent instanceof OrderAware) {
  98.             return;
  99.         }
  101.         $orderId = $baseEvent->getOrderId();
  103.         $this->shipOrder($orderId, $baseEvent->getContext());
  104.     }
  106.     /**
  107.      * @param string $orderId
  108.      * @param Context $context
  109.      * @throws \Exception
  110.      * @return void
  111.      */
  112.     private function shipOrder(string $orderId, Context $context): void
  113.     {
  114.         $orderNumber = '';
  116.         try {
  117.             $order = $this->orderService->getOrder($orderId, $context);
  119.             $orderNumber = $order->getOrderNumber();
  121.             $this->logger->info('Starting Shipment through Flow Builder Action for order: ' . $orderNumber);
  123.             # ship (all or) the rest of the order without providing any specific tracking information.
  124.             # this will ensure tracking data is automatically taken from the order
  125.             $this->shipment->shipOrderRest($order, null, $context);
  126.         } catch (\Exception $ex) {
  127.             $this->logger->error(
  128.                 'Error when shipping order with Flow Builder Action',
  129.                 [
  130.                     'error' => $ex->getMessage(),
  131.                     'order' => $orderNumber,
  132.                 ]
  133.             );
  135.             throw $ex;
  136.         }
  137.     }
  138. }