src/Listener/PaymentEventListener.php line 46

Open in your IDE?
  1. <?php
  3. namespace App\Listener;
  5. use App\Entity\DeviceSale;
  6. use App\Entity\Order;
  7. use App\Entity\User;
  8. use App\Mailer\AppMailer;
  9. use App\Service\CreditService;
  10. use App\Service\CreditSmsService;
  11. use App\Service\InvoiceService;
  12. use Doctrine\ORM\EntityManagerInterface;
  13. use Psr\Log\LoggerInterface;
  14. use Wits\PaymentBundle\Event\PaymentEvent;
  16. class PaymentEventListener
  17. {
  19.     private LoggerInterface $logger;
  20.     private CreditService $creditService;
  21.     private CreditSmsService $creditSmsService;
  22.     private InvoiceService $invoiceService;
  23.     private EntityManagerInterface $em;
  25.     private AppMailer $appMailer;
  27.     public function __construct(CreditService          $creditService,
  28.                                 CreditSmsService       $creditSmsService,
  29.                                 InvoiceService         $invoiceService,
  30.                                 LoggerInterface        $logger,
  31.                                 EntityManagerInterface $em,
  32.                                 AppMailer $appMailer)
  33.     {
  34.         $this->logger = $logger;
  35.         $this->creditService = $creditService;
  36.         $this->invoiceService = $invoiceService;
  37.         $this->creditSmsService = $creditSmsService;
  38.         $this->em = $em;
  39.         $this->appMailer = $appMailer;
  40.     }
  42.     /**
  43.      * Method triggered when a payment confirmation is received
  44.      * @param PaymentEvent $event
  45.      */
  46.     public function onPaymentConfirmed(PaymentEvent $event)
  47.     {
  48.         $this->logger->debug('PaymentEventListener onPaymentConfirmed');
  49.         $payment = $event->getPayment();
  50.         if ($payment) {
  51.             $this->logger->info('Payment ' . $payment->getId() . ' has been confirmed');
  53.             //search associated order
  54.             $orderRepository = $this->em->getRepository(Order::class);
  55.             $order = $orderRepository->findOrderAssociatedAtPayment($payment);
  57.             //search associated deviceSale
  58.             $deviceSaleRepository = $this->em->getRepository(DeviceSale::class);
  59.             $sale = $deviceSaleRepository->findSaleAssociatedwithPayment($payment);
  61.             if ($order) {
  62.                 if ($order->hasPack()) {
  63.                     if ($order->getPack()->isCreditPack()) {
  64.                         $this->creditService->increaseCreditForOrder($order);
  65.                     } else if ($order->getPack()->isSmsCreditPack()) {
  66.                         $this->creditSmsService->increaseCreditForOrder($order);
  67.                     } else {
  68.                         $this->logger->error('Unknown pack type for order ' . $order->getId());
  69.                     }
  70.                 } elseif ($order->hasCreditCost()) {
  71.                     $this->logger->info('CreditCost of order ' . $order->getId() . ' have been paid');
  72.                 }
  73.                 elseif ($order->hasStoreIndexation()) {
  74.                     $this->logger->info('StoreIndexation of order ' . $order->getId() . ' have been paid');
  75.                 }
  76.                 else {
  77.                     $this->logger->error('Unknown order type (orderId: ' . $order->getId().')');
  78.                 }
  80.                 //generate invoice & notify
  81.                 $this->invoiceService->createInvoiceForOrder($order);
  82.             } elseif ($sale) {
  83.                 $this->invoiceService->createInvoiceForDeviceSale($sale);
  84.             } else {
  85.                 $this->logger->error('No Order nor sale found (associated with payment ' . $payment->getId() . ' )');
  87.             }
  90.         } else {
  91.             $this->logger->warning('No payment associated with event onPaymentConfirmed');
  92.         }
  93.     }
  95.     /**
  96.      * Method triggered when a user is created (in stripe)
  97.      * @param PaymentEvent $event
  98.      */
  99.     public function onCustomerCreated(PaymentEvent $event)
  100.     {
  101.         $this->logger->debug('PaymentEventListener onCustomerCreated');
  102.         $customerStripe = $event->getStripeEvent()->data->object;
  103.         $this->logger->info('User is  ' . $customerStripe->id . ' - ' . $customerStripe->email);
  105.         $user = $this->em->getRepository(User::class)->findOneBy(['email' => $customerStripe->email]);
  106.         $user->setStripeId($customerStripe->id);
  107.         $this->em->flush();
  108.     }
  110.     /**
  111.      * Method triggered when a payment is refused (in stripe)
  112.      * @param PaymentEvent $event
  113.      */
  114.     public function onPaymentRefused(PaymentEvent $event)
  115.     {
  116.         $this->logger->debug('PaymentEventListener onPaymentRefused');
  117.         $payment = $event->getPayment();
  118.         if ($payment) {
  119.             $this->logger->info('Payment ' . $payment->getId() . ' has been refused');
  121.             $this->appMailer->sendAdminEmailPaymentRefused($payment);
  122.             $this->em->flush();
  123.         }
  125.     }
  128. }