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

Open in your IDE?
  1. <?php
  3. namespace Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Actions;
  5. use Kiener\MolliePayments\Facade\MollieShipment;
  6. use Kiener\MolliePayments\Facade\MollieShipmentInterface;
  7. use Kiener\MolliePayments\Service\OrderService;
  8. use Kiener\MolliePayments\Service\OrderServiceInterface;
  9. use Psr\Log\LoggerInterface;
  10. use Shopware\Core\Content\Flow\Dispatching\Action\FlowAction;
  11. use Shopware\Core\Content\Flow\Dispatching\StorableFlow;
  12. use Shopware\Core\Framework\Context;
  13. use Shopware\Core\Framework\Event\FlowEvent;
  14. use Shopware\Core\Framework\Event\OrderAware;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class ShipOrderAction extends FlowAction implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var LoggerInterface
  21.      */
  22.     private $logger;
  24.     /**
  25.      * @var OrderServiceInterface
  26.      */
  27.     private $orderService;
  29.     /**
  30.      * @var MollieShipmentInterface
  31.      */
  32.     private $shipmentFacade;
  35.     /**
  36.      * @param OrderServiceInterface $orderService
  37.      * @param MollieShipmentInterface $shipment
  38.      * @param LoggerInterface $logger
  39.      */
  40.     public function __construct(OrderServiceInterface $orderService, MollieShipmentInterface $shipment, LoggerInterface $logger)
  41.     {
  42.         $this->orderService = $orderService;
  43.         $this->shipmentFacade = $shipment;
  44.         $this->logger = $logger;
  45.     }
  47.     /**
  48.      * @return string
  49.      */
  50.     public static function getName(): string
  51.     {
  52.         return 'action.mollie.order.ship';
  53.     }
  55.     /**
  56.      * @return string[]
  57.      */
  58.     public static function getSubscribedEvents(): array
  59.     {
  60.         return [
  61.             self::getName() => 'handle',
  62.         ];
  63.     }
  65.     /**
  66.      * @return string[]
  67.      */
  68.     public function requirements(): array
  69.     {
  70.         return [OrderAware::class];
  71.     }
  73.     /**
  74.      * @param StorableFlow $flow
  75.      * @throws \Exception
  76.      * @return void
  77.      */
  78.     public function handleFlow(StorableFlow $flow): void
  79.     {
  80.         $orderId = $flow->getStore('orderId');
  82.         $this->shipOrder($orderId, $flow->getContext());
  83.     }
  85.     /**
  86.      * @param FlowEvent $event
  87.      * @throws \Exception
  88.      */
  89.     public function handle(FlowEvent $event): void
  90.     {
  91.         $config = $event->getConfig();
  93.         if (empty($config)) {
  94.             return;
  95.         }
  97.         $baseEvent = $event->getEvent();
  99.         if (!$baseEvent instanceof OrderAware) {
  100.             return;
  101.         }
  103.         $orderId = $baseEvent->getOrderId();
  105.         $this->shipOrder($orderId, $baseEvent->getContext());
  106.     }
  108.     /**
  109.      * @param string $orderId
  110.      * @param Context $context
  111.      * @throws \Exception
  112.      * @return void
  113.      */
  114.     private function shipOrder(string $orderId, Context $context): void
  115.     {
  116.         $orderNumber = '';
  118.         try {
  119.             $order = $this->orderService->getOrder($orderId, $context);
  121.             $orderNumber = $order->getOrderNumber();
  123.             $this->logger->info('Starting Shipment through Flow Builder Action for order: ' . $orderNumber);
  125.             $this->shipmentFacade->shipOrder(
  126.                 $order,
  127.                 '',
  128.                 '',
  129.                 '',
  130.                 $context
  131.             );
  132.         } catch (\Exception $ex) {
  133.             $this->logger->error(
  134.                 'Error when shipping order with Flow Builder Action',
  135.                 [
  136.                     'error' => $ex->getMessage(),
  137.                     'order' => $orderNumber,
  138.                 ]
  139.             );
  141.             throw $ex;
  142.         }
  143.     }
  144. }