vendor/boldr/mollie-payment-method/src/EventSubscriber/MollieEventSubscriber.php line 44

Open in your IDE?
  1. <?php
  3. namespace Boldr\Shop\MolliePaymentMethodBundle\EventSubscriber;
  5. use Boldr\Shop\ShopBundle\Event\{ InvoiceStatusUpdatedEvent, PaymentStatusUpdatedEvent };
  6. use Boldr\Shop\ShopBundle\Entity\Invoice;
  7. use Boldr\Shop\MolliePaymentMethodBundle\Entity\MolliePayment;
  8. use Boldr\Cms\MollieBundle\Event\MolliePaymentUpdatedEvent;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Psr\EventDispatcher\EventDispatcherInterface;
  12. use Doctrine\ORM\EntityManagerInterface;
  13. use Mollie\Api\MollieApiClient;
  15. class MollieEventSubscriber implements EventSubscriberInterface
  16. {
  18.     private EventDispatcherInterface $eventDispatcher;
  19.     private EntityManagerInterface $em;
  20.     private MollieApiClient $mollieApiClient;
  22.     public function __construct(EventDispatcherInterface $eventDispatcher, EntityManagerInterface $em, MollieApiClient $mollieApiClient)
  23.     {
  24.         $this->eventDispatcher = $eventDispatcher;
  25.         $this->em = $em;
  26.         $this->mollieApiClient = $mollieApiClient;
  27.     }
  29.     public static function getSubscribedEvents(): array
  30.     {
  31.         return [
  32.             MolliePaymentUpdatedEvent::class => [
  33.                 ['onMolliePaymentUpdated', 10]
  34.             ],
  35.             InvoiceStatusUpdatedEvent::class => [
  36.                 ['onInvoiceStateUpdated', 0]
  37.             ],
  38.             PaymentStatusUpdatedEvent::class => [
  39.                 ['onPaymentStatusUpdated', 10]
  40.             ]
  41.         ];
  42.     }
  44.     public function onPaymentStatusUpdated(PaymentStatusUpdatedEvent $event)
  45.     {
  46.         $payment = $event->getPayment();
  47.         if ($payment instanceof MolliePayment)
  48.         {
  49.             if ($event->getNewStatus() === MolliePayment::STATUS_CANCELLED)
  50.             {
  51.                 try
  52.                 {
  53.                     $this->mollieApiClient->payments->cancel($payment->getMolliePaymentId());
  54.                 } catch (\Exception $ex) {
  55.                     // ignore silently
  56.                 }
  57.             }
  58.         }
  59.     }
  61.     public function onInvoiceStateUpdated(InvoiceStatusUpdatedEvent $event)
  62.     {
  63.         $invoice = $event->getInvoice();
  64.         $orders = $invoice->getOrders();
  66.         if (count($orders) > 1)
  67.         {
  68.             return;
  69.         }
  71.         if (isset($orders[0]))
  72.         {
  73.             $order = $orders[0];
  74.             if ($order->getNumber() !== null)
  75.             {
  76.                 foreach ($invoice->getPayments() as $payment)
  77.                 {
  78.                     if ($payment instanceof MolliePayment)
  79.                     {
  80.                         try
  81.                         {
  82.                             $molliePayment = $this->mollieApiClient->payments->get($payment->getMolliePaymentId());
  83.                             $molliePayment->description = 'Bestelling #'. $order->getNumber();
  84.                             $molliePayment->update();
  85.                         }
  86.                         catch (\Exception $ex)
  87.                         {
  88.                             // ignore silently
  89.                         }
  90.                     }
  91.                 }
  92.             }
  93.         }
  95.         if ($event->getNewStatus() === Invoice::STATUS_PAID)
  96.         {
  97.             // Cancel pending mollie payments
  98.             foreach ($invoice->getPayments() as $payment)
  99.             {
  100.                 if ($payment instanceof MolliePayment)
  101.                 {
  102.                     if ($payment->getStatus() === MolliePayment::STATUS_PENDING)
  103.                     {
  104.                         try
  105.                         {
  106.                             $this->mollieApiClient->payments->cancel($payment->getMolliePaymentId());
  107.                         }
  108.                         catch (\Exception $ex)
  109.                         {
  110.                             // ignore silently
  111.                         }
  112.                     }
  113.                 }
  114.             }
  115.         }
  116.     }
  118.     public function onMolliePaymentUpdated(MolliePaymentUpdatedEvent $event)
  119.     {
  120.         $molliePaymentRepository = $this->em->getRepository(MolliePayment::class);
  122.         $payment = $event->getPayment();
  123.         $molliePayment = $molliePaymentRepository->findOneBy(['molliePaymentId' => $payment->id]);
  125.         if ($molliePayment === null || $molliePayment->getStatus() === MolliePayment::STATUS_FAILED)
  126.         {
  127.             return;
  128.         }
  130.         if ($molliePayment !== null)
  131.         {
  132.             $oldStatus = $molliePayment->getStatus();
  133.             $newStatus = $payment->isPaid()
  134.                 ? MolliePayment::STATUS_PAID
  135.                 : ($payment->isFailed() || $payment->isCanceled() || $payment->isExpired() || $payment->getAmountRefunded() > 0
  136.                     ? MolliePayment::STATUS_FAILED
  137.                     : ($payment->hasChargebacks()
  138.                         ? MolliePayment::STATUS_CHARGEBACK
  139.                         : MolliePayment::STATUS_PENDING
  140.                     )
  141.                 )
  142.             ;
  144.             if ($oldStatus !== $newStatus)
  145.             {
  146.                 $molliePayment->setStatus($newStatus);
  147.                 $this->em->flush();
  149.                 $event = new PaymentStatusUpdatedEvent($molliePayment, $oldStatus, $newStatus);
  150.                 $this->eventDispatcher->dispatch($event);
  151.             }
  152.         }
  153.     }
  155. }