fix: filtres formations spécifique OU et pas ET

mission-apprentissage · Dec 9, 2024 · d6a2429 · d6a2429
1 parent eb09ddb
commit d6a2429
Show file tree

Hide file tree

Showing 7 changed files with 157 additions and 123 deletions.
diff --git a/server/src/modules/corrections/usecases/getCorrections/deps/getCorrections.dep.ts b/server/src/modules/corrections/usecases/getCorrections/deps/getCorrections.dep.ts
@@ -83,6 +83,12 @@ export const getCorrectionsQuery = async ({
         ])
       )
     )
+    .leftJoin("actionPrioritaire", (join) =>
+      join
+        .onRef("actionPrioritaire.cfd", "=", "demande.cfd")
+        .onRef("actionPrioritaire.codeDispositif", "=", "demande.codeDispositif")
+        .onRef("actionPrioritaire.codeRegion", "=", "demande.codeRegion")
+    )
     .select((eb) => [
       eb.fn.count<number>("correction.id").over().as("count"),
       "demande.uai",
@@ -271,23 +277,22 @@ export const getCorrectionsQuery = async ({
     })
     .$call((q) => {
       if (formationSpecifique?.length) {
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Action prioritaire"])) {
-          return q.innerJoin("actionPrioritaire", (join) =>
-            join
-              .onRef("actionPrioritaire.cfd", "=", "demande.cfd")
-              .onRef("actionPrioritaire.codeDispositif", "=", "demande.codeDispositif")
-              .onRef("actionPrioritaire.codeRegion", "=", "demande.codeRegion")
-          );
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition écologique"])) {
-          q = q.where("formationView.isTransitionEcologique", "=", true);
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition démographique"])) {
-          q = q.where("formationView.isTransitionDemographique", "=", true);
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition numérique"])) {
-          q = q.where("formationView.isTransitionNumerique", "=", true);
-        }
+        return q.where((w) =>
+          w.or([
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Action prioritaire"])
+              ? w("actionPrioritaire.cfd", "is not", null)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition écologique"])
+              ? w("formationView.isTransitionEcologique", "=", true)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition démographique"])
+              ? w("formationView.isTransitionDemographique", "=", true)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition numérique"])
+              ? w("formationView.isTransitionNumerique", "=", true)
+              : sql.val(false),
+          ])
+        );
       }
       return q;
     })

diff --git a/server/src/modules/corrections/usecases/getCorrections/deps/getStatsCorrections.dep.ts b/server/src/modules/corrections/usecases/getCorrections/deps/getStatsCorrections.dep.ts
@@ -47,6 +47,12 @@ export const getStatsCorrectionsQuery = async ({
     .leftJoin("user", "user.id", "demande.createdBy")
     .leftJoin("niveauDiplome", "niveauDiplome.codeNiveauDiplome", "formationView.codeNiveauDiplome")
     .leftJoin("nsf", "nsf.codeNsf", "formationView.codeNsf")
+    .leftJoin("actionPrioritaire", (join) =>
+      join
+        .onRef("actionPrioritaire.cfd", "=", "demande.cfd")
+        .onRef("actionPrioritaire.codeDispositif", "=", "demande.codeDispositif")
+        .onRef("actionPrioritaire.codeRegion", "=", "demande.codeRegion")
+    )
     .select((eb) => [
       eb.fn.count<number>("correction.id").as("nbCorrections"),
       eb.fn
@@ -210,23 +216,22 @@ export const getStatsCorrectionsQuery = async ({
     })
     .$call((q) => {
       if (formationSpecifique?.length) {
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Action prioritaire"])) {
-          return q.innerJoin("actionPrioritaire", (join) =>
-            join
-              .onRef("actionPrioritaire.cfd", "=", "demande.cfd")
-              .onRef("actionPrioritaire.codeDispositif", "=", "demande.codeDispositif")
-              .onRef("actionPrioritaire.codeRegion", "=", "demande.codeRegion")
-          );
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition écologique"])) {
-          q = q.where("formationView.isTransitionEcologique", "=", true);
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition démographique"])) {
-          q = q.where("formationView.isTransitionDemographique", "=", true);
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition numérique"])) {
-          q = q.where("formationView.isTransitionNumerique", "=", true);
-        }
+        return q.where((w) =>
+          w.or([
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Action prioritaire"])
+              ? w("actionPrioritaire.cfd", "is not", null)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition écologique"])
+              ? w("formationView.isTransitionEcologique", "=", true)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition démographique"])
+              ? w("formationView.isTransitionDemographique", "=", true)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition numérique"])
+              ? w("formationView.isTransitionNumerique", "=", true)
+              : sql.val(false),
+          ])
+        );
       }
       return q;
     })

diff --git a/.../usecases/getDemandesRestitutionIntentions/deps/getDemandesRestitutionIntentions.query.ts b/.../usecases/getDemandesRestitutionIntentions/deps/getDemandesRestitutionIntentions.query.ts
@@ -87,6 +87,12 @@ export const getDemandesRestitutionIntentionsQuery = async ({
         ])
       )
     )
+    .leftJoin("actionPrioritaire", (join) =>
+      join
+        .onRef("actionPrioritaire.cfd", "=", "demande.cfd")
+        .onRef("actionPrioritaire.codeDispositif", "=", "demande.codeDispositif")
+        .onRef("actionPrioritaire.codeRegion", "=", "demande.codeRegion")
+    )
     .selectAll("demande")
     .select((eb) => [
       "dataFormation.libelleFormation",
@@ -242,23 +248,22 @@ export const getDemandesRestitutionIntentionsQuery = async ({
     })
     .$call((q) => {
       if (formationSpecifique?.length) {
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Action prioritaire"])) {
-          q = q.innerJoin("actionPrioritaire", (join) =>
-            join
-              .onRef("actionPrioritaire.cfd", "=", "demande.cfd")
-              .onRef("actionPrioritaire.codeDispositif", "=", "demande.codeDispositif")
-              .onRef("actionPrioritaire.codeRegion", "=", "demande.codeRegion")
-          );
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition écologique"])) {
-          q = q.where("formationView.isTransitionEcologique", "=", true);
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition démographique"])) {
-          q = q.where("formationView.isTransitionDemographique", "=", true);
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition numérique"])) {
-          q = q.where("formationView.isTransitionNumerique", "=", true);
-        }
+        return q.where((w) =>
+          w.or([
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Action prioritaire"])
+              ? w("actionPrioritaire.cfd", "is not", null)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition écologique"])
+              ? w("formationView.isTransitionEcologique", "=", true)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition démographique"])
+              ? w("formationView.isTransitionDemographique", "=", true)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition numérique"])
+              ? w("formationView.isTransitionNumerique", "=", true)
+              : sql.val(false),
+          ])
+        );
       }
       return q;
     })

diff --git a/...ules/data/usecases/getFormationEtablissements/deps/getFormationEtablissementsQuery.dep.ts b/...ules/data/usecases/getFormationEtablissements/deps/getFormationEtablissementsQuery.dep.ts
@@ -98,6 +98,12 @@ export const getFormationEtablissementsQuery = async ({
         ])
       )
     )
+    .leftJoin("actionPrioritaire", (join) =>
+      join
+        .onRef("actionPrioritaire.cfd", "=", "formationEtablissement.cfd")
+        .onRef("actionPrioritaire.codeDispositif", "=", "formationEtablissement.codeDispositif")
+        .onRef("actionPrioritaire.codeRegion", "=", "etablissement.codeRegion")
+    )
     .select((eb) => [
       sql<number>`COUNT(*) OVER()`.as("count"),
       "etablissement.libelleEtablissement",
@@ -324,23 +330,22 @@ export const getFormationEtablissementsQuery = async ({
     })
     .$call((q) => {
       if (formationSpecifique?.length) {
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Action prioritaire"])) {
-          q = q.innerJoin("actionPrioritaire", (join) =>
-            join
-              .onRef("actionPrioritaire.cfd", "=", "formationEtablissement.cfd")
-              .onRef("actionPrioritaire.codeDispositif", "=", "formationEtablissement.codeDispositif")
-              .onRef("actionPrioritaire.codeRegion", "=", "etablissement.codeRegion")
-          );
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition écologique"])) {
-          q = q.where("formationView.isTransitionEcologique", "=", true);
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition démographique"])) {
-          q = q.where("formationView.isTransitionDemographique", "=", true);
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition numérique"])) {
-          q = q.where("formationView.isTransitionNumerique", "=", true);
-        }
+        return q.where((w) =>
+          w.or([
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Action prioritaire"])
+              ? w("actionPrioritaire.cfd", "is not", null)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition écologique"])
+              ? w("formationView.isTransitionEcologique", "=", true)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition démographique"])
+              ? w("formationView.isTransitionDemographique", "=", true)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition numérique"])
+              ? w("formationView.isTransitionNumerique", "=", true)
+              : sql.val(false),
+          ])
+        );
       }
       return q;
     })

diff --git a/server/src/modules/data/usecases/getFormations/deps/getFormationsQuery.dep.ts b/server/src/modules/data/usecases/getFormations/deps/getFormationsQuery.dep.ts
@@ -72,6 +72,14 @@ export const getFormationsQuery = async ({
       join.onRef("formationHistorique.ancienCFD", "=", "formationView.cfd").on(isScolaireFormationHistorique)
     )
     .leftJoin("nsf", "nsf.codeNsf", "formationView.codeNsf")
+    .leftJoin("actionPrioritaire", (join) =>
+      join
+        .onRef("actionPrioritaire.cfd", "=", "formationEtablissement.cfd")
+        .onRef("actionPrioritaire.codeDispositif", "=", "formationEtablissement.codeDispositif")
+        .$call((join) =>
+          codeRegion ? join.onRef("actionPrioritaire.codeRegion", "=", "etablissement.codeRegion") : join
+        )
+    )
     .$call((eb) => {
       if (!codeRegion) return eb;
       return eb
@@ -329,25 +337,22 @@ export const getFormationsQuery = async ({
     })
     .$call((q) => {
       if (formationSpecifique?.length) {
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Action prioritaire"])) {
-          q = q.innerJoin("actionPrioritaire", (join) =>
-            join
-              .onRef("actionPrioritaire.cfd", "=", "formationEtablissement.cfd")
-              .onRef("actionPrioritaire.codeDispositif", "=", "formationEtablissement.codeDispositif")
-              .$call((join) =>
-                codeRegion ? join.onRef("actionPrioritaire.codeRegion", "=", "etablissement.codeRegion") : join
-              )
-          );
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition écologique"])) {
-          q = q.where("formationView.isTransitionEcologique", "=", true);
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition démographique"])) {
-          q = q.where("formationView.isTransitionDemographique", "=", true);
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition numérique"])) {
-          q = q.where("formationView.isTransitionNumerique", "=", true);
-        }
+        return q.where((w) =>
+          w.or([
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Action prioritaire"])
+              ? w("actionPrioritaire.cfd", "is not", null)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition écologique"])
+              ? w("formationView.isTransitionEcologique", "=", true)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition démographique"])
+              ? w("formationView.isTransitionDemographique", "=", true)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition numérique"])
+              ? w("formationView.isTransitionNumerique", "=", true)
+              : sql.val(false),
+          ])
+        );
       }
       return q;
     })

diff --git a/server/src/modules/data/usecases/getStatsRestitutionIntentions/dependencies.ts b/server/src/modules/data/usecases/getStatsRestitutionIntentions/dependencies.ts
@@ -87,6 +87,12 @@ const getStatsRestitutionIntentionsQuery = async ({
         ])
       )
     )
+    .leftJoin("actionPrioritaire", (join) =>
+      join
+        .onRef("actionPrioritaire.cfd", "=", "demande.cfd")
+        .onRef("actionPrioritaire.codeDispositif", "=", "demande.codeDispositif")
+        .onRef("actionPrioritaire.codeRegion", "=", "demande.codeRegion")
+    )
     .select((eb) =>
       jsonBuildObject({
         total: eb.fn.coalesce(eb.fn.sum<number>(countPlacesNonColoreesTransformees(eb)), eb.val(0)),
@@ -319,23 +325,22 @@ const getStatsRestitutionIntentionsQuery = async ({
     })
     .$call((q) => {
       if (formationSpecifique?.length) {
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Action prioritaire"])) {
-          q = q.innerJoin("actionPrioritaire", (join) =>
-            join
-              .onRef("actionPrioritaire.cfd", "=", "demande.cfd")
-              .onRef("actionPrioritaire.codeDispositif", "=", "demande.codeDispositif")
-              .onRef("actionPrioritaire.codeRegion", "=", "demande.codeRegion")
-          );
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition écologique"])) {
-          q = q.where("formationView.isTransitionEcologique", "=", true);
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition démographique"])) {
-          q = q.where("formationView.isTransitionDemographique", "=", true);
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition numérique"])) {
-          q = q.where("formationView.isTransitionNumerique", "=", true);
-        }
+        return q.where((w) =>
+          w.or([
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Action prioritaire"])
+              ? w("actionPrioritaire.cfd", "is not", null)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition écologique"])
+              ? w("formationView.isTransitionEcologique", "=", true)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition démographique"])
+              ? w("formationView.isTransitionDemographique", "=", true)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition numérique"])
+              ? w("formationView.isTransitionNumerique", "=", true)
+              : sql.val(false),
+          ])
+        );
       }
       return q;
     })

diff --git a/server/src/modules/data/utils/onDemande.ts b/server/src/modules/data/utils/onDemande.ts
@@ -1,4 +1,4 @@
-import { expressionBuilder } from "kysely";
+import { expressionBuilder, sql } from "kysely";
 import { VoieEnum } from "shared";
 import type { DemandeStatutType } from "shared/enum/demandeStatutEnum";
 import { DemandeTypeEnum } from "shared/enum/demandeTypeEnum";
@@ -74,7 +74,12 @@ export const genericOnDemandes = ({
     .leftJoin("formationView", (join) =>
       join.onRef("formationView.cfd", "=", "demande.cfd").on("formationView.voie", "=", VoieEnum.scolaire)
     )
-
+    .leftJoin("actionPrioritaire", (join) =>
+      join
+        .onRef("actionPrioritaire.cfd", "=", "demande.cfd")
+        .onRef("actionPrioritaire.codeDispositif", "=", "demande.codeDispositif")
+        .onRef("actionPrioritaire.codeRegion", "=", "demande.codeRegion")
+    )
     .leftJoin("positionFormationRegionaleQuadrant", (join) =>
       join.on((eb) =>
         eb.and([
@@ -170,23 +175,22 @@ export const genericOnDemandes = ({
     })
     .$call((q) => {
       if (formationSpecifique?.length) {
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Action prioritaire"])) {
-          q = q.innerJoin("actionPrioritaire", (join) =>
-            join
-              .onRef("actionPrioritaire.cfd", "=", "demande.cfd")
-              .onRef("actionPrioritaire.codeDispositif", "=", "demande.codeDispositif")
-              .onRef("actionPrioritaire.codeRegion", "=", "demande.codeRegion")
-          );
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition écologique"])) {
-          q = q.where("formationView.isTransitionEcologique", "=", true);
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition démographique"])) {
-          q = q.where("formationView.isTransitionDemographique", "=", true);
-        }
-        if (formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition numérique"])) {
-          q = q.where("formationView.isTransitionNumerique", "=", true);
-        }
+        return q.where((w) =>
+          w.or([
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Action prioritaire"])
+              ? w("actionPrioritaire.cfd", "is not", null)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition écologique"])
+              ? w("formationView.isTransitionEcologique", "=", true)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition démographique"])
+              ? w("formationView.isTransitionDemographique", "=", true)
+              : sql.val(false),
+            formationSpecifique.includes(TypeFormationSpecifiqueEnum["Transition numérique"])
+              ? w("formationView.isTransitionNumerique", "=", true)
+              : sql.val(false),
+          ])
+        );
       }
       return q;
     });