custom/plugins/PayonePayment/src/EventListener/CheckoutFinishEventListener.php line 43

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace PayonePayment\EventListener;
  7. use PayonePayment\DataAbstractionLayer\Aggregate\PayonePaymentOrderTransactionDataEntity;
  8. use PayonePayment\DataAbstractionLayer\Entity\Mandate\PayonePaymentMandateEntity;
  9. use PayonePayment\DataAbstractionLayer\Extension\PayonePaymentOrderTransactionExtension;
  10. use PayonePayment\Installer\PaymentMethodInstaller;
  11. use PayonePayment\Storefront\Struct\CheckoutFinishPaymentData;
  12. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionEntity;
  13. use Shopware\Core\Checkout\Order\OrderEntity;
  14. use Shopware\Core\Checkout\Payment\PaymentMethodEntity;
  15. use Shopware\Core\Framework\Context;
  16. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  19. use Shopware\Storefront\Page\Checkout\Finish\CheckoutFinishPageLoadedEvent;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  22. class CheckoutFinishEventListener implements EventSubscriberInterface
  23. {
  24.     private EntityRepositoryInterface $mandateRepository;
  26.     private EntityRepositoryInterface $orderTransactionRepository;
  28.     public function __construct(
  29.         EntityRepositoryInterface $mandateRepository,
  30.         EntityRepositoryInterface $orderTransactionRepository
  31.     ) {
  32.         $this->mandateRepository = $mandateRepository;
  33.         $this->orderTransactionRepository = $orderTransactionRepository;
  34.     }
  36.     public static function getSubscribedEvents(): array
  37.     {
  38.         return [
  39.             CheckoutFinishPageLoadedEvent::class => 'onCheckoutFinish',
  40.         ];
  41.     }
  43.     public function onCheckoutFinish(CheckoutFinishPageLoadedEvent $event): void
  44.     {
  45.         $salesChannelContext = $event->getSalesChannelContext();
  46.         $context = $salesChannelContext->getContext();
  48.         if (!$this->isPayonePayment($salesChannelContext->getPaymentMethod())) {
  49.             return;
  50.         }
  52.         $mandateIdentification = $this->getMandateIdentification(
  53.             $event->getPage()->getOrder(),
  54.             $context
  55.         );
  57.         if ($mandateIdentification === null) {
  58.             return;
  59.         }
  61.         if (!$this->hasDirectDebitPayment($mandateIdentification)) {
  62.             return;
  63.         }
  65.         $payoneData = new CheckoutFinishPaymentData();
  67.         $payoneData->assign([
  68.             'mandate' => $this->getMandate($mandateIdentification, $context),
  69.         ]);
  71.         $event->getPage()->addExtension(CheckoutFinishPaymentData::EXTENSION_NAME, $payoneData);
  72.     }
  74.     protected function hasDirectDebitPayment(?string $mandateIdentification): bool
  75.     {
  76.         return $mandateIdentification !== null;
  77.     }
  79.     private function isPayonePayment(PaymentMethodEntity $paymentMethod): bool
  80.     {
  81.         return \in_array($paymentMethod->getId(), PaymentMethodInstaller::PAYMENT_METHOD_IDS, true);
  82.     }
  84.     private function getMandate(string $mandateIdentification, Context $context): ?PayonePaymentMandateEntity
  85.     {
  86.         $criteria = new Criteria();
  87.         $criteria->addFilter(new EqualsFilter('identification', $mandateIdentification));
  89.         return $this->mandateRepository->search($criteria, $context)->first();
  90.     }
  92.     private function getMandateIdentification(OrderEntity $order, Context $context): ?string
  93.     {
  94.         $criteria = new Criteria();
  95.         $criteria->addFilter(new EqualsFilter('orderId', $order->getId()));
  97.         /** @var OrderTransactionEntity[] $transactions */
  98.         $transactions = $this->orderTransactionRepository->search($criteria, $context);
  100.         foreach ($transactions as $transaction) {
  101.             /** @var PayonePaymentOrderTransactionDataEntity|null $payoneTransactionData */
  102.             $payoneTransactionData = $transaction->getExtension(PayonePaymentOrderTransactionExtension::NAME);
  104.             if ($payoneTransactionData !== null && !empty($payoneTransactionData->getMandateIdentification())) {
  105.                 return $payoneTransactionData->getMandateIdentification();
  106.             }
  107.         }
  109.         return null;
  110.     }
  111. }