fix: mise à jour des regles pour les indicateurs ij pour le continuum

server/src/commands.product.ts

@@ -383,6 +383,7 @@ export function productCommands(cli: Command) {
       await anonymizeUsers();
       await createJob({ name: "anonymizeUsers" });
     });
+
   cli.command("refreshViews").action(async () => {
     await refreshViews();
   });

server/src/modules/data/usecases/getDomaineDeFormation/dependencies/getFormations.dep.ts

@@ -42,8 +42,13 @@ export const getFormations = async ({
       wb
         .selectFrom("formations")
         .leftJoin("formationHistorique", "formationHistorique.cfd", "formations.cfd")
-        .where("formations.dateOuverture", "<=", sql<Date>`${getDateRentreeScolaire(CURRENT_RENTREE)}`)
-        .where("formationHistorique.ancienCFD", "in", (eb) => eb.selectFrom("formationEtablissement").select("cfd"))
+        .leftJoin("formationView as fva", "fva.cfd", "formationHistorique.ancienCFD")
+        .where(wb => wb.and([
+          wb("formations.dateOuverture", "<=", sql<Date>`${getDateRentreeScolaire(CURRENT_RENTREE)}`),
+          wb("fva.dateFermeture", "is not", null),
+          wb("fva.dateFermeture", ">", sql<Date>`${getDateRentreeScolaire(CURRENT_RENTREE)}`),
+          wb("formationHistorique.ancienCFD", "in", (eb) => eb.selectFrom("formationEtablissement").select("cfd"))
+        ]))
         .select("formationHistorique.cfd")
         .distinct()
     )

server/src/modules/data/usecases/getFormation/dependencies/getFormation.dep.ts

@@ -77,9 +77,14 @@ export const getFormation = async ({
     getKbdClient()
       .selectFrom("formationHistorique")
       .leftJoin("formationView", "formationHistorique.cfd", "formationView.cfd")
-      .where("formationHistorique.cfd", "=", cfd)
-      .where("formationView.dateOuverture", "<=", sql<Date>`${getDateRentreeScolaire(CURRENT_RENTREE)}`)
-      .where("formationHistorique.ancienCFD", "in", (eb) => eb.selectFrom("formationEtablissement").select("cfd"))
+      .leftJoin("formationView as fva", "fva.cfd", "formationHistorique.ancienCFD")
+      .where(wb => wb.and([
+        wb("formationHistorique.cfd", '=', cfd),
+        wb("formationHistorique.ancienCFD", "in",(eb) => eb.selectFrom("formationEtablissement").select("cfd")),
+        wb("formationView.dateOuverture", "<=", sql<Date>`${getDateRentreeScolaire(CURRENT_RENTREE)}` ),
+        wb("fva.dateFermeture", "is not", null),
+        wb("fva.dateFermeture", ">", sql<Date>`${getDateRentreeScolaire(CURRENT_RENTREE)}`),
+      ]))
       .select("formationView.cfd")
       .distinct();
 

server/src/modules/data/usecases/getFormationEtablissements/deps/getFormationEtablissementsQuery.dep.ts

@@ -3,6 +3,7 @@ import { jsonBuildObject } from "kysely/helpers/postgres";
 import { CURRENT_IJ_MILLESIME, CURRENT_RENTREE } from "shared";
 import { TypeFormationSpecifiqueEnum } from "shared/enum/formationSpecifiqueEnum";
 import { PositionQuadrantEnum } from "shared/enum/positionQuadrantEnum";
+import { getDateRentreeScolaire } from "shared/utils/getRentreeScolaire";
 import { MAX_LIMIT } from "shared/utils/maxLimit";
 
 import { getKbdClient } from "@/db/db";
@@ -160,9 +161,13 @@ export const getFormationEtablissementsQuery = async ({
         .as("continuumEtablissement"),
       eb
         .selectFrom("formationHistorique")
-        .select("formationHistorique.cfd")
-        .whereRef("formationHistorique.cfd", "=", "formationView.cfd")
-        .where("formationHistorique.ancienCFD", "in", (eb) => eb.selectFrom("formationEtablissement").select("cfd"))
+        .innerJoin("formationView as fva", "fva.cfd", "formationHistorique.ancienCFD")
+        .select("formationHistorique.ancienCFD")
+        .where(wb => wb.and([
+          wb(wb.ref("formationHistorique.cfd"), "=", wb.ref("formationView.cfd")),
+          wb("fva.dateFermeture", "is not", null),
+          wb("fva.dateFermeture", ">", sql<Date>`${getDateRentreeScolaire(rentreeScolaire[0])}`)
+        ]))
         .limit(1)
         .as("isFormationRenovee"),
       isFormationActionPrioritaire({

server/src/modules/data/usecases/getFormations/deps/getFormationsQuery.dep.ts

@@ -2,6 +2,7 @@ import { sql } from "kysely";
 import { CURRENT_IJ_MILLESIME, CURRENT_RENTREE } from "shared";
 import { TypeFormationSpecifiqueEnum } from "shared/enum/formationSpecifiqueEnum";
 import { PositionQuadrantEnum } from "shared/enum/positionQuadrantEnum";
+import { getDateRentreeScolaire } from "shared/utils/getRentreeScolaire";
 import { MAX_LIMIT } from "shared/utils/maxLimit";
 
 import { getKbdClient } from "@/db/db";
@@ -201,9 +202,13 @@ export const getFormationsQuery = async ({
       "formationHistorique.cfd as formationRenovee",
       eb
         .selectFrom("formationHistorique")
-        .select("formationHistorique.cfd")
-        .whereRef("formationHistorique.cfd", "=", "formationView.cfd")
-        .where("formationHistorique.ancienCFD", "in", (eb) => eb.selectFrom("formationEtablissement").select("cfd"))
+        .innerJoin("formationView as fva", "fva.cfd", "formationHistorique.ancienCFD")
+        .select("formationHistorique.ancienCFD")
+        .where(wb => wb.and([
+          wb(wb.ref("formationHistorique.cfd"), "=", wb.ref("formationView.cfd")),
+          wb("fva.dateFermeture", "is not", null),
+          wb("fva.dateFermeture", ">", sql<Date>`${getDateRentreeScolaire(rentreeScolaire[0])}`)
+        ]))
         .limit(1)
         .as("isFormationRenovee"),
       sql<string | null>`

server/src/modules/import/usecases/importFormationEtablissement/steps/importIndicateursSortieRegionaux/importIndicateursSortieRegionaux.step.ts

@@ -5,6 +5,7 @@ import { MILLESIMES_IJ_REG } from "shared";
 import { regionAcademiqueMapping } from "@/modules/import/domain/regionAcademiqueMapping";
 import { rawDataRepository } from "@/modules/import/repositories/rawData.repository";
 import { inserJeunesApi } from "@/modules/import/services/inserJeunesApi/inserJeunes.api";
+import { getCfdDispositifs } from "@/modules/import/usecases/getCfdRentrees/getCfdDispositifs.dep";
 
 import { createIndicateurRegionSortie } from "./createIndicateurRegionSortie.dep";
 import { findAnciennesFormation } from "./findAnciennesFormation.dep";
@@ -39,6 +40,7 @@ export const [importIndicateursRegionSortie] = inject(
             if (!continuumData) continue;
             await deps.createIndicateurRegionSortie({
               ...continuumData,
+              codeDispositif,
               cfd,
               cfdContinuum: continuumData.cfd,
             });
@@ -113,11 +115,17 @@ export const [importIndicateursRegionSortieApprentissage] = inject(
     }
 );
 
+// Règle dans le cas du continuum MC vers CS qui ont des codes dispositifs différents
+const isMCToCS = (cfd: string, cfdContinuum: string) => {
+  return ["461", "561"].includes(cfd.substring(0,3)) && cfdContinuum.substring(0,3) === "010";
+};
+
 const [getContinuumData] = inject(
   {
     findIndicateurRegionSortie,
     findAnciennesFormation,
     findNouvellesFormation,
+    getCfdDispositifs
   },
   (deps) =>
     async ({
@@ -138,19 +146,30 @@ const [getContinuumData] = inject(
         voie,
       });
       if (ancienneFormation.length !== 1) return;
+
       const cfdContinuum = ancienneFormation[0].ancienCFD;
+
       const nouvellesFormation = await deps.findNouvellesFormation({
         cfd: cfdContinuum,
         voie,
       });
       if (nouvellesFormation.length !== 1) return;
 
-      return await deps.findIndicateurRegionSortie({
-        cfd: cfdContinuum,
-        codeDispositif: codeDispositif,
-        codeRegion,
-        millesimeSortie,
-        voie,
+      const baseParams = { codeRegion, millesimeSortie, voie, cfd: cfdContinuum };
+
+      if (isMCToCS(cfd, cfdContinuum)) {
+        const dispositifs = await deps.getCfdDispositifs({ cfd: cfdContinuum });
+        if (dispositifs.length !== 1) return;
+
+        return deps.findIndicateurRegionSortie({
+          ...baseParams,
+          codeDispositif: dispositifs[0].codeDispositif,
+        });
+      }
+
+      return deps.findIndicateurRegionSortie({
+        ...baseParams,
+        codeDispositif,
       });
     }
 );