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

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\Order\OrderEntity;
  12. use Shopware\Core\Checkout\Payment\PaymentMethodEntity;
  13. use Shopware\Core\System\StateMachine\Aggregation\StateMachineTransition\StateMachineTransitionActions;
  14. use Shopware\Core\System\StateMachine\Event\StateMachineStateChangeEvent;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class OrderDeliverySubscriber implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var SettingsService
  21.      */
  22.     private $settings;
  24.     /**
  25.      * @var ShipmentManager
  26.      */
  27.     private $mollieShipment;
  29.     /**
  30.      * @var OrderService
  31.      */
  32.     private $orderService;
  34.     /**
  35.      * @var OrderTransactionRepositoryInterface
  36.      */
  37.     private $repoOrderTransactions;
  39.     /**
  40.      * @var LoggerInterface
  41.      */
  42.     private $logger;
  44.     /**
  45.      * @param SettingsService $settings
  46.      * @param ShipmentManager $mollieShipment
  47.      * @param OrderService $orderService
  48.      * @param OrderTransactionRepositoryInterface $repoOrderTransactions
  49.      * @param LoggerInterface $logger
  50.      */
  51.     public function __construct(SettingsService $settings, ShipmentManager $mollieShipment, OrderService $orderService, OrderTransactionRepositoryInterface $repoOrderTransactions, LoggerInterface $logger)
  52.     {
  53.         $this->settings = $settings;
  54.         $this->mollieShipment = $mollieShipment;
  55.         $this->orderService = $orderService;
  56.         $this->repoOrderTransactions = $repoOrderTransactions;
  57.         $this->logger = $logger;
  58.     }
  61.     /**
  62.      * @return array<mixed>
  63.      */
  64.     public static function getSubscribedEvents(): array
  65.     {
  66.         return [
  67.             'state_machine.order_delivery.state_changed' => 'onOrderDeliveryChanged',
  68.         ];
  69.     }
  71.     /**
  72.      * @param StateMachineStateChangeEvent $event
  73.      */
  74.     public function onOrderDeliveryChanged(StateMachineStateChangeEvent $event): void
  75.     {
  76.         if ($event->getTransitionSide() !== StateMachineStateChangeEvent::STATE_MACHINE_TRANSITION_SIDE_ENTER) {
  77.             return;
  78.         }
  80.         $transitionName = $event->getTransition()->getTransitionName();
  82.         if ($transitionName !== StateMachineTransitionActions::ACTION_SHIP) {
  83.             return;
  84.         }
  86.         # get the configuration of the sales channel from the order
  87.         $configSalesChannel = $this->settings->getSettings($event->getSalesChannelId());
  90.         # if we don't even configure automatic shipping
  91.         # then don't even look into our order to find out if we should actually starts
  92.         if (!$configSalesChannel->getAutomaticShipping()) {
  93.             return;
  94.         }
  96.         $orderDeliveryId = $event->getTransition()->getEntityId();
  98.         try {
  99.             $order = $this->orderService->getOrderByDeliveryId($orderDeliveryId, $event->getContext());
  101.             $swTransaction = $this->repoOrderTransactions->getLatestOrderTransaction($order->getId(), $event->getContext());
  103.             # verify if the customer really paid with Mollie in the end
  104.             $paymentMethod = $swTransaction->getPaymentMethod();
  106.             if (!$paymentMethod instanceof PaymentMethodEntity) {
  107.                 throw new \Exception('Transaction ' . $swTransaction->getId() . ' has no payment method!');
  108.             }
  110.             $paymentMethodAttributes = new PaymentMethodAttributes($paymentMethod);
  112.             if (!$paymentMethodAttributes->isMolliePayment()) {
  113.                 # just skip it if it has been paid
  114.                 # with another payment provider
  115.                 # do NOT throw an error
  116.                 return;
  117.             }
  119.             $this->logger->info('Starting Shipment through Order Delivery Transition for order: ' . $order->getOrderNumber());
  121.             $this->mollieShipment->shipOrderRest($order, null, $event->getContext());
  122.         } catch (\Throwable $ex) {
  123.             $this->logger->error('Failed to transfer delivery state to mollie: '.$ex->getMessage());
  124.             return;
  125.         }
  126.     }
  127. }