custom/plugins/RpayPayments/src/Components/CreditworthinessPreCheck/Subscriber/AccountSubscriber.php line 59

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. /*
  6.  * Copyright (c) Ratepay GmbH
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Ratepay\RpayPayments\Components\CreditworthinessPreCheck\Subscriber;
  14. use RatePAY\Model\Response\PaymentQuery;
  15. use Ratepay\RpayPayments\Components\Account\Event\PaymentUpdateRequestBagValidatedEvent;
  16. use Ratepay\RpayPayments\Components\CreditworthinessPreCheck\Dto\PaymentQueryData;
  17. use Ratepay\RpayPayments\Components\CreditworthinessPreCheck\Service\Request\PaymentQueryService;
  18. use Ratepay\RpayPayments\Components\PaymentHandler\AbstractPaymentHandler;
  19. use Ratepay\RpayPayments\Components\PluginConfig\Service\ConfigService;
  20. use Ratepay\RpayPayments\Components\RedirectException\Exception\ForwardException;
  21. use Ratepay\RpayPayments\Exception\RatepayException;
  22. use Shopware\Core\Checkout\Cart\Order\OrderConverter;
  23. use Shopware\Core\Checkout\Order\OrderEntity;
  24. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  25. use Symfony\Contracts\Translation\TranslatorInterface;
  27. class AccountSubscriber implements EventSubscriberInterface
  28. {
  29.     private PaymentQueryService $paymentQueryService;
  31.     private OrderConverter $orderConverter;
  33.     private TranslatorInterface $translator;
  35.     private ConfigService $configService;
  37.     public function __construct(
  38.         TranslatorInterface $translator,
  39.         PaymentQueryService $paymentQueryService,
  40.         OrderConverter $orderConverter,
  41.         ConfigService $configService
  42.     ) {
  43.         $this->translator = $translator;
  44.         $this->paymentQueryService = $paymentQueryService;
  45.         $this->orderConverter = $orderConverter;
  46.         $this->configService = $configService;
  47.     }
  49.     public static function getSubscribedEvents(): array
  50.     {
  51.         return [
  52.             PaymentUpdateRequestBagValidatedEvent::class => 'onRequestDataValidated',
  53.         ];
  54.     }
  56.     /**
  57.      * @throws ForwardException
  58.      */
  59.     public function onRequestDataValidated(PaymentUpdateRequestBagValidatedEvent $event): void
  60.     {
  61.         try {
  62.             $paymentQuery = $this->paymentQueryService->doRequest(new PaymentQueryData(
  63.                 $event->getSalesChannelContext(),
  64.                 $this->orderConverter->convertToCart($event->getOrderEntity(), $event->getContext()),
  65.                 $event->getRequestDataBag(),
  66.                 $event->getRequestDataBag()->get('ratepay')->get('transactionId'),
  67.                 $this->configService->isSendDiscountsAsCartItem(),
  68.                 $this->configService->isSendShippingCostsAsCartItem()
  69.             ));
  71.             $response = $paymentQuery->getResponse();
  72.             if ($response instanceof PaymentQuery && $response->getStatusCode() === 'OK') {
  73.                 if (!in_array($event->getPaymentHandler()::getRatepayPaymentMethodName(), $response->getAdmittedPaymentMethods(), true)) {
  74.                     throw $this->createException(
  75.                         $event->getOrderEntity(),
  76.                         $this->translator->trans('error.' . AbstractPaymentHandler::ERROR_SNIPPET_VIOLATION_PREFIX . CheckoutValidationSubscriber::CODE_METHOD_NOT_AVAILABLE)
  77.                     );
  78.                 }
  79.             } else {
  80.                 throw $this->createException(
  81.                     $event->getOrderEntity(),
  82.                     (string) $response->getReasonMessage()
  83.                 );
  84.             }
  85.         } catch (RatepayException $ratepayException) {
  86.             throw $this->createException(
  87.                 $event->getOrderEntity(),
  88.                 $ratepayException->getMessage()
  89.             );
  90.         }
  91.     }
  93.     private function createException(OrderEntity $orderEntity, ?string $message): ForwardException
  94.     {
  95.         return (new ForwardException(
  96.             'frontend.account.edit-order.page',
  97.             [
  98.                 'orderId' => $orderEntity->getId(),
  99.             ],
  100.             [
  101.                 'ratepay-errors' => [$message],
  102.             ]
  103.         )
  104.         )->setCustomerMessage($message);
  105.     }
  106. }