src/EventListener/UserSubscriber.php line 28

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  5. use Symfony\Component\HttpKernel\Event\ControllerEvent;
  6. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  7. use Doctrine\DBAL\Connection;
  8. use Twig\Environment;
  10. class UserSubscriber
  11. {
  12.     private $connection;
  13.     private $twig;
  15.     public function __construct(Connection $connection, Environment $twig)
  16.     {
  17.         $this->connection = $connection;
  18.         $this->twig = $twig;
  19.     }
  21.     public function onKernelController(ControllerEvent $event): void
  22.     {
  23.         $request = $event->getRequest();
  24.         $session = $request->getSession();
  26.         $user = null;
  28.         if ($session->has('hash')) {
  29.             $hash = $session->get('hash');
  30.             $user = $this->connection->fetchAssociative('SELECT * FROM users WHERE hash = ?', [$hash]);
  32.             $sumDeposits = $this->connection->fetchOne(
  33.                 'SELECT COALESCE(SUM(suma), 0) FROM deposits WHERE user_id = ? AND status = 1',
  34.                 [$user['id']]
  35.             );
  36.             $xp = (int)$sumDeposits;
  38.             $levels = [
  39.                 ['xp' => 1000,      'bonus' => 100],
  40.                 ['xp' => 5000,      'bonus' => 250],
  41.                 ['xp' => 10000,  'bonus' => 500],
  42.                 ['xp' => 25000,  'bonus' => 1000],
  43.                 ['xp' => 100000, 'bonus' => 1500],
  44.             ];
  46.             $oldRank = $user['rank'];
  47.             $newRank = 0;
  48.             $totalBonus = 0;
  50.             foreach ($levels as $i => $level) {
  51.                 if ($xp >= $level['xp']) {
  52.                     $newRank = $i + 1; 
  53.                     if ($i + 1 > $oldRank) {
  54.                         $totalBonus += $level['bonus'];
  55.                     }
  56.                 } else {
  57.                     break;
  58.                 }
  59.             }
  61.             if ($newRank > $oldRank) {
  62.                 $this->connection->executeStatement(
  63.                     'UPDATE users SET balance = balance + :balance, wager = wager + :wager, `rank` = :rank WHERE id = :id',
  64.                     [
  65.                         'balance' => $totalBonus,
  66.                         'wager' => $totalBonus * 5,
  67.                         'rank' => $newRank,
  68.                         'id' => $user['id']
  69.                     ]
  70.                 );
  71.                 
  72.                 $this->connection->insert('events', [
  73.                     'user_id' => $user['id'],
  74.                     'event' => '[Rank] Получение бонуса +' . $totalBonus . '',
  75.                     'time' => (new \DateTime())->format('Y-m-d H:i:s')
  76.                 ]);
  77.                 
  78.                 $user['balance'] += $totalBonus;
  79.                 $user['wager'] += $totalBonus * 5;
  80.                 $user['rank'] = $newRank;
  81.             }
  82.         }
  84.         $this->twig->addGlobal('user', $user);
  85.     }
  86. }