feat: maj import declare

Signed-off-by: Maud Royer <[email protected]>
AgenceBio · Jul 12, 2024 · 9a01e59 · 9a01e59
1 parent c1a4ba3
commit 9a01e59
Show file tree

Hide file tree

Showing 2 changed files with 26 additions and 3 deletions.
diff --git a/bin/import-pac-declare.js b/bin/import-pac-declare.js
@@ -8,11 +8,12 @@ const getStream = require('get-stream')
 const gdal = require('gdal-async')
 const { fromCodePacStrict } = require('@agencebio/rosetta-cultures')
 
-const { createOrUpdateOperatorRecord } = require('../lib/providers/cartobio')
+const { createOrUpdateOperatorRecord, getRecord, patchFeatureCollection, deleteRecord } = require('../lib/providers/cartobio')
 const { CertificationState, EtatProduction } = require('../lib/enums.js')
 const pool = require('../lib/db')
 const { unzipGeographicalContent, detectSrs, wgs84 } = require('../lib/providers/gdal')
 const { getRandomFeatureId } = require('../lib/outputs/features')
+const { normalizeRecord } = require('../lib/outputs/record')
 
 /**
  * Ce script lit la grande FeatureCollection des parcellaires déclarés de l'ASP
@@ -143,6 +144,22 @@ if (process.argv.length < 4) {
             })
           }
 
+          let firstRecord = null
+          const currentRecord = await pool.query(/* sql */
+            `
+                SELECT cartobio_operators.record_id 
+                FROM cartobio_operators
+                LEFT JOIN cartobio_parcelles cp on cartobio_operators.record_id = cp.record_id
+                WHERE numerobio = $1
+                AND numero_pacage = $2 LIMIT 1
+            `,
+            [operator.numerobio, pacage]
+          )
+
+          if (currentRecord.rows.length) {
+            firstRecord = await getRecord(currentRecord.rows[0].record_id)
+          }
+
           /**
            * @type {import('../outputs/types/record').NormalizedRecord}
            */
@@ -162,7 +179,13 @@ if (process.argv.length < 4) {
             }
           }
 
-          await createOrUpdateOperatorRecord(record, { copyParcellesData: true }, client)
+          const newRecord = normalizeRecord(await createOrUpdateOperatorRecord(record, { copyParcellesData: true }, client))
+          if (firstRecord) {
+            await patchFeatureCollection({ record: firstRecord }, newRecord.parcelles.features)
+            await pool.query(`
+              DELETE FROM cartobio_operators WHERE record_id = $1
+            `, [newRecord.record_id])
+          }
           i++
           progress.increment()
         }

diff --git a/lib/providers/cartobio.js b/lib/providers/cartobio.js
@@ -85,7 +85,7 @@ const recordFields = /* sqlFragment */`cartobio_operators.record_id, numerobio,
  * @param {CartoBioUser} [context.user]
  * @param {Boolean} [context.copyParcellesData]
  * @param {import('pg').PoolClient} [customClient]
- * @returns {Promise<DBOperatorRecord>}
+ * @returns {Promise<DBOperatorRecordWithParcelles>}
  */
 async function createOrUpdateOperatorRecord (record, context = {}, customClient) {
   const certificationState = record.certification_state || CertificationState.OPERATOR_DRAFT