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

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace PayonePayment\EventListener;
  7. use PayonePayment\DataAbstractionLayer\Entity\Mandate\PayonePaymentMandateEntity;
  8. use PayonePayment\Installer\CustomFieldInstaller;
  9. use PayonePayment\Installer\PaymentMethodInstaller;
  10. use PayonePayment\Storefront\Struct\CheckoutFinishPaymentData;
  11. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionEntity;
  12. use Shopware\Core\Checkout\Order\OrderEntity;
  13. use Shopware\Core\Checkout\Payment\PaymentMethodEntity;
  14. use Shopware\Core\Framework\Context;
  15. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  18. use Shopware\Storefront\Page\Checkout\Finish\CheckoutFinishPageLoadedEvent;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class CheckoutFinishEventListener implements EventSubscriberInterface
  22. {
  23.     /** @var EntityRepositoryInterface */
  24.     private $mandateRepository;
  26.     /** @var EntityRepositoryInterface */
  27.     private $orderTransactionRepository;
  29.     public function __construct(
  30.         EntityRepositoryInterface $mandateRepository,
  31.         EntityRepositoryInterface $orderTransactionRepository
  32.     ) {
  33.         $this->mandateRepository          = $mandateRepository;
  34.         $this->orderTransactionRepository = $orderTransactionRepository;
  35.     }
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             CheckoutFinishPageLoadedEvent::class => 'onCheckoutFinish',
  41.         ];
  42.     }
  44.     public function onCheckoutFinish(CheckoutFinishPageLoadedEvent $event): void
  45.     {
  46.         $salesChannelContext = $event->getSalesChannelContext();
  47.         $context             = $salesChannelContext->getContext();
  49.         if (!$this->isPayonePayment($salesChannelContext->getPaymentMethod())) {
  50.             return;
  51.         }
  53.         $mandateIdentification = $this->getMandateIdentification(
  54.             $event->getPage()->getOrder(),
  55.             $context
  56.         );
  58.         if (null === $mandateIdentification) {
  59.             return;
  60.         }
  62.         if (!$this->hasDirectDebitPayment($mandateIdentification)) {
  63.             return;
  64.         }
  66.         $payoneData = new CheckoutFinishPaymentData();
  68.         $payoneData->assign([
  69.             'mandate' => $this->getMandate($mandateIdentification, $context),
  70.         ]);
  72.         $event->getPage()->addExtension(CheckoutFinishPaymentData::EXTENSION_NAME, $payoneData);
  73.     }
  75.     protected function hasDirectDebitPayment(?string $mandateIdentification): bool
  76.     {
  77.         return null !== $mandateIdentification;
  78.     }
  80.     private function isPayonePayment(PaymentMethodEntity $paymentMethod): bool
  81.     {
  82.         return in_array($paymentMethod->getId(), PaymentMethodInstaller::PAYMENT_METHOD_IDS);
  83.     }
  85.     private function getMandate(string $mandateIdentification, Context $context): ?PayonePaymentMandateEntity
  86.     {
  87.         $criteria = new Criteria();
  88.         $criteria->addFilter(new EqualsFilter('identification', $mandateIdentification));
  90.         return $this->mandateRepository->search($criteria, $context)->first();
  91.     }
  93.     private function getMandateIdentification(OrderEntity $order, Context $context): ?string
  94.     {
  95.         $criteria = new Criteria();
  96.         $criteria->addFilter(new EqualsFilter('orderId', $order->getId()));
  98.         /** @var OrderTransactionEntity[] $transactions */
  99.         $transactions = $this->orderTransactionRepository->search($criteria, $context);
  101.         foreach ($transactions as $transaction) {
  102.             $customFields = $transaction->getCustomFields();
  104.             if (!empty($customFields[CustomFieldInstaller::MANDATE_IDENTIFICATION])) {
  105.                 return $customFields[CustomFieldInstaller::MANDATE_IDENTIFICATION];
  106.             }
  107.         }
  109.         return null;
  110.     }
  111. }