src/EventSubscriber/GoCardlessMandateSubscriber.php line 70

Open in your IDE?
  1. <?php
  2. /*
  3.  * This file is part of the CosaVostra, TrackPay package.
  4.  *
  5.  * (c) Mohamed Radhi GUENNICHI <rg@mate.tn> <+216 50 711 816>
  6.  *
  7.  * For the full copyright and license information, please view the LICENSE
  8.  * file that was distributed with this source code.
  9.  */
  11. declare(strict_types=1);
  13. namespace App\EventSubscriber;
  15. use App\Entity\GoCardlessAccount;
  16. use App\Entity\GoCardlessMandate;
  17. use App\Event\GoCardlessMandateEvent;
  18. use App\Manager\PaymentManager;
  19. use App\Manager\ProcedureManager;
  20. use App\Repository\GoCardlessAccountRepository;
  21. use App\Service\GoCardlessService;
  22. use DateTime;
  23. use Doctrine\ORM\EntityManagerInterface;
  24. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  25. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  27. class GoCardlessMandateSubscriber implements EventSubscriberInterface
  28. {
  29.     /**
  30.      * @var PaymentManager
  31.      */
  32.     protected $paymentManager;
  34.     /**
  35.      * @var GoCardlessService
  36.      */
  37.     protected $gocardlessService;
  39.     /**
  40.      * @var GoCardlessAccountRepository
  41.      */
  42.     protected $accountRepository;
  44.     /**
  45.      * @var ProcedureManager
  46.      */
  47.     protected $procedureManager;
  49.     /**
  50.      * @var EventDispatcherInterface
  51.      */
  52.     protected $eventDispatcher;
  54.     /**
  55.      * @var EntityManagerInterface
  56.      */
  57.     protected $entityManager;
  59.     public function __construct(PaymentManager $paymentManager, GoCardlessService $gocardlessService, GoCardlessAccountRepository $accountRepository, ProcedureManager $procedureManager, EventDispatcherInterface $eventDispatcher, EntityManagerInterface $entityManager)
  60.     {
  61.         $this->paymentManager = $paymentManager;
  62.         $this->gocardlessService = $gocardlessService;
  63.         $this->accountRepository = $accountRepository;
  64.         $this->procedureManager = $procedureManager;
  65.         $this->eventDispatcher = $eventDispatcher;
  66.         $this->entityManager = $entityManager;
  67.     }
  70.     public function onMandate(GoCardlessMandateEvent $event): void
  71.     {
  72.         $mandate = $event->getMandate();
  73.         $invoice = $mandate->getInvoice();
  75.         // Create a new payment record with pending status
  76.         $procedure = $invoice->getProcedure();
  78.         if ($mandate->getChargeDate() <= new DateTime()) {
  79.             $account = $this->accountRepository->findOneByUser($invoice->getUser());
  81.             // Pay now
  82.             $gcPayment = $this->gocardlessService->connect($account->getCredential(GoCardlessAccount::CREDENTIAL_ACCESS_TOKEN))
  83.                     ->payments()->create([
  84.                             'params' => [
  85.                                     'amount' => $invoice->getDueAmount(),
  86.                                     'currency' => 'EUR',
  87.                                     'links' => [
  88.                                             'mandate' => $mandate->getMandateId()
  89.                                     ],
  90.                                     'metadata' => [
  91.                                             'invoice_number' => $invoice->getName()
  92.                                     ]
  93.                             ]
  94.                     ]);
  96.             $this->paymentManager->order($invoice = $mandate->getInvoice(), $gcPayment->id, $mandate);
  98.             $mandate->setStatus(GoCardlessMandate::STATUS_PROCESSING);
  100.             $this->entityManager->flush();
  102.             // Stop.
  103.             return;
  104.         }
  106.         // Pause the procedure related to the invoice.
  107.         $this->procedureManager->pause($procedure);
  108.     }
  110.     public static function getSubscribedEvents()
  111.     {
  112.         return [
  113.                 GoCardlessMandateEvent::class => 'onMandate'
  114.         ];
  115.     }
  116. }