src/Subscriber/Payout/WebmasterPayoutSubscriber.php line 77

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Payout;
  5. use App\Dictionary\PayoutArea;
  6. use App\Entity\Billing;
  7. use App\Event\Payment\PayoutCreatedEvent;
  8. use App\Event\Payment\PayoutSealedEvent;
  9. use App\Lib\Payment\Admin\WebmasterPayoutItem;
  10. use App\Service\Payment\BillingService;
  11. use App\Service\Payment\PayoutService;
  12. use App\Service\User\AccountService;
  13. use App\Service\Webmaster\BalanceWebmasterService;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class WebmasterPayoutSubscriber implements EventSubscriberInterface
  17. {
  18.     /**
  19.      * @var BalanceWebmasterService
  20.      */
  21.     protected $service;
  23.     /**
  24.      * @var PayoutService
  25.      */
  26.     protected $payoutService;
  28.     /**
  29.      * @var AccountService
  30.      */
  31.     protected $accountService;
  33.     /**
  34.      * @var BillingService
  35.      */
  36.     protected $billingService;
  38.     /**
  39.      * WebmasterPayoutSubscriber constructor.
  40.      */
  41.     public function __construct(BalanceWebmasterService $service, BillingService $billingService,
  42.         PayoutService $payoutService, AccountService $accountService)
  43.     {
  44.         $this->service = $service;
  45.         $this->payoutService = $payoutService;
  46.         $this->accountService = $accountService;
  47.         $this->billingService = $billingService;
  48.     }
  50.     public static function getSubscribedEvents(): array
  51.     {
  52.         return [
  53.             PayoutCreatedEvent::class => [
  54.                 ['onPayoutCreated', 0],
  55.             ],
  56.             PayoutSealedEvent::class => [
  57.                 ['onPayoutSealed', 0],
  58.             ],
  59.         ];
  60.     }
  62.     public function onPayoutCreated(PayoutCreatedEvent $event)
  63.     {
  64.         $payout = $event->getPayout();
  65.         if (PayoutArea::WEBMASTER !== $payout->getArea()) {
  66.             return;
  67.         }
  69.         $this->service->markBalancesWithPayout($payout);
  70.     }
  72.     /**
  73.      * @throws \Doctrine\DBAL\Exception
  74.      * @throws \Doctrine\ORM\ORMException
  75.      * @throws \Doctrine\ORM\OptimisticLockException
  76.      */
  77.     public function onPayoutSealed(PayoutSealedEvent $event)
  78.     {
  79.         $payout = $event->getPayout();
  80.         if (PayoutArea::WEBMASTER !== $payout->getArea() || !$payout->getIsSealed()) {
  81.             return;
  82.         }
  84.         $payouts = $this->payoutService->getPayoutListWebmaster($payout, 'sum', 'DESC');
  85.         $startBillingId = $this->billingService->getMaxBillingId() + 1;
  86.         $month = $payout->getBillingMonth();
  87.         $month->modify('-1 month');
  89.         foreach ($payouts as $item) {
  90.             $bill = $this->createBillForPayoutItem($item);
  91.             $bill->setPayout($payout);
  92.             $bill->setBillingId($startBillingId);
  93.             $bill->setInvoiceNumber($month->format('Ym').'.'.$startBillingId);
  95.             $this->billingService->storeEntity($bill, false);
  96.             ++$startBillingId;
  97.         }
  99.         $this->billingService->delayedFlush();
  100.     }
  102.     protected function createBillForPayoutItem(WebmasterPayoutItem $item): Billing
  103.     {
  104.         $bill = new Billing();
  105.         $account = $this->accountService->findById($item->getAccountId());
  107.         $bill->setWebmaster($account->getWebmaster());
  108.         $bill->setPerson($account->getWebmaster()->getPerson());
  109.         $bill->setIsGross($item->isGross());
  111.         return $bill;
  112.     }
  113. }