diff --git a/server/src/commands.ts b/server/src/commands.ts index 8be3108b9..5493a7dc4 100644 --- a/server/src/commands.ts +++ b/server/src/commands.ts @@ -377,6 +377,12 @@ program .option("-q, --queued", "Run job asynchronously", false) .action(createJobAction("tmp:effectifs:update_computed_statut")); +program + .command("hydrate:effectifs:update_computed_statut") + .description("Remplissage du champ effectifs._computed avec les types des effectifs") + .option("-q, --queued", "Run job asynchronously", false) + .action(createJobAction("hydrate:effectifs:update_computed_statut")); + program .command("hydrate:effectifs-formation-niveaux") .description("Remplissage du champ niveau des formations des effectifs") diff --git a/server/src/common/actions/effectifs.statut.actions.ts b/server/src/common/actions/effectifs.statut.actions.ts index 97db3b72c..f3fa12805 100644 --- a/server/src/common/actions/effectifs.statut.actions.ts +++ b/server/src/common/actions/effectifs.statut.actions.ts @@ -240,13 +240,10 @@ function determineNewStatutFromHistorique( ]; sortedHistoriqueStatut.forEach((statut) => { - const statutYear = new Date(statut.date_statut).getFullYear(); - if (statutYear >= startYear && statutYear <= endYear) { - parcours.push({ - valeur: mapValeurStatutToStatutApprenant(statut.valeur_statut), - date: new Date(statut.date_statut), - }); - } + parcours.push({ + valeur: mapValeurStatutToStatutApprenant(statut.valeur_statut), + date: new Date(statut.date_statut), + }); }); return parcours; diff --git a/server/src/jobs/jobs.ts b/server/src/jobs/jobs.ts index a1e6e5aba..93c0a549a 100644 --- a/server/src/jobs/jobs.ts +++ b/server/src/jobs/jobs.ts @@ -139,7 +139,7 @@ export async function setupJobProcessor() { "Mettre à jour les statuts d'effectifs le 1er de chaque mois à 00h45": { cron_string: "45 0 1 * *", handler: async () => { - await addJob({ name: "hydrate:effectifs:update_computed_statut", queued: true }); + await addJob({ name: "hydrate:effectifs:update_computed_statut_month", queued: true }); return 0; }, }, @@ -212,6 +212,11 @@ export async function setupJobProcessor() { return hydrateEffectifsComputedTypes(); }, }, + "hydrate:effectifs:update_computed_statut": { + handler: async () => { + return await addJob({ name: "tmp:effectifs:update_computed_statut", queued: true }); + }, + }, "hydrate:effectifs-formation-niveaux": { handler: async () => { return hydrateEffectifsFormationsNiveaux(); @@ -262,7 +267,7 @@ export async function setupJobProcessor() { return hydrateDeca(job.payload as any); }, }, - "hydrate:effectifs:update_computed_statut": { + "hydrate:effectifs:update_computed_statut_month": { handler: async () => { return hydrateEffectifsComputedTypes({ query: { annee_scolaire: { $in: getAnneesScolaireListFromDate(new Date()) } },