test export annelis emails

Author: folland87

src/jobs/index.js

@@ -23,6 +23,7 @@ import {
 	exportFrEsrPrizes,
 	exportFrEsrStructureIdentifiers,
 	exportFrEsrStructureWebsites,
+	exportFrEsrAnnelisPaysageMails,
 } from "./opendata";
 import { sendMattermostNotification } from "./send-mattermost-notification";
 import { monitorSiren, monitorSiret } from "./sirene";
@@ -113,6 +114,11 @@ agenda.define(
 	{ shouldSaveResult: true },
 	exportFrEsrAnnelisPaysageEtablissements,
 );
+agenda.define(
+	"export fr-esr-annelis-paysage-email-generiques",
+	{ shouldSaveResult: true },
+	exportFrEsrAnnelisPaysageMails,
+);
 agenda.define(
 	"export fr-esr-paysage_structures_websites",
 	{ shouldSaveResult: true },

src/jobs/opendata/fr-esr-annelis-paysage-email-generiques.js

@@ -0,0 +1,32 @@
+import { client, db } from '../../services/mongo.service';
+
+const dataset = 'fr-esr-annelis-paysage-email-generiques';
+
+export default async function exportFrEsrAnnelisPaysageMails() {
+
+  const emails = await db.collection('emailtypes').find({ $and: [{ annelisId: { $ne: null } }, { annelisId: { $ne: "" } }] }).toArray();
+  const emailMap = new Map(emails.map(email => [email.id, email]));
+
+  const data = await db.collection('emails').aggregate([
+    { $match: { emailTypeId: { $in: emails.map(email => email.id) } } },
+  ]).toArray();
+
+  const json = data.map((elem) => {
+    const row = {
+      dataset,
+      eta_id_paysage: elem.resourceId,
+      annelis_email_type_id: emailMap.get(elem.emailTypeId)?.annelisId || '',
+      annelis_email_type: emailMap.get(elem.emailTypeId)?.usualName || '',
+      annelis_email: elem.email
+    };
+    return row;
+  });
+  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

@@ -5,3 +5,4 @@ export { default as exportFrEsrPersonIdentifiers } from './fr-esr-paysage_person
 export { default as exportFrEsrStructureWebsites } from './fr-esr-paysage_structures_websites';
 export { default as exportFrEsrPrizes } from './fr-esr-paysage_prix';
 export { default as exportFrEsrPaysageLaureatAll } from './fr_esr_paysage_laureats_all';
+export { default as exportFrEsrAnnelisPaysageMails } from './fr-esr-annelis-paysage-email-generiques';