custom/plugins/RpayPayments/src/Components/Checkout/Subscriber/PaymentFailedSubscriber.php line 44

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\Checkout\Subscriber;
  14. use Exception;
  15. use Ratepay\RpayPayments\Components\Checkout\Model\Extension\OrderExtension;
  16. use Ratepay\RpayPayments\Components\Checkout\Model\RatepayOrderDataEntity;
  17. use Ratepay\RpayPayments\Components\Logging\Model\ApiRequestLogEntity;
  18. use Ratepay\RpayPayments\Components\RatepayApi\Service\Request\PaymentRequestService;
  19. use Ratepay\RpayPayments\Components\RatepayApi\Util\ResponseConverter;
  20. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  21. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  22. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  23. use Shopware\Storefront\Page\Checkout\Finish\CheckoutFinishPageLoadedEvent;
  24. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  25. use Symfony\Component\HttpFoundation\Session\Session;
  27. class PaymentFailedSubscriber implements EventSubscriberInterface
  28. {
  29.     private EntityRepository $ratepayApiLogRepository;
  31.     public function __construct(
  32.         EntityRepository $ratepayApiLogRepository
  33.     ) {
  34.         $this->ratepayApiLogRepository = $ratepayApiLogRepository;
  35.     }
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             CheckoutFinishPageLoadedEvent::class => 'onFinishPage',
  41.         ];
  42.     }
  44.     public function onFinishPage(CheckoutFinishPageLoadedEvent $event): void
  45.     {
  46.         if (!$event->getPage()->isPaymentFailed()) {
  47.             return;
  48.         }
  50.         $order = $event->getPage()->getOrder();
  51.         $ratepayData = $order->getExtension(OrderExtension::EXTENSION_NAME);
  52.         if ($ratepayData instanceof RatepayOrderDataEntity && !$ratepayData->isSuccessful()) {
  53.             $transactionId = $ratepayData->getTransactionId();
  55.             $criteria = new Criteria();
  56.             $criteria->addFilter(new EqualsFilter(ApiRequestLogEntity::FIELD_OPERATION, 'PAYMENT_REQUEST'));
  57.             $criteria->addFilter(new EqualsFilter(ApiRequestLogEntity::FIELD_ADDITIONAL_DATA . '.transactionId', $transactionId));
  58.             $criteria->addFilter(new EqualsFilter(ApiRequestLogEntity::FIELD_ADDITIONAL_DATA . '.orderNumber', $order->getOrderNumber()));
  59.             $criteria->setLimit(1);
  61.             $logEntry = $this->ratepayApiLogRepository->search($criteria, $event->getContext())->first();
  63.             if (!$logEntry instanceof ApiRequestLogEntity) {
  64.                 // log entry was not found.
  65.                 return;
  66.             }
  68.             try {
  69.                 $response = ResponseConverter::getResponseObjectByXml(
  70.                     PaymentRequestService::CALL_PAYMENT_REQUEST,
  71.                     $logEntry->getResponse()
  72.                 );
  73.             } catch (Exception $exception) {
  74.                 // response can not be converted.
  75.                 return;
  76.             }
  78.             $session = $event->getRequest()->getSession();
  79.             if ($session instanceof Session) {
  80.                 $message = null;
  81.                 if (method_exists($response, 'getCustomerMessage')) {
  82.                     $message = $response->getCustomerMessage();
  83.                 }
  85.                 $session->getFlashBag()->add('danger', !empty($message) ? $message : $response->getResultMessage());
  86.             }
  87.         }
  88.     }
  89. }