src/Repository/User/UserRepository.php line 78

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Slivki\Repository\User;
  7. use Doctrine\ORM\EntityManagerInterface;
  8. use Doctrine\ORM\EntityRepository;
  9. use Doctrine\ORM\Mapping\ClassMetadata;
  10. use Doctrine\ORM\NonUniqueResultException;
  11. use Doctrine\ORM\Query\Expr\Join;
  12. use Slivki\Entity\Director;
  13. use Slivki\Entity\MobileUserToken;
  14. use Slivki\Entity\User;
  15. use Slivki\Entity\User\Employee;
  16. use Slivki\Exception\UserNotFoundException;
  18. use function mb_strtolower;
  20. final class UserRepository extends EntityRepository implements UserRepositoryInterface
  21. {
  22.     public function __construct(EntityManagerInterface $entityManager)
  23.     {
  24.         parent::__construct($entityManager, new ClassMetadata(User::class));
  25.     }
  27.     public function save(User $user): void
  28.     {
  29.         $this->_em->persist($user);
  30.         $this->_em->flush($user);
  31.     }
  33.     public function getById(int $id): User
  34.     {
  35.         $qb = $this->createQueryBuilder('u');
  36.         $expr = $qb->expr();
  38.         $user = $qb
  39.             ->andWhere($expr->eq('u.ID', ':id'))
  40.             ->setParameter('id', $id)
  41.             ->getQuery()
  42.             ->getOneOrNullResult();
  44.         if (!$user instanceof User) {
  45.             throw UserNotFoundException::missingId($id);
  46.         }
  48.         return $user;
  49.     }
  51.     public function findByToken(string $token): ?User
  52.     {
  53.         $qb = $this->createQueryBuilder('user');
  54.         $expr = $qb->expr();
  56.         return $qb
  57.             ->andWhere($expr->eq('user.token', ':token'))
  58.             ->setParameter('token', $token)
  59.             ->getQuery()
  60.             ->getOneOrNullResult();
  61.     }
  63.     public function findByMobileToken(string $token): ?User
  64.     {
  65.         $qb = $this->createQueryBuilder('user');
  66.         $expr = $qb->expr();
  68.         return $qb
  69.             ->innerJoin(
  70.                 MobileUserToken::class,
  71.                 'mobileUserToken',
  72.                 Join::WITH,
  73.                 $expr->eq('user', 'mobileUserToken.user'),
  74.             )
  75.             ->andWhere($expr->eq('mobileUserToken.token', ':token'))
  76.             ->setParameter('token', $token)
  77.             ->getQuery()
  78.             ->getOneOrNullResult();
  79.     }
  81.     /**
  82.      * @throws NonUniqueResultException
  83.      */
  84.     public function findByPhoneNumber(string $phoneNumber): ?User
  85.     {
  86.         $qb = $this->createQueryBuilder('user');
  87.         $expr = $qb->expr();
  89.         return $qb
  90.             ->innerJoin('user.phones', 'userPhone')
  91.             ->andWhere($expr->eq('userPhone.confirmed', ':confirmed'))
  92.             ->andWhere($expr->eq('userPhone.phoneNumber', ':phoneNumber'))
  93.             ->setParameter('confirmed', true)
  94.             ->setParameter('phoneNumber', $phoneNumber)
  95.             ->getQuery()
  96.             ->getOneOrNullResult();
  97.     }
  99.     public function getByEmail(string $email): User
  100.     {
  101.         $qb = $this->createQueryBuilder('u');
  102.         $expr = $qb->expr();
  104.         $user = $qb
  105.             ->andWhere($expr->eq($expr->lower('u.email'), ':email'))
  106.             ->setParameter('email', mb_strtolower($email))
  107.             ->getQuery()
  108.             ->getOneOrNullResult();
  110.         if (!$user instanceof User) {
  111.             throw UserNotFoundException::missingByEmail($email);
  112.         }
  114.         return $user;
  115.     }
  117.     public function findDirectorUserByEmployeeUserId(int $userId): ?User
  118.     {
  119.         $qb = $this->createQueryBuilder('user');
  120.         $expr = $qb->expr();
  122.         return $qb
  123.             ->innerJoin(Director::class, 'director', Join::WITH, $expr->eq('director.email', 'user.email'))
  124.             ->innerJoin(Employee::class, 'employee', Join::WITH, $expr->eq('employee.company', 'director'))
  125.             ->andWhere($expr->eq('employee.user', ':userId'))
  126.             ->setParameter('userId', $userId)
  127.             ->getQuery()
  128.             ->getOneOrNullResult();
  129.     }
  130. }