custom/plugins/MolliePayments/src/Subscriber/OrderDeliverySubscriber.php line 73

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Kiener\MolliePayments\Subscriber;
  5. use Kiener\MolliePayments\Components\ShipmentManager\ShipmentManager;
  6. use Kiener\MolliePayments\Repository\OrderTransaction\OrderTransactionRepositoryInterface;
  7. use Kiener\MolliePayments\Service\OrderService;
  8. use Kiener\MolliePayments\Service\SettingsService;
  9. use Kiener\MolliePayments\Struct\PaymentMethod\PaymentMethodAttributes;
  10. use Psr\Log\LoggerInterface;
  11. use Shopware\Core\Checkout\Payment\PaymentMethodEntity;
  12. use Shopware\Core\System\StateMachine\Aggregation\StateMachineTransition\StateMachineTransitionActions;
  13. use Shopware\Core\System\StateMachine\Event\StateMachineStateChangeEvent;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class OrderDeliverySubscriber implements EventSubscriberInterface
  17. {
  18.     /**
  19.      * @var SettingsService
  20.      */
  21.     private $settings;
  23.     /**
  24.      * @var ShipmentManager
  25.      */
  26.     private $mollieShipment;
  28.     /**
  29.      * @var OrderService
  30.      */
  31.     private $orderService;
  33.     /**
  34.      * @var OrderTransactionRepositoryInterface
  35.      */
  36.     private $repoOrderTransactions;
  38.     /**
  39.      * @var LoggerInterface
  40.      */
  41.     private $logger;
  43.     /**
  44.      * @param SettingsService $settings
  45.      * @param ShipmentManager $mollieShipment
  46.      * @param OrderService $orderService
  47.      * @param OrderTransactionRepositoryInterface $repoOrderTransactions
  48.      * @param LoggerInterface $logger
  49.      */
  50.     public function __construct(SettingsService $settings, ShipmentManager $mollieShipment, OrderService $orderService, OrderTransactionRepositoryInterface $repoOrderTransactions, LoggerInterface $logger)
  51.     {
  52.         $this->settings = $settings;
  53.         $this->mollieShipment = $mollieShipment;
  54.         $this->orderService = $orderService;
  55.         $this->repoOrderTransactions = $repoOrderTransactions;
  56.         $this->logger = $logger;
  57.     }
  60.     /**
  61.      * @return array<mixed>
  62.      */
  63.     public static function getSubscribedEvents(): array
  64.     {
  65.         return [
  66.             'state_machine.order_delivery.state_changed' => 'onOrderDeliveryChanged',
  67.         ];
  68.     }
  70.     /**
  71.      * @param StateMachineStateChangeEvent $event
  72.      */
  73.     public function onOrderDeliveryChanged(StateMachineStateChangeEvent $event): void
  74.     {
  75.         if ($event->getTransitionSide() !== StateMachineStateChangeEvent::STATE_MACHINE_TRANSITION_SIDE_ENTER) {
  76.             return;
  77.         }
  79.         $transitionName = $event->getTransition()->getTransitionName();
  81.         if ($transitionName !== StateMachineTransitionActions::ACTION_SHIP) {
  82.             return;
  83.         }
  85.         # get the configuration of the sales channel from the order
  86.         $configSalesChannel = $this->settings->getSettings($event->getSalesChannelId());
  89.         # if we don't even configure automatic shipping
  90.         # then don't even look into our order to find out if we should actually starts
  91.         if (!$configSalesChannel->getAutomaticShipping()) {
  92.             return;
  93.         }
  95.         $orderDeliveryId = $event->getTransition()->getEntityId();
  97.         try {
  98.             $order = $this->orderService->getOrderByDeliveryId($orderDeliveryId, $event->getContext());
  100.             $swTransaction = $this->repoOrderTransactions->getLatestOrderTransaction($order->getId(), $event->getContext());
  102.             # verify if the customer really paid with Mollie in the end
  103.             $paymentMethod = $swTransaction->getPaymentMethod();
  105.             if (!$paymentMethod instanceof PaymentMethodEntity) {
  106.                 throw new \Exception('Transaction ' . $swTransaction->getId() . ' has no payment method!');
  107.             }
  109.             $paymentMethodAttributes = new PaymentMethodAttributes($paymentMethod);
  111.             if (!$paymentMethodAttributes->isMolliePayment()) {
  112.                 # just skip it if it has been paid
  113.                 # with another payment provider
  114.                 # do NOT throw an error
  115.                 return;
  116.             }
  118.             $this->logger->info('Starting Shipment through Order Delivery Transition for order: ' . $order->getOrderNumber());
  120.             $this->mollieShipment->shipOrderRest($order, null, $event->getContext());
  121.         } catch (\Throwable $ex) {
  122.             $this->logger->error('Failed to transfer delivery state to mollie: '.$ex->getMessage(), ['exception' => $ex]);
  123.             return;
  124.         }
  125.     }
  126. }