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

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