src/Subscriber/Balance/Webmaster/ProvisionTrackingSubscriber.php line 134

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Balance\Webmaster;
  5. use App\Dictionary\BalanceType;
  6. use App\Dictionary\VAT;
  7. use App\Event\Balance\BalanceWebmasterProvisionCreatedEvent;
  8. use App\Event\User\MemberCreatedEvent;
  9. use App\Lib\Payment\PayMethod\AdminBonusMethod;
  10. use App\Lib\System\Job\DelineSunctionPaymentTrackingJob;
  11. use App\Service\Property\WebmasterPropertyService;
  12. use App\Service\System\JobService;
  13. use App\Service\User\WebmasterService;
  14. use App\Service\Webmaster\BalanceWebmasterService;
  15. use App\Service\Webmaster\WebmasterProvisionSignupCampaignService;
  16. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. class ProvisionTrackingSubscriber implements EventSubscriberInterface
  20. {
  21.     protected BalanceWebmasterService $balanceWebmasterService;
  23.     protected JobService $jobService;
  25.     protected WebmasterPropertyService $webmasterPropertyService;
  27.     protected WebmasterProvisionSignupCampaignService $service;
  29.     /**
  30.      * @var array|int[]
  31.      */
  32.     protected array $advertiserIds = [];
  34.     /**
  35.      * ProvisionTrackingSubscriber constructor.
  36.      */
  37.     public function __construct(JobService $jobService, BalanceWebmasterService $balanceWebmasterService,
  38.         WebmasterPropertyService $webmasterPropertyService,
  39.         WebmasterProvisionSignupCampaignService $webmasterProvisionSignupCampaignService,
  40.         ParameterBagInterface $params,
  41.     ) {
  42.         $this->jobService = $jobService;
  43.         $this->balanceWebmasterService = $balanceWebmasterService;
  44.         $this->webmasterPropertyService = $webmasterPropertyService;
  45.         $this->service = $webmasterProvisionSignupCampaignService;
  46.         $advertiserIds = explode(',', $params->get('advertiser_ids'));
  47.         $this->advertiserIds = array_map(function ($item) {
  48.             return (int) trim($item);
  49.         }, $advertiserIds);
  50.     }
  52.     public static function getSubscribedEvents(): array
  53.     {
  54.         return [
  55.             BalanceWebmasterProvisionCreatedEvent::class => [
  56.                 ['trackIncome', 0],
  57.             ],
  58.             MemberCreatedEvent::class => [
  59.                 ['createWebmasterProvisionOnMemberSignupCompleted', 0],
  60.             ],
  61.         ];
  62.     }
  64.     protected function getPaymentMethodBlacklist(): array
  65.     {
  66.         return [
  67.             AdminBonusMethod::NAME,
  68.         ];
  69.     }
  71.     protected function getAdvertiserIds(): array
  72.     {
  73.         return $this->advertiserIds;
  74.     }
  76.     protected function ensureConditionsForIncomeProvision(BalanceWebmasterProvisionCreatedEvent $event): bool
  77.     {
  78.         $provision = $event->getBalance();
  79.         if (BalanceType::INCOME !== $provision->getType()) {
  80.             return false;
  81.         }
  82.         $advertisingWebmaster = $provision->getWebmaster();
  84.         // exit early, as this is only for some webmaster ids
  85.         if (!in_array($advertisingWebmaster->getId(), $this->getAdvertiserIds())) {
  86.             return false;
  87.         }
  89.         // payment could be null for provisions of provisions
  90.         $payment = $provision->getPayment();
  91.         if (!$payment) {
  92.             return false;
  93.         }
  95.         // ignore bonuses
  96.         if (in_array($payment->getMethod(), $this->getPaymentMethodBlacklist())) {
  97.             return false;
  98.         }
  100.         $account = $payment->getAccount();
  102.         // nothing to do without a tracking id
  103.         $trackingId = $account->getAdvertisedByTrackingId();
  104.         if (empty($trackingId)) {
  105.             return false;
  106.         }
  107.         if (!$account->getAdvertisedBy() || $account->getAdvertisedBy()->getId() != $advertisingWebmaster->getId()) {
  108.             return false;
  109.         }
  111.         return true;
  112.     }
  114.     /**
  115.      * @throws \Doctrine\ORM\ORMException
  116.      * @throws \Doctrine\ORM\OptimisticLockException
  117.      */
  118.     public function trackIncome(BalanceWebmasterProvisionCreatedEvent $event)
  119.     {
  120.         if (!$this->ensureConditionsForIncomeProvision($event)) {
  121.             return;
  122.         }
  124.         $provision = $event->getBalance();
  125.         $payment = $provision->getPayment();
  126.         $account = $payment->getAccount();
  127.         $trackingId = $account->getAdvertisedByTrackingId();
  129.         $jobManager = $this->jobService;
  130.         $job = new DelineSunctionPaymentTrackingJob($trackingId, $provision->getAmount(), $payment->getId(), $account->getId());
  131.         $jobManager->createSaveAndSchedule($job, '', null, DelineSunctionPaymentTrackingJob::queue);
  132.     }
  134.     public function createWebmasterProvisionOnMemberSignupCompleted(MemberCreatedEvent $event)
  135.     {
  136.         if (!$this->service->canTriggerSignupProvision($event->getMember())) {
  137.             return;
  138.         }
  139.         $webmaster = $event->getAccount()->getAdvertisedBy();
  140.         $provisionAmount = $this->webmasterPropertyService->getValueForWebmaster($webmaster, WebmasterService::PROPERTY_MEMBERCREATED_PROVISION_AMOUNT_NET);
  141.         $provision = $this->balanceWebmasterService->createSignupProvisionByWebmaster($webmaster, BalanceType::INCOME);
  142.         $provision->setAmountAddVat($provisionAmount, VAT::PERCENT_21_FACTOR);
  143.         $this->balanceWebmasterService->storeBalanceWebmaster($provision);
  144.     }
  145. }