custom/plugins/PolPaymentPayolutionSW6/src/EventListener/CheckoutFinishEventListener.php line 98

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace PolPaymentPayolutionSW6\EventListener;
  7. use PolPaymentPayolutionSW6\Component\CustomFields\CustomFieldsInterface;
  8. use PolPaymentPayolutionSW6\Component\DataHandler\OrderTransactionDataHandler\OrderTransactionDataHandlerInterface;
  9. use PolPaymentPayolutionSW6\Component\DataHandler\OrderTransactionStatusHandler\OrderTransactionStatusHandlerInterface;
  10. use PolPaymentPayolutionSW6\Component\PaymentMethodConfiguration\PaymentMethodConfigurationServiceInterface;
  11. use PolPaymentPayolutionSW6\Component\Validator\PaymentRequestValidator\PaymentRequestValidatorInterface;
  12. use PolPaymentPayolutionSW6\Event\PreAuthFinished;
  13. use PolPaymentPayolutionSW6\PayolutionApi\Client\Exception\InvalidXmlException;
  14. use PolPaymentPayolutionSW6\PayolutionApi\Process\Exception\ProcessFailedException;
  15. use PolPaymentPayolutionSW6\PayolutionApi\Request\RequestFactory\PaymentRequestFactoryInterface;
  16. use PolPaymentPayolutionSW6\PayolutionApi\Request\RequestFactory\Transaction\TransactionRequestFactoryInterface;
  17. use PolPaymentPayolutionSW6\PayolutionApi\Request\RequestProcessor\RequestProcessorInterface;
  18. use Psr\Log\LoggerInterface;
  19. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionEntity;
  20. use Shopware\Core\Framework\Context;
  21. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  22. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  23. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  24. use Shopware\Core\Framework\Validation\DataBag\RequestDataBag;
  25. use Shopware\Storefront\Event\RouteRequest\HandlePaymentMethodRouteRequestEvent;
  26. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  28. class CheckoutFinishEventListener implements EventSubscriberInterface
  29. {
  30.     /**
  31.      * @var EntityRepositoryInterface
  32.      */
  33.     private $orderTransactionRepository;
  35.     /**
  36.      * @var OrderTransactionDataHandlerInterface
  37.      */
  38.     private $orderTransactionDataHandler;
  40.     /**
  41.      * @var OrderTransactionStatusHandlerInterface
  42.      */
  43.     private $orderTransactionStatusHandler;
  45.     /**
  46.      * @var TransactionRequestFactoryInterface
  47.      */
  48.     private $transactionRequestFactory;
  50.     /**
  51.      * @var PaymentRequestFactoryInterface
  52.      */
  53.     private $paymentRequestFactory;
  55.     /**
  56.      * @var RequestProcessorInterface
  57.      */
  58.     private $captureRequestProcessor;
  60.     /**
  61.      * @var PaymentMethodConfigurationServiceInterface
  62.      */
  63.     private $paymentMethodConfigurationService;
  65.     /**
  66.      * @var LoggerInterface
  67.      */
  68.     private $logger;
  70.     public function __construct(
  71.         EntityRepositoryInterface $orderTransactionRepository,
  72.         OrderTransactionDataHandlerInterface $orderTransactionDataHandler,
  73.         OrderTransactionStatusHandlerInterface $orderTransactionStatusHandler,
  74.         TransactionRequestFactoryInterface $transactionRequestFactory,
  75.         PaymentRequestFactoryInterface $paymentRequestFactory,
  76.         RequestProcessorInterface $captureRequestProcessor,
  77.         PaymentMethodConfigurationServiceInterface $paymentMethodConfigurationService,
  78.         LoggerInterface $logger
  79.     ) {
  80.         $this->orderTransactionRepository = $orderTransactionRepository;
  81.         $this->orderTransactionDataHandler = $orderTransactionDataHandler;
  82.         $this->orderTransactionStatusHandler = $orderTransactionStatusHandler;
  83.         $this->transactionRequestFactory = $transactionRequestFactory;
  84.         $this->paymentRequestFactory = $paymentRequestFactory;
  85.         $this->captureRequestProcessor = $captureRequestProcessor;
  86.         $this->paymentMethodConfigurationService = $paymentMethodConfigurationService;
  87.         $this->logger = $logger;
  88.     }
  90.     public static function getSubscribedEvents(): array
  91.     {
  92.         return [
  93.             PreAuthFinished::class => 'onPreAuthFinish',
  94.             HandlePaymentMethodRouteRequestEvent::class => 'addRequiredRequestParameter',
  95.         ];
  96.     }
  98.     public function onPreAuthFinish(PreAuthFinished $event): void
  99.     {
  100.         $criteria = new Criteria();
  101.         $criteria->addFilter(new EqualsFilter('orderId', $event->getOrder()->getId()));
  102.         $criteria->addAssociations(['order.customer', 'order.currency', 'order.lineItems', 'order.deliveries', 'order.salesChannel', 'paymentMethod']);
  104.         $context = $event->getContext();
  106.         /** @var OrderTransactionEntity $orderTransaction */
  107.         $orderTransaction = $this->orderTransactionRepository->search($criteria, $context)->filter(function (OrderTransactionEntity $orderTransaction) use ($event): bool {
  108.             return $orderTransaction->getPaymentMethodId() === $event->getSalesChannelContext()->getPaymentMethod()->getId();
  109.         })->last();
  111.         $this->updateOrderTransactionLineItems($orderTransaction, $context);
  113.         if (!$this->paymentMethodConfigurationService->paymentMethodSupportsAutoCapture($event->getSalesChannelContext()->getPaymentMethod()) || $orderTransaction->getCustomFields()[CustomFieldsInterface::IS_PAYMENT_CAPTURED]) {
  114.             return;
  115.         }
  117.         try {
  118.             $transaction = $this->transactionRequestFactory->createTransaction(
  119.                 $orderTransaction,
  120.                 new RequestDataBag(),
  121.                 $orderTransaction->getAmount()->getTotalPrice(),
  122.                 null,
  123.                 [PaymentRequestValidatorInterface::IS_CAPTURE_REQUEST => true]
  124.             );
  125.             $captureRequest = $this->paymentRequestFactory->createRequest($orderTransaction, $transaction, $orderTransaction->getOrder()->getSalesChannel()->getId());
  126.             $captureRequest->setPreAuthorizationUniqueId($orderTransaction->getCustomFields()[CustomFieldsInterface::UNIQUE_ID]);
  128.             $captureResponse = $this->captureRequestProcessor->processRequest($captureRequest);
  130.             $this->orderTransactionDataHandler->updateOrderTransactionData($orderTransaction, $context, [
  131.                 CustomFieldsInterface::IS_PAYMENT_CAPTURED => true,
  132.                 CustomFieldsInterface::REMAINING_CAPTURE_AMOUNT => 0,
  133.                 CustomFieldsInterface::REMAINING_REFUND_AMOUNT => $orderTransaction->getAmount()->getTotalPrice(),
  134.             ]);
  136.             foreach ($orderTransaction->getOrder()->getLineItems() as $orderLineItem) {
  137.                 $this->orderTransactionDataHandler->updateOrderLineItemData($orderLineItem, $context, [CustomFieldsInterface::IS_PAYMENT_CAPTURED => true]);
  138.             }
  140.             $this->orderTransactionStatusHandler->setPaid($orderTransaction, $context);
  142.             $this->logger->info('payment auto captured due enabled setting', $captureResponse->getResponseAsArray());
  143.         } catch (InvalidXmlException $xmlException) {
  144.             $this->logger->error('payment auto capture invalid xml', ['message' => $xmlException->getMessage()]);
  145.         } catch (ProcessFailedException $processFailedException) {
  146.             $this->logger->error('payment auto capture process failed', $processFailedException->getResponse()->getResponseAsArray());
  147.         } catch (\Throwable $e) {
  148.             $this->logger->error('payment auto capture error occurred', ['message' => $e->getMessage()]);
  149.         }
  150.     }
  152.     public function addRequiredRequestParameter(HandlePaymentMethodRouteRequestEvent $event): void
  153.     {
  154.         $this->logger->debug('Adding request parameter');
  155.         $storefrontRequest = $event->getStorefrontRequest();
  156.         $storeApiRequest = $event->getStoreApiRequest();
  158.         $originalRoute = $storefrontRequest->attributes->get('_route');
  159.         if ($originalRoute !== 'frontend.account.edit-order.update-order') {
  160.             return;
  161.         }
  163.         $requiredRequestParameter = $this->getRequiredRequestParameter();
  165.         foreach ($requiredRequestParameter as $requestParameter) {
  166.             $storeApiRequest->request->set(
  167.                 $requestParameter,
  168.                 $storefrontRequest->request->get($requestParameter)
  169.             );
  170.             $storeApiRequest->request->set(
  171.                 $requestParameter,
  172.                 $storefrontRequest->request->get($requestParameter)
  173.             );
  174.         }
  176.         $this->logger->debug('Added request parameter');
  177.     }
  179.     private function getRequiredRequestParameter(): array
  180.     {
  181.         return [
  182.             PaymentRequestValidatorInterface::PRE_CHECK_ID,
  183.             PaymentRequestValidatorInterface::TRANSACTION_ID,
  184.             PaymentRequestValidatorInterface::CALCULATION_ID,
  185.             PaymentRequestValidatorInterface::B2B_COMPANY_TYPE,
  186.             PaymentRequestValidatorInterface::B2B_COMPANY_NAME,
  187.             PaymentRequestValidatorInterface::B2B_COMPANY_VAT_ID,
  188.             PaymentRequestValidatorInterface::B2B_COMPANY_OWNER_FIRST_NAME,
  189.             PaymentRequestValidatorInterface::B2B_COMPANY_OWNER_LAST_NAME,
  190.             PaymentRequestValidatorInterface::B2B_COMPANY_ACCEPT_CREDIT_CHECK,
  191.             PaymentRequestValidatorInterface::BIRTHDAY_DAY,
  192.             PaymentRequestValidatorInterface::BIRTHDAY_MONTH,
  193.             PaymentRequestValidatorInterface::BIRTHDAY_YEAR,
  194.             PaymentRequestValidatorInterface::INVOICE_ACCEPT_CREDIT_CHECK,
  195.             PaymentRequestValidatorInterface::INSTALLMENTS_ACCEPT_CREDIT_CHECK,
  196.             PaymentRequestValidatorInterface::INSTALLMENTS_DURATION,
  197.             PaymentRequestValidatorInterface::INSTALLMENTS_ACCOUNT_HOLDER,
  198.             PaymentRequestValidatorInterface::INSTALLMENTS_ACCOUNT_IBAN,
  199.             PaymentRequestValidatorInterface::DIRECT_DEBIT_MANDATE_OWNER,
  200.             PaymentRequestValidatorInterface::DIRECT_DEBIT_MANDATE_IBAN,
  201.             PaymentRequestValidatorInterface::DIRECT_DEBIT_ACCEPT_CREDIT_CHECK,
  202.             PaymentRequestValidatorInterface::DIRECT_DEBIT_ACCEPT_MANDATE,
  203.         ];
  204.     }
  206.     private function updateOrderTransactionLineItems(OrderTransactionEntity $orderTransaction, Context $context): void
  207.     {
  208.         foreach ($orderTransaction->getOrder()->getLineItems() as $orderLineItem) {
  209.             $this->orderTransactionDataHandler->updateOrderLineItemData(
  210.                 $orderLineItem,
  211.                 $context,
  212.                 [
  213.                     CustomFieldsInterface::IS_PAYOLUTION_PAYMENT => true,
  214.                     CustomFieldsInterface::IS_PAYMENT_CAPTURED => false,
  215.                     CustomFieldsInterface::IS_PAYMENT_REFUNDED => false,
  216.                 ]
  217.             );
  218.         }
  219.     }
  220. }