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

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\Content\Flow\Dispatching\StorableFlow;
  11. use Shopware\Core\Framework\Context;
  12. use Shopware\Core\Framework\Event\FlowEvent;
  13. use Shopware\Core\Framework\Event\OrderAware;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class RefundOrderAction extends FlowAction implements EventSubscriberInterface
  17. {
  18.     /**
  19.      * @var OrderServiceInterface
  20.      */
  21.     private $orderService;
  23.     /**
  24.      * @var RefundManagerInterface
  25.      */
  26.     private $refundManager;
  28.     /**
  29.      * @var LoggerInterface
  30.      */
  31.     private $logger;
  34.     /**
  35.      * @param OrderServiceInterface $orderService
  36.      * @param RefundManagerInterface $refundManager
  37.      * @param LoggerInterface $logger
  38.      */
  39.     public function __construct(OrderServiceInterface $orderService, RefundManagerInterface $refundManager, LoggerInterface $logger)
  40.     {
  41.         $this->orderService = $orderService;
  42.         $this->refundManager = $refundManager;
  43.         $this->logger = $logger;
  44.     }
  46.     /**
  47.      * @return string
  48.      */
  49.     public static function getName(): string
  50.     {
  51.         return 'action.mollie.order.refund';
  52.     }
  54.     /**
  55.      * @return string[]
  56.      */
  57.     public static function getSubscribedEvents(): array
  58.     {
  59.         return [
  60.             self::getName() => 'handle',
  61.         ];
  62.     }
  64.     /**
  65.      * @return string[]
  66.      */
  67.     public function requirements(): array
  68.     {
  69.         return [OrderAware::class];
  70.     }
  72.     /**
  73.      * @param StorableFlow $flow
  74.      * @throws \Exception
  75.      * @return void
  76.      */
  77.     public function handleFlow(StorableFlow $flow): void
  78.     {
  79.         $orderId = $flow->getStore('orderId');
  81.         $this->refundOrder($orderId, $flow->getContext());
  82.     }
  84.     /**
  85.      * @param FlowEvent $event
  86.      * @throws \Exception
  87.      */
  88.     public function handle(FlowEvent $event): void
  89.     {
  90.         $config = $event->getConfig();
  92.         if (empty($config)) {
  93.             return;
  94.         }
  96.         $baseEvent = $event->getEvent();
  98.         if (!$baseEvent instanceof OrderAware) {
  99.             return;
  100.         }
  102.         $orderId = $baseEvent->getOrderId();
  104.         $this->refundOrder($orderId, $baseEvent->getContext());
  105.     }
  107.     /**
  108.      * @param string $orderId
  109.      * @param Context $context
  110.      * @throws \Exception
  111.      * @return void
  112.      */
  113.     private function refundOrder(string $orderId, Context $context): void
  114.     {
  115.         $orderNumber = '';
  117.         try {
  118.             $order = $this->orderService->getOrder($orderId, $context);
  120.             $orderNumber = $order->getOrderNumber();
  122.             $this->logger->info('Starting Refund through Flow Builder Action for order: ' . $orderNumber);
  124.             $request = new RefundRequest(
  125.                 (string)$order->getOrderNumber(),
  126.                 'Refund through Shopware Flow Builder',
  127.                 '',
  128.                 null
  129.             );
  131.             $this->refundManager->refund($order, $request, $context);
  132.         } catch (\Exception $ex) {
  133.             $this->logger->error(
  134.                 'Error when refunding order with Flow Builder Action',
  135.                 [
  136.                     'error' => $ex->getMessage(),
  137.                     'order' => $orderNumber,
  138.                 ]
  139.             );
  141.             throw $ex;
  142.         }
  143.     }
  144. }