src/Repository/UserRepository.php line 36

Open in your IDE?
  1. <?php
  3. namespace App\Repository;
  5. use App\Entity\User;
  6. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  7. use Doctrine\ORM\EntityManagerInterface;
  8. use Doctrine\Persistence\ManagerRegistry;
  10. /**
  11.  * @method User|null find($id, $lockMode = null, $lockVersion = null)
  12.  * @method User|null findOneBy(array $criteria, array $orderBy = null)
  13.  * @method User[]    findAll()
  14.  * @method User[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
  15.  */
  16. class UserRepository extends ServiceEntityRepository
  17. {
  19.     private $entityManager;
  21.     public function __construct(ManagerRegistry $registry, EntityManagerInterface $entityManager)
  22.     {
  23.         parent::__construct($registry, User::class);
  24.         $this->entityManager = $entityManager;
  25.     }
  27.     public function saveUser($user):User
  28.     {
  29.         $this->entityManager->persist($user);
  30.         $this->entityManager->flush();
  31.         return $user;
  32.     }
  34.     public function findOneByUsernameOrEmail($value): ?User
  35.     {
  36.         return $this->createQueryBuilder('u')
  37.             ->andWhere('u.email = :val or u.username = :val')
  38.             ->setParameter('val', $value)
  39.             ->getQuery()
  40.             ->getOneOrNullResult();
  41.     }
  43.    
  44.     public function changeValidite(User $user){
  45.         if ($user->isValid())
  46.         {
  47.             $user->setValid(false);
  48.         }
  49.         else
  50.         {
  51.             if((!$user->getFechaExpiracionClave()) or 
  52.                 ($user->getFechaExpiracionClave() > (new \DateTime('now'))))
  53.             {
  54.                 $user->setValid(true);
  55.             }
  56.         }
  57.         $this->entityManager->persist($user);
  58.         $this->entityManager->flush();
  59.         return $user;
  60.     }
  62.     public function delete(User $user){
  63.         $user->setDeleted(true);
  64.         $this->entityManager->persist($user);
  65.         $this->entityManager->flush();
  66.         return $user;
  67.     }
  69.     public function findClavesExpiradas()
  70.     {
  71.         $fecha = (new \DateTime('today'));
  73.         return $this->createQueryBuilder("q")
  74.             ->andWhere("q.valid = 1")
  75.             ->andWhere("q.fechaExpiracionClave IS NOT NULL")
  76.             ->andWhere("q.fechaExpiracionClave <= :fecha")
  77.             ->setParameter('fecha', $fecha)
  78.             ->getQuery()
  79.             ->getResult()
  80.         ;
  81.     }
  82.     public function buscarEjecutivaPorCliente($clienteId): ?User
  83. {
  84.     // Crear una conexión directa a la base de datos
  85.     $conn = $this->getEntityManager()->getConnection();
  87.     // Consulta SQL para buscar la ejecutiva en la tabla `ejecutiva_cliente`
  88.     $sql = '
  89.         SELECT u.*
  90.         FROM user u
  91.         INNER JOIN ejecutiva_cliente ec ON u.id = ec.ejecutiva_id
  92.         WHERE ec.cliente_id = :clienteId
  93.         AND u.es_ejecutiva = 1
  94.         LIMIT 1
  95.     ';
  97.     // Preparar y ejecutar la consulta
  98.     $stmt = $conn->prepare($sql);
  99.     $result = $stmt->executeQuery(['clienteId' => $clienteId])->fetchAssociative();
  101.     // Si se encuentra un resultado, retornar el objeto User
  102.     if ($result) {
  103.         return $this->getEntityManager()->getRepository(User::class)->find($result['id']);
  104.     }
  106.     // Retornar null si no se encuentra una ejecutiva
  107.     return null;
  108. }
  110.     public function getClientesPorEjecutiva(User $ejecutiva): array
  111. {
  112.     $qb = $this->createQueryBuilder('u')
  113.         ->select('c.id')
  114.         ->innerJoin('u.clientes', 'c') // Relación entre User y Cliente
  115.         ->where('u.id = :ejecutivaId')
  116.         ->setParameter('ejecutivaId', $ejecutiva->getId());
  118.     return $qb->getQuery()->getArrayResult();
  119. }
  121.     public function findClavesPorExpirar($dias)
  122.     {
  123.         $interval = new \DateInterval('P'.$dias.'D');
  124.         $fecha_desde = (new \DateTime('today'));
  125.         $fecha_hasta = (new \DateTime('today'))->add($interval);
  127.         $interval2 = new \DateInterval('P1D');
  128.         $interval2->invert = 1;
  129.         $fecha_notificacion = (new \DateTime('today'))->add($interval2);
  131.         return $this->createQueryBuilder("q")
  132.             ->andWhere("q.valid = 1")
  133.             ->andWhere("q.fechaExpiracionClave IS NOT NULL")
  134.             ->andWhere("q.fechaExpiracionClave >= :fecha_desde")
  135.             ->andWhere("q.fechaExpiracionClave <= :fecha_hasta")
  136.             ->andWhere("q.fechaNotificacionExpiracionClave IS NULL OR q.fechaNotificacionExpiracionClave < :fecha_notificacion")
  137.             ->setParameter('fecha_desde', $fecha_desde)
  138.             ->setParameter('fecha_hasta', $fecha_hasta)
  139.             ->setParameter('fecha_notificacion', $fecha_notificacion)
  140.             ->getQuery()
  141.             ->getResult()
  142.         ;
  143.     }
  144. }