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

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