src/PaymentBundle/Listener/PaymentCompleteListener.php line 54

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. /*
  6.  * This file is part of SolidInvoice project.
  7.  *
  8.  * (c) Pierre du Plessis <[email protected]>
  9.  *
  10.  * This source file is subject to the MIT license that is bundled
  11.  * with this source code in the file LICENSE.
  12.  */
  14. namespace SolidInvoice\PaymentBundle\Listener;
  16. use Brick\Math\Exception\MathException;
  17. use Doctrine\Persistence\ManagerRegistry;
  18. use Generator;
  19. use SolidInvoice\ClientBundle\Entity\Credit;
  20. use SolidInvoice\CoreBundle\Response\FlashResponse;
  21. use SolidInvoice\InvoiceBundle\Entity\Invoice;
  22. use SolidInvoice\InvoiceBundle\Model\Graph;
  23. use SolidInvoice\PaymentBundle\Entity\Payment;
  24. use SolidInvoice\PaymentBundle\Event\PaymentCompleteEvent;
  25. use SolidInvoice\PaymentBundle\Event\PaymentEvents;
  26. use SolidInvoice\PaymentBundle\Model\Status;
  27. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  28. use Symfony\Component\HttpFoundation\RedirectResponse;
  29. use Symfony\Component\Routing\RouterInterface;
  30. use Symfony\Component\Workflow\StateMachine;
  32. class PaymentCompleteListener implements EventSubscriberInterface
  33. {
  34.     /**
  35.      * @return array<string, string>
  36.      */
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             PaymentEvents::PAYMENT_COMPLETE => 'onPaymentComplete',
  41.         ];
  42.     }
  44.     public function __construct(
  45.         private readonly StateMachine $invoiceStateMachine,
  46.         private readonly ManagerRegistry $registry,
  47.         private readonly RouterInterface $router
  48.     ) {
  49.     }
  51.     /**
  52.      * @throws MathException
  53.      */
  54.     public function onPaymentComplete(PaymentCompleteEvent $event): void
  55.     {
  56.         $payment = $event->getPayment();
  57.         $status = (string) $payment->getStatus();
  59.         if ('credit' === $payment->getMethod()?->getGatewayName()) {
  60.             $creditRepository = $this->registry->getRepository(Credit::class);
  61.             $creditRepository->deductCredit(
  62.                 $payment->getClient(),
  63.                 $payment->getTotalAmount(),
  64.             );
  65.         }
  67.         if (($invoice = $event->getPayment()->getInvoice()) instanceof Invoice) {
  68.             $em = $this->registry->getManager();
  70.             if (Status::STATUS_CAPTURED === $status && $em->getRepository(Invoice::class)->isFullyPaid($invoice)) {
  71.                 $this->invoiceStateMachine->apply($invoice, Graph::TRANSITION_PAY);
  72.             } else {
  73.                 $paymentRepository = $this->registry->getRepository(Payment::class);
  74.                 $invoiceTotal = $invoice->getTotal();
  75.                 $totalPaid = $paymentRepository->getTotalPaidForInvoice($invoice);
  76.                 $invoice->setBalance($invoiceTotal->minus($totalPaid));
  78.                 $em = $this->registry->getManager();
  79.                 $em->persist($invoice);
  80.                 $em->flush();
  81.             }
  83.             $router = $this->router;
  85.             $event->setResponse(
  86.                 new class($router->generate('_view_invoice_external', ['uuid' => $invoice->getUuid()]), $status) extends RedirectResponse implements FlashResponse {
  87.                     public function __construct(
  88.                         string $route,
  89.                         private readonly string $paymentStatus
  90.                     ) {
  91.                         parent::__construct($route);
  92.                     }
  94.                     public function getFlash(): Generator
  95.                     {
  96.                         yield from PaymentCompleteListener::addFlashMessage($this->paymentStatus);
  97.                     }
  98.                 }
  99.             );
  100.         }
  101.     }
  103.     public static function addFlashMessage(string $status): Generator
  104.     {
  105.         match ($status) {
  106.             Status::STATUS_CAPTURED => yield FlashResponse::FLASH_SUCCESS => 'payment.flash.status.success',
  107.             Status::STATUS_CANCELLED => yield FlashResponse::FLASH_DANGER => 'payment.flash.status.cancelled',
  108.             Status::STATUS_PENDING => yield FlashResponse::FLASH_WARNING => 'payment.flash.status.pending',
  109.             Status::STATUS_EXPIRED => yield FlashResponse::FLASH_DANGER => 'payment.flash.status.expired',
  110.             Status::STATUS_FAILED => yield FlashResponse::FLASH_DANGER => 'payment.flash.status.failed',
  111.             Status::STATUS_NEW => yield FlashResponse::FLASH_WARNING => 'payment.flash.status.new',
  112.             Status::STATUS_SUSPENDED => yield FlashResponse::FLASH_DANGER => 'payment.flash.status.suspended',
  113.             Status::STATUS_AUTHORIZED => yield FlashResponse::FLASH_INFO => 'payment.flash.status.authorized',
  114.             Status::STATUS_REFUNDED => yield FlashResponse::FLASH_WARNING => 'payment.flash.status.refunded',
  115.             default => yield FlashResponse::FLASH_DANGER => 'payment.flash.status.unknown',
  116.         };
  117.     }
  118. }