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

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. }