src/Subscriber/Payment/Purchase/PurchaseMemberContentSubscriber.php line 50

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Payment\Purchase;
  5. use App\Event\Payment\PurchaseCreatedEvent;
  6. use App\Lib\Purchase\ContentPurchasable;
  7. use App\Lib\Purchase\ImageContentPurchasable;
  8. use App\Service\Amateur\BalanceAmateurService;
  9. use App\Service\Content\ContentService;
  10. use App\Service\Content\MemberContentService;
  11. use App\Service\User\MemberRankingService;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class PurchaseMemberContentSubscriber implements EventSubscriberInterface
  15. {
  16.     protected MemberContentService $service;
  18.     protected ContentService $contentService;
  20.     protected MemberRankingService $memberRankingService;
  22.     protected BalanceAmateurService $balanceAmateurService;
  24.     /**
  25.      * PurchaseMemberContentSubscriber constructor.
  26.      */
  27.     public function __construct(MemberContentService $service, ContentService $contentService,
  28.         MemberRankingService $rankingService, BalanceAmateurService $balanceAmateurService)
  29.     {
  30.         $this->service = $service;
  31.         $this->contentService = $contentService;
  32.         $this->memberRankingService = $rankingService;
  33.         $this->balanceAmateurService = $balanceAmateurService;
  34.     }
  36.     public static function getSubscribedEvents(): array
  37.     {
  38.         return [
  39.             PurchaseCreatedEvent::class => [
  40.                 ['onContentPurchaseCreateMemberContent', 0],
  41.                 ['onContentPurchaseUpdateSellersMemberRanking', 1],
  42.             ],
  43.         ];
  44.     }
  46.     /**
  47.      * @throws \Doctrine\ORM\ORMException
  48.      * @throws \Doctrine\ORM\OptimisticLockException
  49.      */
  50.     public function onContentPurchaseCreateMemberContent(PurchaseCreatedEvent $event)
  51.     {
  52.         if (!$event->getPurchasable() instanceof ContentPurchasable) {
  53.             return;
  54.         }
  56.         $purchase = $event->getPurchase();
  57.         $purchasable = $event->getPurchasable();
  58.         $content = $this->contentService->getContentById($purchase->getReferenceId());
  60.         if ($purchasable instanceof ImageContentPurchasable) {
  61.             $memberContent = $this->service->createByMemberAndContent($purchase->getBuyer(), $content, $purchasable->getImagesetImageId());
  62.         } else {
  63.             $memberContent = $this->service->createByMemberAndContent($purchase->getBuyer(), $content);
  64.         }
  66.         $memberContent->setPurchase($purchase);
  67.         $memberContent->setCoins($event->getPurchasable()->getCoinAmount());
  69.         $this->service->storeMemberContent($memberContent);
  70.     }
  72.     /**
  73.      * @throws \Doctrine\ORM\ORMException
  74.      * @throws \Doctrine\ORM\OptimisticLockException
  75.      */
  76.     public function onContentPurchaseUpdateSellersMemberRanking(PurchaseCreatedEvent $event)
  77.     {
  78.         if (!$event->getPurchasable() instanceof ContentPurchasable) {
  79.             return;
  80.         }
  82.         $purchase = $event->getPurchase();
  83.         $amateur = $purchase->getSeller();
  84.         if (!$amateur->getIsAmateur()) {
  85.             return;
  86.         }
  88.         $ranking = $this->memberRankingService->getRankingByMember($amateur);
  89.         $ranking->setAmateurScore($this->balanceAmateurService->getSumBalancesForMemberSinceNumberOfDays($amateur, 30));
  91.         $this->memberRankingService->storeRanking($ranking);
  92.     }
  93. }