src/Repository/UserSessionLogRepository.php line 25

Open in your IDE?
  1. <?php
  3. namespace App\Repository;
  5. use App\Entity\UserSessionLog;
  6. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  7. use Doctrine\Persistence\ManagerRegistry;
  9. /**
  10.  * @method UserSessionLog|null find($id, $lockMode = null, $lockVersion = null)
  11.  * @method UserSessionLog|null findOneBy(array $criteria, array $orderBy = null)
  12.  * @method UserSessionLog[]    findAll()
  13.  * @method UserSessionLog[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
  14.  */
  15. class UserSessionLogRepository extends ServiceEntityRepository
  16. {
  17.     public function __construct(ManagerRegistry $registry)
  18.     {
  19.         parent::__construct($registry, UserSessionLog::class);
  20.     }
  22.     /**
  23.      * Find active session by session ID
  24.      */
  25.     public function findActiveBySessionId(string $sessionId): ?UserSessionLog
  26.     {
  27.         return $this->createQueryBuilder('s')
  28.             ->andWhere('s.sessionId = :sessionId')
  29.             ->andWhere('s.logoutAt IS NULL')
  30.             ->setParameter('sessionId', $sessionId)
  31.             ->getQuery()
  32.             ->getOneOrNullResult();
  33.     }
  35.     /**
  36.      * Find all active sessions
  37.      */
  38.     public function findActiveSessions(): array
  39.     {
  40.         return $this->createQueryBuilder('s')
  41.             ->andWhere('s.logoutAt IS NULL')
  42.             ->orderBy('s.lastActivityAt', 'DESC')
  43.             ->getQuery()
  44.             ->getResult();
  45.     }
  47.     /**
  48.      * Close inactive sessions (no activity for more than X minutes)
  49.      */
  50.     public function closeInactiveSessions(int $inactiveMinutes = 30): int
  51.     {
  52.         $threshold = new \DateTime();
  53.         $threshold->modify("-{$inactiveMinutes} minutes");
  55.         $qb = $this->createQueryBuilder('s');
  57.         return $qb->update()
  58.             ->set('s.logoutAt', ':now')
  59.             ->set('s.duration', 'TIMESTAMPDIFF(SECOND, s.loginAt, s.lastActivityAt)')
  60.             ->where('s.logoutAt IS NULL')
  61.             ->andWhere('s.lastActivityAt < :threshold')
  62.             ->setParameter('now', new \DateTime())
  63.             ->setParameter('threshold', $threshold)
  64.             ->getQuery()
  65.             ->execute();
  66.     }
  68.     /**
  69.      * Get user session statistics
  70.      */
  71.     public function getUserStats(int $userId, \DateTimeInterface $from, \DateTimeInterface $to): array
  72.     {
  73.         $qb = $this->createQueryBuilder('s');
  75.         return $qb->select([
  76.                 'COUNT(s.id) as total_sessions',
  77.                 'SUM(s.duration) as total_duration',
  78.                 'AVG(s.duration) as avg_duration',
  79.                 'MAX(s.duration) as max_duration',
  80.                 'MIN(s.duration) as min_duration',
  81.             ])
  82.             ->where('s.user = :userId')
  83.             ->andWhere('s.loginAt >= :from')
  84.             ->andWhere('s.loginAt <= :to')
  85.             ->setParameter('userId', $userId)
  86.             ->setParameter('from', $from)
  87.             ->setParameter('to', $to)
  88.             ->getQuery()
  89.             ->getSingleResult();
  90.     }
  91. }