src/EventSubscriber/Tournament/TournamentEndedEventSubscriber.php line 26

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber\Tournament;
  5. use App\Entity\ContestPlayer;
  6. use App\Entity\Phase;
  7. use App\Entity\Transaction;
  8. use App\Event\Tournament\TournamentEndedEvent;
  9. use App\Factory\TransactionFactory;
  10. use App\Helper\ContestHelper;
  11. use App\Helper\TournamentHelper;
  12. use App\Service\TournamentService;
  13. use Doctrine\ORM\EntityManagerInterface;
  14. use LogicException;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Throwable;
  18. class TournamentEndedEventSubscriber implements EventSubscriberInterface
  19. {
  20.     public function __construct(
  21.         private EntityManagerInterface $entityManager, private TransactionFactory $transactionFactory,
  22.         private TournamentService $tournamentService
  23.     ) {
  24.     }
  26.     public function onTournamentEndedEvent(TournamentEndedEvent $tournamentEndedEvent): void
  27.     {
  28.         $tournament = $tournamentEndedEvent->getTournament();
  29.         $jackpot = $this->tournamentService->calculateJackpot($tournament);
  31.         /** @var Phase $penultimatePhase the before last phase */
  32.         $penultimatePhase = array_reverse($tournament->getPhases()->toArray())[1];
  33.         /** @var Phase|null $beforePenultimatePhase */
  34.         $beforePenultimatePhase = array_reverse($tournament->getPhases()->toArray())[2] ?? null;
  35.         $finalContest = TournamentHelper::getFinalContest($tournament);
  37.         foreach ($tournament->getPrizes() as $prize) {
  38.             $rewardedPs = $jackpot / 100 * $prize->getValue();
  40.             if ($prize->getRank() === 1) {
  41.                 $player = $finalContest->getWinner();
  43.                 $this->transactionFactory
  44.                     ->forPlayer($player)
  45.                     ->givePs($rewardedPs)
  46.                     ->because(Transaction::TOURNAMENT_WINNER_TYPE)
  47.                     ->save()
  48.                 ;
  50.                 $prize->addPlayer($player);
  52.                 continue;
  53.             }
  55.             if ($prize->getRank() === 2) {
  56.                 $contestPlayers = $finalContest->getContestPlayers()->filter(function (ContestPlayer $contestPlayer) use ($finalContest) {
  57.                     return $contestPlayer->getPlayer() !== $finalContest->getWinner();
  58.                 });
  60.                 if ($contestPlayers->isEmpty()) {
  61.                     continue;
  62.                 }
  64.                 /** @var ContestPlayer $contestPlayer */
  65.                 $contestPlayer = $contestPlayers->first();
  66.                 $player = $contestPlayer->getPlayer();
  68.                 $this->transactionFactory
  69.                     ->forPlayer($player)
  70.                     ->givePs($rewardedPs)
  71.                     ->because(Transaction::TOURNAMENT_WINNER_TYPE)
  72.                     ->save()
  73.                 ;
  75.                 $prize->addPlayer($player);
  77.                 continue;
  78.             }
  80.             if ($prize->getRank() === 3) {
  81.                 $players = null;
  83.                 foreach ($penultimatePhase->getContests() as $contest) {
  84.                     try {
  85.                         $players[] = ContestHelper::getLoser($contest);
  86.                     } catch (Throwable) {
  87.                         continue;
  88.                     }
  89.                 }
  91.                 if (empty($players)) {
  92.                     continue;
  93.                 }
  95.                 foreach ($players as $player) {
  96.                     $this->transactionFactory
  97.                         ->forPlayer($player)
  98.                         ->givePs($rewardedPs)
  99.                         ->because(Transaction::TOURNAMENT_WINNER_TYPE)
  100.                         ->save()
  101.                     ;
  103.                     $prize->addPlayer($player);
  104.                 }
  106.                 continue;
  107.             }
  109.             if ($prize->getRank() === 4) {
  110.                 // handle tournament that does not have before penultimate phase
  111.                 if (!$beforePenultimatePhase) {
  112.                     continue;
  113.                 }
  115.                 $players = null;
  117.                 // loops through all contests of the tournament
  118.                 foreach ($beforePenultimatePhase->getContests() as $contest) {
  119.                     try {
  120.                         $players[] = ContestHelper::getLoser($contest);
  121.                     } catch (Throwable) {
  122.                         continue;
  123.                     }
  124.                 }
  126.                 if (empty($players)) {
  127.                     continue;
  128.                 }
  130.                 foreach ($players as $player) {
  131.                     $this->transactionFactory
  132.                         ->forPlayer($player)
  133.                         ->givePs($rewardedPs)
  134.                         ->because(Transaction::TOURNAMENT_WINNER_TYPE)
  135.                         ->save()
  136.                     ;
  138.                     $prize->addPlayer($player);
  139.                 }
  141.                 continue;
  142.             }
  144.             throw new LogicException('Unsupported prize ranking passed: ' . $prize->getRank());
  145.         }
  147.         $this->entityManager->flush();
  148.     }
  150.     public static function getSubscribedEvents(): array
  151.     {
  152.         return [
  153.             TournamentEndedEvent::class => 'onTournamentEndedEvent',
  154.         ];
  155.     }
  156. }