src/Subscriber/Payment/Purchase/PurchaseBalanceAmateurSubscriber.php line 46

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Payment\Purchase;
  5. use App\Dictionary\BalanceType;
  6. use App\Dictionary\PaymentType;
  7. use App\Event\Payment\PurchaseCreatedEvent;
  8. use App\Service\Amateur\BalanceAmateurService;
  9. use App\Service\Payment\PaymentService;
  10. use App\Service\User\BalanceMemberService;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class PurchaseBalanceAmateurSubscriber implements EventSubscriberInterface
  14. {
  15.     protected BalanceAmateurService $service;
  17.     protected BalanceMemberService $balanceMemberService;
  19.     protected PaymentService $paymentService;
  21.     /**
  22.      * PurchaseBalanceAmateurSubscriber constructor.
  23.      */
  24.     public function __construct(BalanceAmateurService $service, BalanceMemberService $balanceMemberService,
  25.         PaymentService $paymentService)
  26.     {
  27.         $this->service = $service;
  28.         $this->balanceMemberService = $balanceMemberService;
  29.         $this->paymentService = $paymentService;
  30.     }
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             PurchaseCreatedEvent::class => [
  36.                 ['onPurchaseCreateBalanceAmateur', 0],
  37.             ],
  38.         ];
  39.     }
  41.     /**
  42.      * @throws \App\Exception\Commission\NotAnAmateurException
  43.      * @throws \Doctrine\ORM\ORMException
  44.      * @throws \Doctrine\ORM\OptimisticLockException
  45.      */
  46.     public function onPurchaseCreateBalanceAmateur(PurchaseCreatedEvent $event)
  47.     {
  48.         if ($event->getPurchasable()->useDelayedProvision()) {
  49.             return;
  50.         }
  52.         $purchase = $event->getPurchase();
  53.         $seller = $purchase->getSeller();
  54.         if (!$seller || !$seller->getIsAmateur()) {
  55.             return;
  56.         }
  57.         $balances = $this->balanceMemberService->findByIds($purchase->getBalanceMember());
  59.         foreach ($balances as $balanceMember) {
  60.             $income = $this->service->createProvisionForAmateurByBalanceMember($seller, $balanceMember);
  62.             // triggers event
  63.             $this->service->storeBalanceAmateur($income);
  65.             if ($payment = $balanceMember->getPayment()) {
  66.                 $latest = $this->paymentService->getLatestItemByPayment($payment);
  68.                 if ($latest && $latest->isType(PaymentType::CHARGEBACK)) {
  69.                     $cb = $this->service->createProvisionByAmateur($income->getMember(), BalanceType::CHARGEBACK);
  71.                     $cb->setBalanceDetail($income->getBalanceDetail());
  72.                     $cb->setAmount($income->getAmount() * -1);
  73.                     $cb->setPayment($latest);
  75.                     $this->service->storeBalanceAmateur($cb);
  76.                 }
  77.             }
  78.         }
  80.         $purchase->setProvisionAssigned(true);
  81.         $this->service->storeEntity($purchase);
  82.     }
  83. }