src/Subscriber/Payment/PaymentReleasedSubscriber.php line 38

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Payment;
  5. use App\Event\Payment\PaymentReleasedEvent;
  6. use App\Event\User\PhoneNumberConfirmedEvent;
  7. use App\Service\Payment\PaymentService;
  8. use App\Service\User\BalanceMemberService;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. class PaymentReleasedSubscriber implements EventSubscriberInterface
  12. {
  13.     protected BalanceMemberService $service;
  14.     protected PaymentService $paymentService;
  16.     public function __construct(BalanceMemberService $balanceMemberService, PaymentService $paymentService)
  17.     {
  18.         $this->service = $balanceMemberService;
  19.         $this->paymentService = $paymentService;
  20.     }
  22.     public static function getSubscribedEvents(): array
  23.     {
  24.         return [
  25.             PaymentReleasedEvent::class => [
  26.                 ['onOnHoldPaymentReleased', 0],
  27.             ],
  28.             PhoneNumberConfirmedEvent::class => [
  29.                 ['releaseWhenPhoneNumberConfirmed', 0],
  30.             ],
  31.         ];
  32.     }
  34.     /**
  35.      * @throws \Doctrine\ORM\ORMException
  36.      * @throws \Doctrine\ORM\OptimisticLockException
  37.      */
  38.     public function onOnHoldPaymentReleased(PaymentReleasedEvent $event)
  39.     {
  40.         $payment = $event->getPayment();
  41.         if ($payment->getOnHold()) {
  42.             return;
  43.         }
  45.         $member = $payment->getAccount()->getMember();
  46.         $balance = $this->service->createIncomeForMember($member);
  47.         $balance->setPayment($payment);
  49.         if ($process = $payment->getPaymentProcess()) {
  50.             $coins = $process->getTariffObject()->getTotalCoins();
  51.         } else {
  52.             $coins = $payment->getAmount() * 100;
  54.             $details = $payment->getDetails(true);
  55.             if (is_array($details) && isset($details['overrideCoins'])) {
  56.                 $coins = (int) $details['overrideCoins'];
  57.             }
  58.         }
  59.         $balance->setAmount($coins);
  61.         $this->service->storeBalanceMember($balance);
  62.     }
  64.     public function releaseWhenPhoneNumberConfirmed(PhoneNumberConfirmedEvent $event)
  65.     {
  66.         $member = $event->getPhoneNumber()->getMember();
  67.         $payments = $this->paymentService->findOnHoldPayments($member->getAccount());
  68.         foreach ($payments as $payment) {
  69.             $this->paymentService->releaseOnHoldPayment($payment);
  70.         }
  71.     }
  72. }