vendor/store.shopware.com/molliepayments/src/Subscriber/CancelOrderSubscriber.php line 89

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 Kiener\MolliePayments\Service\SettingsService;
  8. use Kiener\MolliePayments\Struct\Order\OrderAttributes;
  9. use Mollie\Api\Exceptions\ApiException;
  10. use Mollie\Api\MollieApiClient;
  11. use Mollie\Api\Types\OrderStatus;
  12. use Psr\Log\LoggerInterface;
  13. use Shopware\Core\System\StateMachine\Aggregation\StateMachineTransition\StateMachineTransitionActions;
  14. use Shopware\Core\System\StateMachine\Event\StateMachineStateChangeEvent;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class CancelOrderSubscriber implements EventSubscriberInterface
  18. {
  20.     /**
  21.      * These Shopware actions will automatically trigger
  22.      * our cancellation (if enabled in the config).
  23.      */
  24.     public const AUTOMATIC_TRIGGER_ACTIONS = [
  25.         StateMachineTransitionActions::ACTION_CANCEL
  26.     ];
  28.     /**
  29.      * Cancellations are only done for these Mollie states.
  30.      */
  31.     public const ALLOWED_CANCELLABLE_MOLLIE_STATES = [
  32.         OrderStatus::STATUS_CREATED,
  33.         OrderStatus::STATUS_AUTHORIZED,
  34.         OrderStatus::STATUS_SHIPPING
  35.     ];
  38.     /**
  39.      * @var OrderService
  40.      */
  41.     private $orderService;
  43.     /**
  44.      * @var MollieApiFactory
  45.      */
  46.     private $apiFactory;
  48.     /**
  49.      * @var SettingsService
  50.      */
  51.     private $settingsService;
  53.     /**
  54.      * @var LoggerInterface
  55.      */
  56.     private $logger;
  59.     /**
  60.      * @param MollieApiFactory $apiFactory
  61.      * @param OrderService $orderService
  62.      * @param SettingsService $settingsService
  63.      * @param LoggerInterface $loggerService
  64.      */
  65.     public function __construct(MollieApiFactory $apiFactory, OrderService $orderService, SettingsService $settingsService, LoggerInterface $loggerService)
  66.     {
  67.         $this->orderService = $orderService;
  68.         $this->apiFactory = $apiFactory;
  69.         $this->settingsService = $settingsService;
  70.         $this->logger = $loggerService;
  71.     }
  74.     /**
  75.      * @return array<mixed>
  76.      */
  77.     public static function getSubscribedEvents(): array
  78.     {
  79.         return [
  80.             'state_machine.order.state_changed' => ['onOrderStateChanges']
  81.         ];
  82.     }
  85.     /**
  86.      * @param StateMachineStateChangeEvent $event
  87.      * @return void
  88.      */
  89.     public function onOrderStateChanges(StateMachineStateChangeEvent $event): void
  90.     {
  91.         if ($event->getTransitionSide() !== StateMachineStateChangeEvent::STATE_MACHINE_TRANSITION_SIDE_ENTER) {
  92.             return;
  93.         }
  95.         $transitionName = $event->getTransition()->getTransitionName();
  97.         try {
  99.             # if we don't have at least one of our
  100.             # actions that automatically trigger this feature, continue
  101.             if (!in_array($transitionName, self::AUTOMATIC_TRIGGER_ACTIONS, true)) {
  102.                 return;
  103.             }
  105.             # get order and extract our Mollie Order ID
  106.             $order = $this->orderService->getOrder($event->getTransition()->getEntityId(), $event->getContext());
  108.             # -----------------------------------------------------------------------------------------------------------------------
  110.             # check if we have activated this feature in our plugin configuration
  111.             $settings = $this->settingsService->getSettings($order->getSalesChannelId());
  113.             if (!$settings->isAutomaticCancellation()) {
  114.                 return;
  115.             }
  117.             # -----------------------------------------------------------------------------------------------------------------------
  119.             $orderAttributes = new OrderAttributes($order);
  121.             $mollieOrderId = $orderAttributes->getMollieOrderId();
  123.             # if we don't have a Mollie Order ID continue
  124.             # this can also happen for subscriptions where we only have a tr_xxx Transaction ID.
  125.             # but cancellation only works on orders anyway
  126.             if (empty($mollieOrderId)) {
  127.                 return;
  128.             }
  130.             # -----------------------------------------------------------------------------------------------------------------------
  132.             $apiClient = $this->apiFactory->getClient($order->getSalesChannelId());
  134.             $mollieOrder = $apiClient->orders->get($mollieOrderId);
  136.             # check if the status of the Mollie order allows
  137.             # a cancellation based on our whitelist.
  138.             if (in_array($mollieOrder->status, self::ALLOWED_CANCELLABLE_MOLLIE_STATES, true)) {
  139.                 $this->logger->debug('Starting auto-cancellation of order: ' . $order->getOrderNumber() . ', ' . $mollieOrderId);
  141.                 $apiClient->orders->cancel($mollieOrderId);
  143.                 $this->logger->info('Auto-cancellation of order: ' . $order->getOrderNumber() . ', ' . $mollieOrderId . ' successfully executed after transition: ' . $transitionName);
  144.             }
  145.         } catch (ApiException $e) {
  146.             $this->logger->error(
  147.                 'Error when executing auto-cancellation of an order after transition: ' . $transitionName,
  148.                 [
  149.                     'error' => $e,
  150.                 ]
  151.             );
  152.         }
  153.     }
  154. }