src/Subscriber/Billing/PayoutSubscriber.php line 44

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Billing;
  5. use App\Entity\Billing;
  6. use App\Event\Payment\PayoutPublishedEvent;
  7. use App\Lib\System\Job\PayoutEmailJob;
  8. use App\Service\Payment\BillingService;
  9. use App\Service\System\JobService;
  10. use App\Service\User\AccountService;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class PayoutSubscriber implements EventSubscriberInterface
  14. {
  15.     protected BillingService $service;
  17.     protected JobService $jobService;
  19.     protected AccountService $accountService;
  21.     /**
  22.      * PayoutSubscriber constructor.
  23.      */
  24.     public function __construct(BillingService $billingService, JobService $jobService, AccountService $accountService)
  25.     {
  26.         $this->service = $billingService;
  27.         $this->jobService = $jobService;
  28.         $this->accountService = $accountService;
  29.     }
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             PayoutPublishedEvent::class => [
  35.                 ['onPayoutPublishedUpdateBills', 0],
  36.                 ['onPayoutPublishedSendNotifications', 1],
  37.             ],
  38.         ];
  39.     }
  41.     /**
  42.      * @throws \Doctrine\DBAL\Exception
  43.      */
  44.     public function onPayoutPublishedUpdateBills(PayoutPublishedEvent $event)
  45.     {
  46.         $published = $event->isPublished();
  47.         $payout = $event->getPayout();
  49.         $this->service->markBillsAsPublishedForPayout($payout, $published);
  50.     }
  52.     /**
  53.      * @throws \Doctrine\ORM\ORMException
  54.      * @throws \Doctrine\ORM\OptimisticLockException
  55.      */
  56.     public function onPayoutPublishedSendNotifications(PayoutPublishedEvent $event)
  57.     {
  58.         if (!$event->sendNotifications()) {
  59.             return;
  60.         }
  62.         $payout = $event->getPayout();
  64.         $bills = $this->service->getPublishedBillsForPayout($payout);
  65.         foreach ($bills as $bill) {
  66.             /**
  67.              * @var $bill Billing
  68.              */
  69.             $job = new PayoutEmailJob($bill->getId(), $payout->getId());
  71.             if ($bill->getAmateur()) {
  72.                 $account = $bill->getAmateur()->getAccount();
  73.                 $job->setAutologinParam($this->accountService->getAutologinParameter($account));
  74.                 $job->setTemplate('FrivolCoreBundle:Email:payout-amateur.mail.twig');
  75.             } elseif ($bill->getWebmaster()) {
  76.                 $account = $bill->getWebmaster()->getAccount();
  77.                 $job->setAutologinParam($this->accountService->getAutologinParameter($account));
  78.                 $job->setTemplate('FrivolCoreBundle:Email:payout-webmaster.mail.twig');
  79.             }
  81.             $this->jobService->createSaveAndSchedule($job, '', null, PayoutEmailJob::queue);
  82.         }
  83.     }
  84. }