custom/plugins/MolliePayments/src/Subscriber/CancelMollieOrderSubscriber.php line 61

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Kiener\MolliePayments\Subscriber;
  5. use Kiener\MolliePayments\Service\OrderService;
  6. use Mollie\Api\Exceptions\ApiException;
  7. use Mollie\Api\MollieApiClient;
  8. use Mollie\Api\Types\OrderStatus;
  9. use Psr\Log\LoggerInterface;
  10. use Shopware\Core\System\StateMachine\Aggregation\StateMachineTransition\StateMachineTransitionActions;
  11. use Shopware\Core\System\StateMachine\Event\StateMachineStateChangeEvent;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class CancelMollieOrderSubscriber implements EventSubscriberInterface
  15. {
  16.     public const MOLLIE_CANCEL_ORDER_STATES = [
  17.         OrderStatus::STATUS_CREATED,
  18.         OrderStatus::STATUS_AUTHORIZED,
  19.         OrderStatus::STATUS_SHIPPING
  20.     ];
  21.     /**
  22.      * @var string
  23.      */
  24.     private $shopwareVersion;
  25.     /**
  26.      * @var MollieApiClient
  27.      */
  28.     private $apiClient;
  29.     /**
  30.      * @var OrderService
  31.      */
  32.     private $orderService;
  34.     /**
  35.      * @var LoggerInterface
  36.      */
  37.     private $logger;
  40.     /**
  41.      * @param MollieApiClient $apiClient
  42.      * @param OrderService $orderService
  43.      * @param LoggerInterface $loggerService
  44.      * @param string $shopwareVersion
  45.      */
  46.     public function __construct(MollieApiClient $apiClient, OrderService $orderService, LoggerInterface $loggerService, string $shopwareVersion)
  47.     {
  48.         $this->apiClient = $apiClient;
  49.         $this->orderService = $orderService;
  50.         $this->shopwareVersion = $shopwareVersion;
  51.         $this->logger = $loggerService;
  52.     }
  54.     public static function getSubscribedEvents()
  55.     {
  56.         return [
  57.             'state_machine.order.state_changed' => ['onOrderStateChanges']
  58.         ];
  59.     }
  61.     public function onOrderStateChanges(StateMachineStateChangeEvent $event): void
  62.     {
  63.         if ($event->getTransitionSide() !== StateMachineStateChangeEvent::STATE_MACHINE_TRANSITION_SIDE_ENTER) {
  64.             return;
  65.         }
  67.         $allowedStates = [StateMachineTransitionActions::ACTION_CANCEL => true];
  69.         if (version_compare($this->shopwareVersion, '6.2', '>=')) {
  70.             $allowedStates[StateMachineTransitionActions::ACTION_FAIL] = true;
  71.         }
  73.         $transitionName = $event->getTransition()->getTransitionName();
  75.         if (!isset($allowedStates[$transitionName])) {
  76.             return;
  77.         }
  79.         $order = $this->orderService->getOrder($event->getTransition()->getEntityId(), $event->getContext());
  81.         $customFields = $order->getCustomFields() ?? [];
  83.         $mollieOrderId = $customFields['mollie_payments']['order_id'] ?? '';
  85.         if (empty($mollieOrderId)) {
  86.             return;
  87.         }
  89.         try {
  90.             $mollieOrder = $this->apiClient->orders->get($mollieOrderId);
  92.             if (in_array($mollieOrder->status, [self::MOLLIE_CANCEL_ORDER_STATES])) {
  93.                 $this->apiClient->orders->cancel($mollieOrderId);
  94.             }
  95.         } catch (ApiException $e) {
  97.             $this->logger->warning(
  98.                 $e->getMessage()
  99.             );
  100.         }
  102.     }
  103. }