feat: nettoyage des anciennes formation à l'importation (#28)

mission-apprentissage · Jan 8, 2025 · 8745ce4 · 8745ce4
1 parent bc0e50a
commit 8745ce4
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 1 deletion.
diff --git a/server/src/cli.ts b/server/src/cli.ts
@@ -10,7 +10,10 @@ import { importACCEEtablissements } from "./jobs/etablissements/importACCEEtabli
 import { importEtablissements } from "./jobs/etablissements/importEtablissements";
 import { importFormation } from "./jobs/formations/importFormation";
 import { importFormations as importCAFormations } from "./jobs/catalogueApprentissage/importFormations";
-import { importFormationEtablissement } from "./jobs/formations/importFormationEtablissement";
+import {
+  importFormationEtablissement,
+  cleanFormationEtablissement,
+} from "./jobs/formations/importFormationEtablissement";
 import { importOnisep } from "./jobs/onisep/importOnisep";
 import { importIndicateurEntree } from "./jobs/formations/importIndicateurEntree";
 import { computeFormationTag } from "./jobs/formations/tag/computeFormationTag";
@@ -60,6 +63,7 @@ const formationEtablissementJobs = [
   { name: "feIdeoFichesFormations", job: importIdeoFichesFormations },
   { name: "feFichesFormationsTmp", job: importFichesFormationsTmp },
   { name: "feRCO", job: importRCO },
+  { name: "feFEClean", job: cleanFormationEtablissement },
   { name: "feFE", job: importFormationEtablissement },
   { name: "feFamillesMetiers", job: importFamillesMetiers },
   { name: "feIndicateurEntree", job: importIndicateurEntree },

diff --git a/server/src/jobs/formations/importFormationEtablissement.ts b/server/src/jobs/formations/importFormationEtablissement.ts
@@ -7,6 +7,9 @@ import { streamOnisepFormations } from "./streamOnisepFormations";
 import { kdb, upsert } from "#src/common/db/db";
 import EtablissementRepository from "#src/common/repositories/etablissement";
 import RawDataRepository, { RawDataType } from "#src/common/repositories/rawData";
+import FormationEtablissementRepository from "#src/common/repositories/formationEtablissement";
+import IndicateurEntreeRepository from "#src/common/repositories/indicateurEntree";
+import IndicateurPoursuiteRepository from "#src/common/repositories/indicateurPoursuite";
 
 const logger = getLoggerWithContext("import");
 
@@ -111,3 +114,14 @@ export async function importFormationEtablissement() {
 
   return stats;
 }
+
+export async function cleanFormationEtablissement() {
+  logger.info(`Suppression du catalogue de formations précédent`);
+
+  await IndicateurEntreeRepository.remove({});
+  await IndicateurPoursuiteRepository.remove({});
+  const resultFormationEtablissement = await FormationEtablissementRepository.remove({});
+
+  logger.info(`${resultFormationEtablissement.length} formations supprimées`);
+  return { deleted: resultFormationEtablissement.length };
+}