custom/plugins/MolliePayments/src/Subscriber/OrderStateSubscriber.php line 50

Open in your IDE?
  1. <?php
  4. namespace Kiener\MolliePayments\Subscriber;
  6. use Kiener\MolliePayments\Factory\MollieApiFactory;
  7. use Kiener\MolliePayments\Service\CustomFieldService;
  8. use Kiener\MolliePayments\Service\OrderService;
  9. use Kiener\MolliePayments\Service\PaymentMethodService;
  10. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionCollection;
  11. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionEntity;
  12. use Shopware\Core\Checkout\Order\OrderEntity;
  13. use Shopware\Core\Checkout\Order\OrderStates;
  14. use Shopware\Core\Framework\Api\Context\AdminApiSource;
  15. use Shopware\Core\System\StateMachine\Event\StateMachineStateChangeEvent;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class OrderStateSubscriber implements EventSubscriberInterface
  19. {
  20.     public static function getSubscribedEvents()
  21.     {
  22.         return [
  23.             'state_machine.order.state_changed' => ['onKlarnaOrderCancelledAsAdmin']
  24.         ];
  25.     }
  27.     /** @var MollieApiFactory */
  28.     private $apiFactory;
  29.     /** @var OrderService */
  30.     private $orderService;
  32.     /** @var PaymentMethodService */
  33.     private $paymentMethodService;
  35.     public function __construct(
  36.         MollieApiFactory     $apiFactory,
  37.         OrderService         $orderService,
  38.         PaymentMethodService $paymentMethodService
  39.     ) {
  40.         $this->orderService = $orderService;
  41.         $this->paymentMethodService = $paymentMethodService;
  42.         $this->apiFactory = $apiFactory;
  43.     }
  46.     /**
  47.      * @param StateMachineStateChangeEvent $event
  48.      * @throws \Mollie\Api\Exceptions\ApiException
  49.      */
  50.     public function onKlarnaOrderCancelledAsAdmin(StateMachineStateChangeEvent $event): void
  51.     {
  52.         if (! ($event->getContext()->getSource() instanceof AdminApiSource)) {
  53.             return;
  54.         }
  56.         // Build order state change to cancelled event name
  57.         $orderStateCancelled = implode('.', [
  58.             StateMachineStateChangeEvent::STATE_MACHINE_TRANSITION_SIDE_ENTER,
  59.             OrderStates::STATE_MACHINE,
  60.             OrderStates::STATE_CANCELLED
  61.         ]);
  63.         if ($event->getStateEventName() !== $orderStateCancelled) {
  64.             return;
  65.         }
  68.         $order = $this->orderService->getOrder($event->getTransition()->getEntityId(), $event->getContext());
  70.         if (! $order instanceof OrderEntity) {
  71.             return;
  72.         }
  74.         if (! $order->getTransactions() instanceof OrderTransactionCollection) {
  75.             return;
  76.         }
  78.         // use filterByState(OrderTransactionStates::STATE_OPEN)?
  79.         $lastTransaction = $order->getTransactions()->last();
  81.         if (! $lastTransaction instanceof OrderTransactionEntity) {
  82.             return;
  83.         }
  85.         $paymentMethod = $lastTransaction->getPaymentMethod();
  87.         if (is_null($paymentMethod) && $lastTransaction->getPaymentMethodId() !== '') {
  88.             $paymentMethod = $this->paymentMethodService->getPaymentMethodById($lastTransaction->getPaymentMethodId());
  89.         }
  91.         $molliePaymentMethod = null;
  93.         if (! is_null($paymentMethod) && ! is_null($paymentMethod->getCustomFields())
  94.             && array_key_exists('mollie_payment_method_name', $paymentMethod->getCustomFields())) {
  95.             $molliePaymentMethod = $paymentMethod->getCustomFields()['mollie_payment_method_name'];
  96.         }
  98.         if (is_null($molliePaymentMethod) ||
  99.             ! in_array($molliePaymentMethod, ['klarnapaylater', 'klarnasliceit'])) {
  100.             return;
  101.         }
  103.         $customFields = $order->getCustomFields();
  105.         $mollieOrderId = null;
  107.         if (! is_null($customFields) &&
  108.             array_key_exists(CustomFieldService::CUSTOM_FIELDS_KEY_MOLLIE_PAYMENTS, $customFields) &&
  109.             array_key_exists('order_id', $customFields[CustomFieldService::CUSTOM_FIELDS_KEY_MOLLIE_PAYMENTS])) {
  110.             $mollieOrderId = $customFields[CustomFieldService::CUSTOM_FIELDS_KEY_MOLLIE_PAYMENTS]['order_id'];
  111.         }
  113.         if (is_null($mollieOrderId)) {
  114.             return;
  115.         }
  116.         $apiClient = $this->apiFactory->getClient($order->getSalesChannelId());
  118.         $mollieOrder = $apiClient->orders->get($mollieOrderId);
  120.         if (in_array($mollieOrder->status, ['created', 'authorized', 'shipping'])) {
  121.             $apiClient->orders->cancel($mollieOrderId);
  122.         }
  123.     }
  124. }