src/Repository/OccupationPerHourRepository.php line 45

  1. <?php
  3. namespace App\Repository;
  5. use App\Entity\GroupAncestorDetails;
  6. use App\Entity\OccupationPerHour;
  7. use App\Entity\Resource;
  8. use App\Entity\Status;
  9. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  10. use Doctrine\ORM\Query\Expr\Join;
  11. use Doctrine\Persistence\ManagerRegistry;
  13. /**
  14.  * @extends ServiceEntityRepository<OccupationPerHour>
  15.  *
  16.  * @method OccupationPerHour|null find($id, $lockMode = null, $lockVersion = null)
  17.  * @method OccupationPerHour|null findOneBy(array $criteria, array $orderBy = null)
  18.  * @method OccupationPerHour[]    findAll()
  19.  * @method OccupationPerHour[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
  20.  */
  21. class OccupationPerHourRepository extends ServiceEntityRepository
  22. {
  23.     public function __construct(ManagerRegistry $registry)
  24.     {
  25.         parent::__construct($registry, OccupationPerHour::class);
  26.     }
  28.     public function save(OccupationPerHour $entity, bool $flush = false): void
  29.     {
  30.         $this->getEntityManager()->persist($entity);
  32.         if ($flush) {
  33.             $this->getEntityManager()->flush();
  34.         }
  35.     }
  37.     public function remove(OccupationPerHour $entity, bool $flush = false): void
  38.     {
  39.         $this->getEntityManager()->remove($entity);
  41.         if ($flush) {
  42.             $this->getEntityManager()->flush();
  43.         }
  44.     }
  45.     public function findCreneau($resource = null,$resourceType = null,$localisation = null, $startDate = null,$endDate = null,$user = null,$status): array
  46.     {
  47.         $conn = $this->getEntityManager()->getConnection();
  48.         $reqDate = "";
  49.         if ($startDate && $endDate){
  50.             $reqDate = " where date between '$startDate' and '$endDate 23:59:59'";
  51.         }elseif ($startDate){
  52.             $reqDate = " where date >= $startDate";
  53.         }elseif ($endDate){
  54.             $reqDate = " where date <= '$endDate 23:59:59'";
  55.         }
  56.         $reqUser = $user ? " and r.user_id = $user" : "";
  57.         $resourcesReq = "";
  58.         if ($resource) {
  59.             $resourcesReq = " and r.resource_id = $resource";
  60.         }else{
  61.             if ($localisation) {
  62.                 $resourcesReq  = " and r.resource_id in (SELECT DISTINCT id as resource FROM `resource` where group_ancestor_id in ($localisation))";
  63.             }
  64.             if ($resourceType) {
  65.                 $resourcesReq  .= " and r.resource_id in (SELECT DISTINCT id as resource FROM `resource` where group_ancestor_id in ($resourceType))";
  66.             }
  67.         }
  69.         $sql = "SELECT hour,date, sum(percentage) as 'value', sum(real_percentage) as 'value_reel'
  70.         FROM `occupation_per_hour` o 
  71.         left join reservation r on o.reservation_id = r.id $reqDate $reqUser $resourcesReq and r.status_id in ($status) group by hour,date";
  72.         $stmt = $conn->prepare($sql);
  73.         $resultSet = $stmt->executeQuery();
  74.     
  75.         // returns an array of arrays (i.e. a raw data set)
  76.         return $resultSet->fetchAllAssociative();
  77.     }
  78.     public function findReservationByDay($resource = null,$resourceType = null,$localisation = null, $startDate = null,$endDate = null,$user = null,$status): array
  79.     {
  80.         $conn = $this->getEntityManager()->getConnection();
  81.         $reqDate = "";
  82.         if ($startDate && $endDate){
  83.             $reqDate = " where date between '$startDate' and '$endDate 23:59:59'";
  84.         }elseif ($startDate){
  85.             $reqDate = " where date >= $startDate";
  86.         }elseif ($endDate){
  87.             $reqDate = " where date <= '$endDate 23:59:59'";
  88.         }
  89.         $reqUser = $user ? " and r.user_id = $user" : "";
  90.         $resourcesReq = "";
  91.         if ($resource) {
  92.             $resourcesReq = " and r.resource_id = $resource";
  93.         }else{
  94.             if ($localisation) {
  95.                 $resourcesReq  = " and r.resource_id in (SELECT DISTINCT id as resource FROM `resource` where group_ancestor_id in ($localisation))";
  96.             }
  97.             if ($resourceType) {
  98.                 $resourcesReq  .= " and r.resource_id in (SELECT DISTINCT id as resource FROM `resource` where group_ancestor_id in ($resourceType))";
  99.             }
  100.         }
  101.         $sql = "SELECT o.date,count(DISTINCT reservation_id) as value FROM `occupation_per_hour` o
  102.         left join reservation r on o.reservation_id = r.id $reqDate $reqUser $resourcesReq and r.status_id in ($status) group by date";
  103.         $stmt = $conn->prepare($sql);
  104.         $resultSet = $stmt->executeQuery();
  105.         // returns an array of arrays (i.e. a raw data set)
  106.         return $resultSet->fetchAllAssociative();
  107.     }
  109.     public function findByFilter($localisation, $user, $startDate, $endDate,$status, $lang,$resource = null,$resourceType = null, $filter = null, $limit = null){
  110.         $status = explode(',',$status);
  111.         $qb=$this->createQueryBuilder('oph')
  112.             ->leftJoin('oph.reservation','r')
  113.             ->leftJoin('r.resource','res')
  114.             ->andWhere('r.status in (:status)')
  115.             ->andWhere('oph.date between :startDate and :endDate')
  116.             ->setParameter('startDate',$startDate)
  117.             ->setParameter('endDate',$endDate)
  118.             ->setParameter('status',$status)
  119.             ->orderBy('value','DESC');
  121.         if ($filter != "resources") {
  122.             $qb->addSelect('count(distinct r.id) as value');
  123.         }
  124.         if ($filter == "resourceBySite") {
  125.             $qb->groupBy('item');
  126.             $qb->addSelect('ga.groupName as item');
  127.             $qb->leftJoin("res.groupParent", "ga");
  128.             $qb->andWhere('ga.groupTypeName=:groupTypeName')
  129.                 ->setParameter('groupTypeName','Localisation');
  130.         }elseif ($filter == "resourceByStage") {
  131.             $qb->addSelect('ga.groupName as item');
  132.             $qb->addSelect("st.id as status");
  133.             $qb->groupBy('item');
  134.             $qb->addGroupBy('st.id');
  136.             $qb->join(Status::class,'st',Join::WITH,'r.status=st.id');
  137.             $qb->leftJoin("res.groupAncestor", "ga")
  138.                 ->andWhere('ga.groupLevelId=4');
  139.             $qb->andWhere('ga.groupTypeName=:groupTypeName')
  140.                 ->setParameter('groupTypeName','Localisation');
  141.         }elseif ($filter == "resourceByZone") {
  142.             $qb->groupBy('item');
  143.             $qb->addSelect('ga.groupName as item');
  144.             $qb->leftJoin("res.groupAncestor", "ga")
  145.                 ->andWhere('ga.groupLevelId=5');
  146.             $qb->andWhere('ga.groupTypeName=:groupTypeName')
  147.                 ->setParameter('groupTypeName','Localisation');
  148.         }elseif ($filter == "resourceByBuilding") {
  149.             $qb->groupBy('item');
  150.             $qb->addSelect('ga.groupName as item');
  151.             $qb->select('ga_building.groupName as item', 'count(distinct r.id) as value')
  152.                 ->leftJoin("res.groupAncestor", "ga")
  153.                 ->leftJoin(GroupAncestorDetails::class,'ga_building',Join::WITH,'ga_building.od=ga.groupAncestor')
  154.                 ->andWhere('ga_building.groupLevelId=2');
  155.             $qb->andWhere('ga_building.groupTypeName=:groupTypeName')
  156.                 ->setParameter('groupTypeName','Localisation');
  157.         }elseif ($filter == "resourceByWing") {
  158.             $qb->groupBy('item');
  159.             $qb->addSelect('ga.groupName as item');
  160.             $qb->select('ga_building.groupName as item', 'count(distinct r.id) as value')
  161.             ->leftJoin("res.groupAncestor", "ga")
  162.             ->leftJoin(GroupAncestorDetails::class,'ga_building',Join::WITH,'ga_building.od=ga.groupAncestor')
  163.                 ->andWhere('ga_building.groupLevelId=3');
  164.             $qb->andWhere('ga_building.groupTypeName=:groupTypeName')
  165.                 ->setParameter('groupTypeName','Localisation');
  166.         }elseif ($filter == "hasNotChildren") {
  167.             $qb->groupBy('item');
  168.             $qb->addSelect('ga.groupName as item');
  169.             $qb->leftJoin(GroupAncestorDetails::class,'ga',Join::WITH,'ga.id=res.groupParentId');
  170.             $qb->leftJoin(GroupAncestorDetails::class,'ga_sub_category',Join::WITH,'ga.id=ga.groupAncestor');
  171.             $qb->andWhere('ga.groupTypeName=:groupTypeName and ga_sub_category.id is null')
  172.                 ->setParameter('groupTypeName','Type');
  173.         }elseif ($filter == "resourceByType") {
  174.             $qb->groupBy('item');
  175.             $qb->addSelect('ga.groupName as item');
  176.             $qb->leftJoin("res.groupAncestor", "ga");
  177.             $qb->leftJoin("res.groupParent", "ga_parent");
  178.             $qb->andWhere('ga.groupTypeName=:groupTypeName')
  179.                ->andWhere('ga_parent.groupTypeName=:groupTypeName')
  180.                 ->setParameter('groupTypeName','Type');
  181.             $qb->addSelect('ga_parent.groupName as site');
  182.         }elseif ($filter == "status") {
  183.             $qb->groupBy('item');
  184.             $qb->addSelect("case 
  185.                 when r.status = -1 then 'Refused' 
  186.                 when r.status = 0 then 'Cancelled' 
  187.                 when r.status = 1 then 'Pending' 
  188.                 else 'Confirmed' end as item");
  190.         }elseif ($filter == "origin") {
  191.             $qb->groupBy('item');
  192.             $qb->addSelect("case 
  193.                 when r.origin = 1 then 'App' 
  194.                 else '' end as item");
  196.         }elseif ($filter == "immediat_use") {
  197.             $qb->groupBy('item');
  198.             $qb->addSelect("case when r.immediatUse = 1 then 'Immediate use' else 'Deferred' end as item");
  200.         }elseif ($filter == "resources") {
  201.             $qb->addSelect("st.id as status");
  202.             $qb->join(Status::class,'st',Join::WITH,'r.status=st.id');
  203.             $qb->leftJoin("res.groupAncestor", "ga");
  204.             $qb->andWhere("ga.groupTypeName = 'Localisation'");
  205.             $qb->leftJoin("res.groupParent", "gaParent");
  206.             $qb->addSelect("concat(gaParent.groupName,' - ',res.Name) as item, count(distinct r.id) as value");
  207.             $qb->groupBy('res.id');
  208.             $qb->addGroupBy('st.id');
  210.         }
  212.         if ($resource) {
  213.             $qb->andWhere('r.resource=:resource_id')
  214.                 ->setParameter('resource_id',$resource);
  215.         }else{
  216.             $qb
  217.                 ->andWhere('r.resource in (SELECT DISTINCT rc.id  FROM App\Entity\Resource rc  where rc.groupAncestor in (:localisations))')
  218.                 ->andWhere('r.resource in (SELECT DISTINCT rc1.id  FROM App\Entity\Resource rc1  where rc1.groupAncestor in (:resourceTypes))')
  219.                 ->setParameter('localisations',explode(',',$localisation))
  220.                 ->setParameter('resourceTypes',explode(',',$resourceType));
  221.         }
  222.         if($user){
  223.             $qb->andWhere('r.userId=:user_id')->setParameter('user_id',$user);
  224.         }
  225.         if ($limit) {
  226.             $qb->setMaxResults($limit);
  227.         }
  228.         return $qb->getQuery()->getResult();
  229.     }
  230.     
  231.     public function synchroUpdateOph($data)
  232.     {
  233.        $conn = $this->getEntityManager()->getConnection();
  235.     //    $reservationIds = join(',',array_unique(array_column($data,'reservation_id')));
  236.     //    $stmt = $conn->prepare("delete from occupation_per_hour where reservation_id in ($reservationIds)")->executeQuery();
  237.        
  238.        foreach ($data as $item) {
  239.             $sql = "INSERT INTO occupation_per_hour
  240.                 (hour, date, percentage, real_percentage, reservation_id)
  241.             VALUES
  242.                 (:hour, :date, :percentage, :real_percentage, :reservation_id)";
  243.             $stmt = $conn->prepare($sql);
  244.             $stmt->bindValue(':hour',$item['hour']);
  245.             $stmt->bindValue(':date',$item['date']);
  246.             $stmt->bindValue(':percentage',$item['percentage']);
  247.             $stmt->bindValue(':real_percentage',$item['realPercentage']);
  248.             $stmt->bindValue(':reservation_id',$item['reservation_id']);
  249.             $stmt->executeQuery();
  250.        }
  252.        return true;
  253.     }
  254. //    /**
  255. //     * @return OccupationPerHour[] Returns an array of OccupationPerHour objects
  256. //     */
  257. //    public function findByExampleField($value): array
  258. //    {
  259. //        return $this->createQueryBuilder('o')
  260. //            ->andWhere('o.exampleField = :val')
  261. //            ->setParameter('val', $value)
  262. //            ->orderBy('o.id', 'ASC')
  263. //            ->setMaxResults(10)
  264. //            ->getQuery()
  265. //            ->getResult()
  266. //        ;
  267. //    }
  269. //    public function findOneBySomeField($value): ?OccupationPerHour
  270. //    {
  271. //        return $this->createQueryBuilder('o')
  272. //            ->andWhere('o.exampleField = :val')
  273. //            ->setParameter('val', $value)
  274. //            ->getQuery()
  275. //            ->getOneOrNullResult()
  276. //        ;
  277. //    }
  278. }