Merge pull request #64 from anct-cnum/Fix_requete_details_cra

Fix de la requete avec codeDepartement et ajout de la date d'update
anct-cnum · Aug 4, 2023 · 953d2c6 · 953d2c6
2 parents e99f311 + 903c26d
commit 953d2c6
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/src/tasks/stats/cras/crasByDepartements/index.js b/src/tasks/stats/cras/crasByDepartements/index.js
@@ -31,6 +31,7 @@ const findAndInsertStats = async (dbDatalake, query, departement) => {
     'repartition_statuts': statutsParDepartement,
     'repartition_thematiques': themesParDepartement.themes,
     'repartition_sous_thematiques': themesParDepartement.sousThemes,
+    'updatedAt': new Date(),
   };
 
   await statsAlltasks.insertStatsOutilPrefet(dbDatalake)(statsOutilPrefet);
@@ -58,6 +59,7 @@ execute(__filename, async ({ logger, dbDatalake }) => {
           //Lorsque les codeCommune seront importer => 'cra.codeCommune': { $regex: new RegExp(regex) },
           'cra.codePostal': { $regex: new RegExp(regex) }
         };
+
         await findAndInsertStats(dbDatalake, query, departement);
         resolve();
       }));

diff --git a/src/tasks/stats/cras/crasByDepartements/tasks/insertStatsOutilPrefet.js b/src/tasks/stats/cras/crasByDepartements/tasks/insertStatsOutilPrefet.js
@@ -1,6 +1,6 @@
 const insertStatsOutilPrefet = dbDatalake => async statsOutilPrefet =>
   await dbDatalake.collection('stats_departements_cras_details').replaceOne(
-    { num_dep: statsOutilPrefet.num_dep },
+    { codeDepartement: statsOutilPrefet.num_dep },
     statsOutilPrefet,
     { upsert: true }
   );