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

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Kiener\MolliePayments\Subscriber;
  5. use Kiener\MolliePayments\Factory\MollieApiFactory;
  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 Psr\Log\LoggerInterface;
  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;
  27.     /**
  28.      * @var OrderService
  29.      */
  30.     private $orderService;
  32.     /**
  33.      * @var LoggerInterface
  34.      */
  35.     private $logger;
  36.     /**
  37.      * @var MollieApiFactory
  38.      */
  39.     private $apiFactory;
  42.     /**
  43.      * @param MollieApiFactory $apiFactory
  44.      * @param OrderService $orderService
  45.      * @param LoggerInterface $loggerService
  46.      * @param string $shopwareVersion
  47.      */
  48.     public function __construct(MollieApiFactory $apiFactory, OrderService $orderService, LoggerInterface $loggerService, string $shopwareVersion)
  49.     {
  50.         $this->orderService = $orderService;
  51.         $this->shopwareVersion = $shopwareVersion;
  52.         $this->logger = $loggerService;
  53.         $this->apiFactory = $apiFactory;
  54.     }
  56.     public static function getSubscribedEvents()
  57.     {
  58.         return [
  59.             'state_machine.order.state_changed' => ['onOrderStateChanges']
  60.         ];
  61.     }
  63.     public function onOrderStateChanges(StateMachineStateChangeEvent $event): void
  64.     {
  65.         if ($event->getTransitionSide() !== StateMachineStateChangeEvent::STATE_MACHINE_TRANSITION_SIDE_ENTER) {
  66.             return;
  67.         }
  69.         $allowedStates = [StateMachineTransitionActions::ACTION_CANCEL => true];
  71.         if (version_compare($this->shopwareVersion, '6.2', '>=')) {
  72.             $allowedStates[StateMachineTransitionActions::ACTION_FAIL] = true;
  73.         }
  75.         $transitionName = $event->getTransition()->getTransitionName();
  77.         if (!isset($allowedStates[$transitionName])) {
  78.             return;
  79.         }
  81.         $order = $this->orderService->getOrder($event->getTransition()->getEntityId(), $event->getContext());
  83.         $customFields = $order->getCustomFields() ?? [];
  85.         $mollieOrderId = $customFields['mollie_payments']['order_id'] ?? '';
  87.         if (empty($mollieOrderId)) {
  88.             return;
  89.         }
  91.         try {
  92.             $apiClient = $this->apiFactory->getClient($order->getSalesChannelId());
  94.             $mollieOrder = $apiClient->orders->get($mollieOrderId);
  96.             if (in_array($mollieOrder->status, [self::MOLLIE_CANCEL_ORDER_STATES])) {
  97.                 $apiClient->orders->cancel($mollieOrderId);
  98.             }
  99.         } catch (ApiException $e) {
  100.             $this->logger->warning(
  101.                 $e->getMessage()
  102.             );
  103.         }
  104.     }
  105. }