src/Subscriber/Payment/EncashmentSubscriber.php line 62

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Payment;
  5. use App\Event\Payment\EncashmentEvent;
  6. use App\Lib\Payment\Settlement;
  7. use App\Service\Payment\BookingService;
  8. use App\Service\Payment\EncashmentService;
  9. use App\Service\Payment\PaymentService;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class EncashmentSubscriber implements EventSubscriberInterface
  13. {
  14.     /**
  15.      * @var EncashmentService
  16.      */
  17.     protected $encashmentService;
  19.     /**
  20.      * @var PaymentService
  21.      */
  22.     protected $service;
  24.     /**
  25.      * @var BookingService
  26.      */
  27.     protected $bookingService;
  29.     /**
  30.      * EncashmentSubscriber constructor.
  31.      */
  32.     public function __construct(PaymentService $paymentService, BookingService $bookingService, EncashmentService $encashmentService)
  33.     {
  34.         $this->encashmentService = $encashmentService;
  35.         $this->service = $paymentService;
  36.         $this->bookingService = $bookingService;
  37.     }
  39.     public static function getSubscribedEvents(): array
  40.     {
  41.         return [
  42.             EncashmentEvent::class => [
  43.                 ['onEncashmentCreated', 0],
  44.             ],
  45.         ];
  46.     }
  48.     protected function getBookingService(): BookingService
  49.     {
  50.         return $this->bookingService;
  51.     }
  53.     protected function getPaymentService(): PaymentService
  54.     {
  55.         return $this->service;
  56.     }
  58.     /**
  59.      * @throws \Doctrine\ORM\ORMException
  60.      * @throws \Doctrine\ORM\OptimisticLockException
  61.      */
  62.     public function onEncashmentCreated(EncashmentEvent $event)
  63.     {
  64.         $encashment = $event->getEncashment();
  65.         $account = $encashment->getAccount();
  67.         $possibleSettlements = $this->getPaymentService()->getPossibleSettlementsByAmount($account, $encashment->getAmount());
  69.         $cleared = 0;
  70.         $fee = 0;
  72.         if (count($possibleSettlements)) {
  73.             $fee = round($encashment->getFee() / count($possibleSettlements), 2);
  74.         }
  76.         foreach ($possibleSettlements as $chargeback) {
  77.             $settlement = new Settlement();
  78.             $settlement->setBookingId($chargeback->getBookingId());
  79.             $settlement->setAmount(abs($chargeback->getAmount()));
  80.             $settlement->setVendor($chargeback->getVendor());
  81.             $settlement->setCustomerId($chargeback->getCustomerId());
  82.             $settlement->setFee($fee);
  83.             $settlement->setRealamount(abs($chargeback->getAmount()) + $fee);
  85.             $payment = $this->getBookingService()->storeConceptObject($settlement, $account);
  86.             if ($encashment->paymentProcess) {
  87.                 $payment->setPaymentProcess($encashment->paymentProcess);
  88.             }
  89.             if ($encashment->paymentReference) {
  90.                 $payment->setPaymentReference($encashment->paymentReference);
  91.             }
  92.             $this->getPaymentService()->storePayment($payment, [
  93.                 'conceptObject' => $settlement,
  94.             ]);
  96.             $cleared += abs($chargeback->getAmount());
  97.             $encashment->resultingPayments[] = $payment;
  98.         }
  100.         $encashment->setCleared($cleared);
  102.         $this->encashmentService->storeEntity($encashment);
  103.     }
  104. }