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\Entity\Mandate\PayonePaymentMandateEntity;
  8. use PayonePayment\Installer\CustomFieldInstaller;
  9. use PayonePayment\Storefront\Struct\CheckoutFinishPaymentData;
  10. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionEntity;
  11. use Shopware\Core\Checkout\Order\OrderEntity;
  12. use Shopware\Core\Checkout\Payment\PaymentMethodEntity;
  13. use Shopware\Core\Framework\Context;
  14. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  17. use Shopware\Storefront\Page\Checkout\Finish\CheckoutFinishPageLoadedEvent;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. class CheckoutFinishEventListener implements EventSubscriberInterface
  21. {
  22.     /** @var EntityRepositoryInterface */
  23.     private $mandateRepository;
  25.     /** @var EntityRepositoryInterface */
  26.     private $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 (null === $mandateIdentification) {
  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 null !== $mandateIdentification;
  77.     }
  79.     private function isPayonePayment(PaymentMethodEntity $paymentMethod): bool
  80.     {
  81.         $customFields = $paymentMethod->getCustomFields();
  83.         if (empty($customFields[CustomFieldInstaller::IS_PAYONE])) {
  84.             return false;
  85.         }
  87.         if (!$customFields[CustomFieldInstaller::IS_PAYONE]) {
  88.             return false;
  89.         }
  91.         return true;
  92.     }
  94.     private function getMandate(string $mandateIdentification, Context $context): ?PayonePaymentMandateEntity
  95.     {
  96.         $criteria = new Criteria();
  97.         $criteria->addFilter(new EqualsFilter('identification', $mandateIdentification));
  99.         /** @var null|PayonePaymentMandateEntity $mandate */
  100.         return $this->mandateRepository->search($criteria, $context)->first();
  101.     }
  103.     private function getMandateIdentification(OrderEntity $order, Context $context): ?string
  104.     {
  105.         $criteria = new Criteria();
  106.         $criteria->addFilter(new EqualsFilter('orderId', $order->getId()));
  108.         /** @var OrderTransactionEntity[] $transactions */
  109.         $transactions = $this->orderTransactionRepository->search($criteria, $context);
  111.         foreach ($transactions as $transaction) {
  112.             $customFields = $transaction->getCustomFields();
  114.             if (!empty($customFields[CustomFieldInstaller::MANDATE_IDENTIFICATION])) {
  115.                 return $customFields[CustomFieldInstaller::MANDATE_IDENTIFICATION];
  116.             }
  117.         }
  119.         return null;
  120.     }
  121. }