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

Open in your IDE?
  1. <?php
  3. namespace Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Actions;
  5. use Kiener\MolliePayments\Components\RefundManager\RefundManagerInterface;
  6. use Kiener\MolliePayments\Components\RefundManager\Request\RefundRequest;
  7. use Kiener\MolliePayments\Service\OrderServiceInterface;
  8. use Psr\Log\LoggerInterface;
  9. use Shopware\Core\Content\Flow\Dispatching\Action\FlowAction;
  10. use Shopware\Core\Framework\Event\FlowEvent;
  11. use Shopware\Core\Framework\Event\OrderAware;
  13. class RefundOrderAction extends FlowAction
  14. {
  16.     /**
  17.      * @var OrderServiceInterface
  18.      */
  19.     private $orderService;
  21.     /**
  22.      * @var RefundManagerInterface
  23.      */
  24.     private $refundManager;
  26.     /**
  27.      * @var LoggerInterface
  28.      */
  29.     private $logger;
  32.     /**
  33.      * @param OrderServiceInterface $orderService
  34.      * @param RefundManagerInterface $refundManager
  35.      * @param LoggerInterface $logger
  36.      */
  37.     public function __construct(OrderServiceInterface $orderService, RefundManagerInterface $refundManager, LoggerInterface $logger)
  38.     {
  39.         $this->orderService = $orderService;
  40.         $this->refundManager = $refundManager;
  41.         $this->logger = $logger;
  42.     }
  44.     /**
  45.      * @return string
  46.      */
  47.     public static function getName(): string
  48.     {
  49.         return 'action.mollie.order.refund';
  50.     }
  52.     /**
  53.      * @return string[]
  54.      */
  55.     public static function getSubscribedEvents(): array
  56.     {
  57.         return [
  58.             self::getName() => 'handle',
  59.         ];
  60.     }
  62.     /**
  63.      * @return string[]
  64.      */
  65.     public function requirements(): array
  66.     {
  67.         return [OrderAware::class];
  68.     }
  70.     /**
  71.      * @param FlowEvent $event
  72.      * @throws \Exception
  73.      */
  74.     public function handle(FlowEvent $event): void
  75.     {
  76.         $config = $event->getConfig();
  78.         if (empty($config)) {
  79.             return;
  80.         }
  82.         $baseEvent = $event->getEvent();
  84.         if (!$baseEvent instanceof OrderAware) {
  85.             return;
  86.         }
  88.         $this->refundOrder($baseEvent, $config);
  89.     }
  91.     /**
  92.      * @param OrderAware $baseEvent
  93.      * @param array<mixed> $config
  94.      * @throws \Exception
  95.      */
  96.     private function refundOrder(OrderAware $baseEvent, array $config): void
  97.     {
  98.         $orderNumber = '';
  100.         try {
  101.             $orderId = $baseEvent->getOrderId();
  103.             $order = $this->orderService->getOrder($orderId, $baseEvent->getContext());
  105.             $orderNumber = $order->getOrderNumber();
  107.             $this->logger->info('Starting Refund through Flow Builder Action for order: ' . $orderNumber);
  109.             $request = new RefundRequest(
  110.                 (string)$order->getOrderNumber(),
  111.                 'Refund through Shopware Flow Builder',
  112.                 null
  113.             );
  115.             $this->refundManager->refund($order, $request, $baseEvent->getContext());
  116.         } catch (\Exception $ex) {
  117.             $this->logger->error(
  118.                 'Error when refunding order with Flow Builder Action',
  119.                 [
  120.                     'error' => $ex->getMessage(),
  121.                     'order' => $orderNumber,
  122.                 ]
  123.             );
  125.             throw $ex;
  126.         }
  127.     }
  128. }