src/Controller/Evrp/IdentificationSSTJOBController.php line 355

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Evrp;
  5. use App\Entity\bilan\Mission;
  6. use App\Entity\bilan\MOG;
  7. use App\Entity\bilan\Situation;
  8. use App\Entity\bilan\SituationRisque;
  9. use App\Entity\bilan\Task;
  10. use App\Entity\Configuration\CompanyEntity;
  11. use App\Repository\bilan\CriticiteRepository;
  12. use App\Repository\bilan\FrequenceRepository;
  13. use App\Repository\bilan\GraviteRepository;
  14. use App\Repository\bilan\JobRepository;
  15. use App\Repository\bilan\MissionRepository;
  16. use App\Repository\bilan\MOGRepository;
  17. use App\Repository\bilan\RisqueRepository;
  18. use App\Repository\bilan\SituationRepository;
  19. use App\Repository\bilan\SituationRisqueRepository;
  20. use App\Repository\bilan\TaskRepository;
  21. use App\Repository\Configuration\CompanyEntityRepository;
  22. use App\Service\SelectedEntityService;
  23. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  24. use Symfony\Component\HttpFoundation\JsonResponse;
  25. use Symfony\Component\HttpFoundation\Request;
  26. use Symfony\Component\HttpFoundation\Response;
  27. use Symfony\Component\Routing\Annotation\Route;
  28. use Symfony\Contracts\Cache\CacheInterface;
  29. use Symfony\Contracts\Cache\ItemInterface;
  31. /**
  32.  * @Route("/identification-metier")
  33.  */
  34. class IdentificationSSTJOBController extends AbstractController
  35. {
  36.     private $jobRepository;
  37.     private $criticiteRepository;
  38.     private $frequenceRepository;
  39.     private $graviteRepository;
  40.     private $risqueRepository;
  41.     private $mogRepository;
  42.     private $cache;
  44.     public function __construct(
  45.         JobRepository $jobRepository,
  46.         CriticiteRepository $criticiteRepository,
  47.         FrequenceRepository $frequenceRepository,
  48.         GraviteRepository $graviteRepository,
  49.         RisqueRepository $risqueRepository,
  50.         MOGRepository $mogRepository,
  51.         CacheInterface $cache
  52.     )
  53.     {
  54.         $this->jobRepository = $jobRepository;
  55.         $this->criticiteRepository = $criticiteRepository;
  56.         $this->cache = $cache;
  57.         $this->frequenceRepository = $frequenceRepository;
  58.         $this->graviteRepository = $graviteRepository;
  59.         $this->risqueRepository = $risqueRepository;
  60.         $this->mogRepository = $mogRepository;
  61.     }
  63.     /**
  64.      * @Route("/", name="job")
  65.      */
  66.     public function index(SelectedEntityService $selectedEntityService, CompanyEntityRepository $ceRepo, RisqueRepository $risqueRepository): Response
  67.     {
  68.         $entities = [];
  69.         $selectedEntity = $selectedEntityService->getSelectedEntity();
  70.         if (null === $selectedEntity) {
  71.             $entities = $ceRepo->findAll();
  72.         }
  74.         $menu = 'evaluate';
  75.         $left_menu = 'identification-metier';
  76.         return $this->render('evrp/identification_sst/job/index.html.twig', [
  77.             'menu' => $menu,
  78.             'left_menu' => $left_menu,
  79.             'entities' => $entities,
  80.             'selectedEntity' => $selectedEntity
  81.         ]);
  82.     }
  84.     /**
  85.      * @Route("/jobs", name="getJobs", methods={"GET"})
  86.      */
  87.     public function getJobs(): JsonResponse
  88.     {
  89.         $jobs = $this->jobRepository->findAll();
  90.          $jobsData = array_map(function ($job) {
  91.              $processus = $job->getProcessus();
  92.              $responsible = $processus->getPilote();
  93.             return [
  94.                 'id' => $job->getId(),
  95.                 'title' => $job->getTitle(),
  96.                 'responsible' => $responsible->getFullName(),
  97.                 'fonction' => $responsible->getFonction(),
  98.                 'processus' => $processus->getTitle(),
  99.             ];
  100.         }, $jobs);
  101.         return new JsonResponse(['jobs' => $jobsData]);
  102.     }
  104.     /**
  105.      * @Route("/tasks/{mission}/{companyEntity}", name="getTasksByMission", methods={"GET"})
  106.      */
  107.     public function getTasksByMission(
  108.         Mission $mission,
  109.         CompanyEntity $companyEntity,
  110.         TaskRepository $taskRepository,
  111.         SituationRepository $situationRepository,
  112.         SituationRisqueRepository $situationRisqueRepository
  113.     ): JsonResponse {
  114.         $tasks = $taskRepository->findBy(['mission' => $mission, 'companyEntity' => $companyEntity], ['id' => 'DESC']);
  115.         $tasksData = array_map(
  116.             function ($task) use ($situationRepository, $situationRisqueRepository) {
  117.                 return $this->formatTask($task, $situationRepository, $situationRisqueRepository);
  118.             },
  119.             $tasks
  120.         );
  122.         return new JsonResponse(['tasks' => $tasksData]);
  123.     }
  126.     private function formatTask(
  127.         $task,
  128.         SituationRepository $situationRepository,
  129.         SituationRisqueRepository $situationRisqueRepository
  130.     ): array {
  131.         $situations = $situationRepository->findBy(['task' => $task], ['id' => 'DESC']);
  133.         return [
  134.             'id' => (string) $task->getId(),
  135.             'title' => $task->getTitle(),
  136.             'situations' => array_map(
  137.                 function ($situation) use ($situationRisqueRepository) {
  138.                     return $this->formatSituation($situation, $situationRisqueRepository);
  139.                 },
  140.                 $situations
  141.             )
  142.         ];
  143.     }
  145.     private function formatSituation($situation, SituationRisqueRepository $situationRisqueRepository): array
  146.     {
  147.         $situationsRisque = $situationRisqueRepository->findBy(['situation' => $situation], ['id' => 'DESC']);
  149.         return [
  150.             'id' => (string) $situation->getId(),
  151.             'title' => $situation->getTitle(),
  152.             'situation_risques' => array_map(
  153.                 function ($situationRisque) {
  154.                     return $this->formatSituationRisque($situationRisque);
  155.                 },
  156.                 $situationsRisque
  157.             )
  158.         ];
  159.     }
  161.     private function formatSituationRisque($situationRisque): array
  162.     {
  163.         $criticite_array = $this->getCachedCriticiteData();
  164.         $frequence = $situationRisque->getFrequence();
  165.         $gravite = $situationRisque->getGravite();
  167.         $idFrequence = $frequence ? $frequence->getId() : null;
  168.         $frequenceNote = $frequence ? $frequence->getNote() : 0;
  169.         $idGravite = $gravite ? $gravite->getId() : null;
  170.         $graviteNote = $gravite ? $gravite->getNote() : 0;
  172.         $criticiteValue=$frequenceNote*$graviteNote;
  173.         $criticite='';
  174.         $criticite_valeur=0;
  175.         $criticite_color='';
  176.         if($idFrequence && $idGravite) {
  177.             foreach ($criticite_array as $criticite_element) {
  178.                 if (($criticite_element->getType()=='criticite')&&($criticiteValue  >=$criticite_element->getValeur())) {
  179.                     $criticite=$criticite_element->getLegende();
  180.                     $criticite_valeur=$criticite_element->getValeur();
  181.                     $criticite_color=$criticite_element->getCouleur();
  182.                 }
  183.             }
  184.         }
  185.         
  186.         $mog = $situationRisque->getMog();
  187.         $idMog = $mog ? $mog->getId() : null;
  188.         $mogNote = $mog ? $mog->getNote() : 0;
  190.         $risqueResiduelValue = $criticiteValue * $mogNote;
  191.         $risqueResiduel='';
  192.         $risqueResiduel_valeur=0;
  193.         $risqueResiduel_color='';
  194.         if($idMog) {
  195.                 foreach ($criticite_array as $RR_element) {
  196.                 if (($RR_element->getType()=='prevention')&&($risqueResiduelValue >=$RR_element->getValeur())) {
  197.                     $risqueResiduel=$RR_element->getLegende();
  198.                     $risqueResiduel_valeur=$RR_element->getValeur();
  199.                     $risqueResiduel_color=$RR_element->getCouleur();
  200.                 }
  201.             }
  202.         }
  204.         return [
  205.             'id' => (string) $situationRisque->getId(),
  206.             'idRisque' => $situationRisque->getRisque() ? $situationRisque->getRisque()->getId() : null,
  207.             'risque' => $situationRisque->getRisque()->getNom() ?? null,
  208.             'idFrequence' => $idFrequence,
  209.             'frequenceNote' => $frequenceNote,
  210.             'idGravite' => $idGravite,
  211.             'graviteNote' => $graviteNote,
  212.             'criticiteValue' => $criticiteValue,
  213.             'criticite' => $criticite,
  214.             'criticite_valeur' => $criticite_valeur,
  215.             'criticite_color' => $criticite_color,
  216.             'idMog' => $idMog,
  217.             'mogNote' => $mogNote,
  218.             'risqueResiduelValue' => $risqueResiduelValue,
  219.             'risqueResiduel' => $risqueResiduel,
  220.             'risqueResiduel_valeur' => $risqueResiduel_valeur,
  221.             'risqueResiduel_color' => $risqueResiduel_color,
  222.         ];
  223.     }
  226.     /**
  227.      * this controller is to save tasks and situations and situation risques in step 2 of identification SST JOB
  228.      * @Route("/tasks/save", name="saveTask" , methods={"POST"})
  229.      */
  230.     public function saveTask(
  231.         Request $request,
  232.         CompanyEntityRepository $companyEntityRepository,
  233.         MissionRepository $missionRepository,
  234.         TaskRepository $taskRepository,
  235.         SituationRepository $situationRepository,
  236.         SituationRisqueRepository $situationRisqueRepository,
  237.         RisqueRepository $risqueRepository
  238.     ): JsonResponse
  239.     {
  240.         $companyEntityId = $request->request->getInt('companyEntityId');
  241.         if (!$companyEntityId) {
  242.             return new JsonResponse([
  243.                 'error' => 'companyEntity ID is required'
  244.             ], Response::HTTP_BAD_REQUEST);
  245.         }
  246.         $companyEntity = $companyEntityRepository->find($companyEntityId);
  247.         if (!$companyEntity) {
  248.             return new JsonResponse([
  249.                 'error' => sprintf('Company entity with ID %d not found', $companyEntityId)
  250.             ], Response::HTTP_NOT_FOUND);
  251.         }
  253.         $idMission = $request->request->getInt('idMission');
  254.         if (!$idMission) {
  255.             return new JsonResponse([
  256.                 'error' => 'Mission ID is required'
  257.             ], Response::HTTP_BAD_REQUEST);
  258.         }
  259.         $mission = $missionRepository->find($idMission);
  260.         if (!$mission) {
  261.             return new JsonResponse([
  262.                 'error' => sprintf('Mission with ID %d not found', $idMission)
  263.             ], Response::HTTP_NOT_FOUND);
  264.         }
  266.         $idTask = $request->request->get('idTask');
  267.         if (!$idTask) {
  268.             return new JsonResponse([
  269.                 'error' => 'Task ID is required'
  270.             ], Response::HTTP_BAD_REQUEST);
  271.         }
  273.         $currentUser = $this->getUser();
  274.         $isNewTask = str_starts_with($idTask, "new");
  275.         $task = $isNewTask ? new Task() : $taskRepository->find($idTask);
  276.         $task->setMission($mission);
  277.         $task->setCompanyEntity($companyEntity);
  278.         if($isNewTask) {
  279.             $task->setCreatedAt(new \DateTime());
  280.             $task->setCreatedBy($currentUser);
  281.         }else {
  282.             $task->setUpdatedBy($currentUser);
  283.             $task->setUpdatedAt(new \DateTime());
  284.         }
  285.         
  286.         if (!empty($request->request->get('taskTitle'))) {
  287.             $taskTitle = $request->request->get('taskTitle');
  288.             $task->setTitle($taskTitle);
  289.             if ($isNewTask) {
  290.                 $task->setSlug(Task::generateSlug($taskTitle));
  291.             }
  292.         }
  294.         $situations = $request->request->get('situations');
  295.         if (!empty($situations) && is_array($situations)) {
  296.             foreach ($situations as $situationData) {
  297.                 $isNewSituation =  str_starts_with($situationData['id'], "new");
  298.                 $situation = $isNewSituation ? new Situation() :  $situationRepository->find($situationData['id']);
  299.                 $situation->setTitle($situationData['title']);
  300.                 $situation->setTask($task);
  301.                 $task->addSituation($situation);
  302.         
  303.                 if($isNewSituation) {
  304.                     $situation->setCreatedBy($currentUser);
  305.                 }else {
  306.                     $situation->setUpdatedBy($currentUser);
  307.                 }
  309.                 if(!empty($situationData['situationRisks']) && is_array($situationData['situationRisks'])) {
  310.                     $newSituationRiskIds = array_column($situationData['situationRisks'], 'idRisque');
  311.                     if(count($newSituationRiskIds) === 0) {
  312.                         $situation->removeAllSituationRisques();
  313.                         continue;
  314.                     }
  315.                     $oldSituationRisksIds = $isNewSituation ? [] : $situationRisqueRepository->getSituationRisqueBySituation($situation);
  317.                     $toRemove = $isNewSituation ? [] : array_diff($oldSituationRisksIds, $newSituationRiskIds);
  319.                     $toAdd = $isNewSituation ? $newSituationRiskIds : array_diff($newSituationRiskIds, $oldSituationRisksIds);
  321.                     
  322.                     
  323.                     if (!empty($toRemove)) {
  324.                         $situationRisqueRepository->removeByRisqueIds($situation, $toRemove);
  325.                     }
  326.                     foreach ($toAdd as $risqueId) {
  327.                         $risque = $risqueRepository->find($risqueId);
  328.                         if ($risque) {
  329.                             $situationRisk = new SituationRisque();
  330.                             $situationRisk->setSituation($situation);
  331.                             $situationRisk->setRisque($risque);
  332.                             $situation->addSituationRisque($situationRisk);
  333.                         }
  334.                     }
  335.                 }
  336.             }
  337.         }
  339.         $taskRepository->save($task);
  341.         return new JsonResponse(['success' => true, 'taskId' => $task->getId()]);
  342.     }
  344.     private function getCachedCriticiteData(): array
  345.     {
  346.         return $this->cache->get('criticite_list', function (ItemInterface $item) {
  347.             $item->expiresAfter(3600);
  348.             return $this->criticiteRepository->findBy([],['valeur'=>'asc']);
  349.         });
  350.     }
  352.     /**
  353.      * @Route("/criticite/{id}/edit", name="editCriticite", methods={"GET","POST"})
  354.      */
  355.     public function editCriticite(Request $request, SituationRisque $situationRisque, FrequenceRepository $frequenceRepository, GraviteRepository $graviteRepository): Response
  356.     {
  358.         if (isset($request->request)) {
  359.             $listF= $this->getCachedFrequenceData();
  360.             $listG= $this->getCachedGraviteData();
  361.             $frequenceId=$situationRisque->getFrequence() ? $situationRisque->getFrequence()->getId() : 0;
  362.             $graviteId=$situationRisque->getGravite() ? $situationRisque->getGravite()->getId() : 0;
  363.             $commentaire=$situationRisque->getCommentCR();
  364.             return $this->render('evrp/identification_sst/_formCR.html.twig', [
  365.                 'frequenceId' => $frequenceId,
  366.                 'graviteId' => $graviteId,
  367.                 'commentaire'=> $commentaire,
  368.                 'id'=>$situationRisque->getId(),
  369.                 'frequences'=>$listF,
  370.                 'gravites'=>$listG,
  371.                 'type'=>'SSTmetier',
  372.             ]);
  373.         }
  374.         return new JsonResponse(array('status' => 'error','message' => 'Access forbidden!'), 400);
  375.     }
  376.     /**
  377.      * @Route("/prevention/{id}/edit", name="editPrevention", methods={"GET","POST"})
  378.      */
  379.     public function editPrevention(Request $request, SituationRisque $situationRisque): Response
  380.     {
  382.         if (isset($request->request)) {
  384.             $listMOG= $this->getCachedMOGData();
  385.             $mogId =0;
  386.             if ($situationRisque->getMOG())
  387.                 $mogId=$situationRisque->getMOG()->getId();
  388.             $commentaire=$situationRisque->getCommentRR();
  389.             $idSR=$situationRisque->getId();
  390.             return $this->render('evrp/identification_sst/_formRR.html.twig', [
  391.                 'mogId' => $mogId,
  392.                 'commentaire'=> $commentaire,
  393.                 'id'=>$idSR,
  394.                 'mogs'=>$listMOG,
  395.                 'type'=>'SSTmetier',
  396.             ]);
  397.         }
  398.         return new JsonResponse(array('status' => 'error','message' => 'Access forbidden!'), 400);
  399.     }
  401.     private function getCachedFrequenceData(): array
  402.     {
  403.         return $this->cache->get('frequence_list', function (ItemInterface $item) {
  404.             $item->expiresAfter(3600);
  405.             return $this->frequenceRepository->findAll();
  406.         });
  407.     }
  409.     private function getCachedGraviteData(): array
  410.     {
  411.         return $this->cache->get('gravite_list', function (ItemInterface $item) {
  412.             $item->expiresAfter(3600);
  413.             return $this->graviteRepository->findAll();
  414.         });
  415.     }
  416.     private function getCachedMOGData(): array
  417.     {
  418.         return $this->cache->get('MOG_list', function (ItemInterface $item) {
  419.             $item->expiresAfter(3600);
  420.             return $this->mogRepository->findAll();
  421.         });
  422.     }
  424. }