feat(jobs): add prizes jobs to creat dataset

src/api/opendata/opendata.routes.js

@@ -13,6 +13,8 @@ const FILTERS = {
   'fr-esr-paysage_structures_identifiants': { dataset: 'fr-esr-paysage_structures_identifiants' },
   'fr-esr-paysage_personnes_identifiants': { dataset: 'fr-esr-paysage_personnes_identifiants' },
   'fr-esr-paysage_structures_websites': { dataset: 'fr-esr-paysage_structures_websites' },
+  'fr-esr-paysage_prix': { dataset: 'fr-esr-paysage_prix' },
+
 };
 
 router.route('/opendata/:datasetId')

src/jobs/index.js

@@ -18,6 +18,7 @@ import {
   exportFrEsrStructureIdentifiers,
   exportFrEsrPersonIdentifiers,
   exportFrEsrStructureWebsites,
+  exportFrEsrPrizes,
 } from './opendata';
 import synchronizeAnnuaireCollection from './synchronize/annuaire-collection';
 import synchronizeCuriexploreActors from './synchronize/curiexplore-actors';
@@ -38,6 +39,7 @@ agenda.define('send recovery email', { shouldSaveResult: true }, sendPasswordRec
 agenda.define('send contact email', { shouldSaveResult: true }, sendContactEmail);
 agenda.define('update key numbers', { shouldSaveResult: true }, updateKeyNumbers);
 agenda.define('reindex', { shouldSaveResult: true }, reindex);
+agenda.define('export fr-esr-paysage_prix', { shouldSaveResult: true }, exportFrEsrPrizes);
 agenda.define('export fr-esr-paysage_structures_identifiants', { shouldSaveResult: true }, exportFrEsrStructureIdentifiers);
 agenda.define('export fr-esr-paysage_personnes_identifiants', { shouldSaveResult: true }, exportFrEsrPersonIdentifiers);
 agenda.define('export fr-esr-paysage-fonctions-gourvernance', { shouldSaveResult: true }, exportFrEsrPaysageFonctionsGourvernance);

src/jobs/opendata/fr-esr-paysage_prix.js

@@ -0,0 +1,54 @@
+import { client, db } from '../../services/mongo.service';
+
+const dataset = 'fr-esr-paysage_prix';
+
+export default async function exportFrEsrPrizes() {
+  const json = await db.collection('prizes').aggregate([
+    {
+      $lookup: {
+        from: 'relationships',
+        let: { prizeId: '$id' },
+        pipeline: [
+          {
+            $match: {
+              $expr: {
+                $and: [
+                  { $eq: ['$resourceId', '$$prizeId'] },
+                  { $eq: ['$relationTag', 'prix-porteur'] },
+                ],
+              },
+            },
+          },
+        ],
+        as: 'relationshipData',
+      },
+    },
+    {
+      $project: {
+        dataset,
+        id_paysage: '$id',
+        nameFr: '$nameFr',
+        nameEn: '$nameEn',
+        descriptionFr: '$descriptionFr',
+        descriptionEn: '$descriptionEn',
+        relatedObjectId: {
+          $ifNull: [{ $arrayElemAt: ['$relationshipData.relatedObjectId', 0] }, null],
+        },
+      },
+    },
+    {
+      $match: {
+        id_paysage: { $exists: true },
+      },
+    },
+  ]).toArray();
+
+  const session = client.startSession();
+  await session.withTransaction(async () => {
+    await db.collection('opendata').deleteMany({ dataset });
+    await db.collection('opendata').insertMany(json);
+    await session.endSession();
+  });
+
+  return { status: 'success', location: `/opendata/${dataset}` };
+}

src/jobs/opendata/index.js

@@ -3,3 +3,4 @@ export { default as exportFrEsrAnnelisPaysageEtablissements } from './fr-esr-ann
 export { default as exportFrEsrStructureIdentifiers } from './fr-esr-paysage_structures_identifiants';
 export { default as exportFrEsrPersonIdentifiers } from './fr-esr-paysage_personnes_identifiants';
 export { default as exportFrEsrStructureWebsites } from './fr-esr-paysage_structures_websites';
+export { default as exportFrEsrPrizes } from './fr-esr-paysage_prix';