custom/plugins/MolliePayments/src/Compatibility/Bundles/FlowBuilder/Actions/RefundOrderAction.php line 78

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  4. namespace Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Actions;
  6. use Kiener\MolliePayments\Components\RefundManager\RefundManagerInterface;
  7. use Kiener\MolliePayments\Components\RefundManager\Request\RefundRequest;
  8. use Kiener\MolliePayments\Service\OrderServiceInterface;
  9. use Psr\Log\LoggerInterface;
  10. use Shopware\Core\Content\Flow\Dispatching\Action\FlowAction;
  11. use Shopware\Core\Content\Flow\Dispatching\StorableFlow;
  12. use Shopware\Core\Framework\Context;
  13. use Shopware\Core\Framework\Event\FlowEvent;
  14. use Shopware\Core\Framework\Event\OrderAware;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class RefundOrderAction extends FlowAction implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var OrderServiceInterface
  21.      */
  22.     private $orderService;
  24.     /**
  25.      * @var RefundManagerInterface
  26.      */
  27.     private $refundManager;
  29.     /**
  30.      * @var LoggerInterface
  31.      */
  32.     private $logger;
  34.     public function __construct(OrderServiceInterface $orderService, RefundManagerInterface $refundManager, LoggerInterface $logger)
  35.     {
  36.         $this->orderService = $orderService;
  37.         $this->refundManager = $refundManager;
  38.         $this->logger = $logger;
  39.     }
  41.     public static function getName(): string
  42.     {
  43.         return 'action.mollie.order.refund';
  44.     }
  46.     /**
  47.      * @return string[]
  48.      */
  49.     public static function getSubscribedEvents(): array
  50.     {
  51.         return [
  52.             self::getName() => 'handle',
  53.         ];
  54.     }
  56.     /**
  57.      * @return string[]
  58.      */
  59.     public function requirements(): array
  60.     {
  61.         return [OrderAware::class];
  62.     }
  64.     /**
  65.      * @throws \Exception
  66.      */
  67.     public function handleFlow(StorableFlow $flow): void
  68.     {
  69.         $orderId = $flow->getStore('orderId');
  71.         $this->refundOrder($orderId, $flow->getContext());
  72.     }
  74.     /**
  75.      * @throws \Exception
  76.      * @phpstan-ignore class.notFound
  77.      */
  78.     public function handle(FlowEvent $event): void
  79.     {
  80.         /** @phpstan-ignore class.notFound */
  81.         $config = $event->getConfig();
  83.         if (empty($config)) {
  84.             return;
  85.         }
  86.         /** @phpstan-ignore class.notFound */
  87.         $baseEvent = $event->getEvent();
  89.         if (! $baseEvent instanceof OrderAware) {
  90.             return;
  91.         }
  93.         $orderId = $baseEvent->getOrderId();
  95.         $this->refundOrder($orderId, $baseEvent->getContext());
  96.     }
  98.     /**
  99.      * @throws \Exception
  100.      */
  101.     private function refundOrder(string $orderId, Context $context): void
  102.     {
  103.         $orderNumber = '';
  105.         try {
  106.             $order = $this->orderService->getOrder($orderId, $context);
  108.             $orderNumber = $order->getOrderNumber();
  110.             $this->logger->info('Starting Refund through Flow Builder Action for order: ' . $orderNumber);
  112.             $request = new RefundRequest(
  113.                 (string) $order->getOrderNumber(),
  114.                 'Refund through Shopware Flow Builder',
  115.                 '',
  116.                 null
  117.             );
  119.             $this->refundManager->refund($order, $request, $context);
  120.         } catch (\Exception $ex) {
  121.             $this->logger->error(
  122.                 'Error when refunding order with Flow Builder Action',
  123.                 [
  124.                     'error' => $ex->getMessage(),
  125.                     'order' => $orderNumber,
  126.                 ]
  127.             );
  129.             throw $ex;
  130.         }
  131.     }
  132. }