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

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