fix: Correctif sur la récuperation des parcelles déssinées

lib/providers/cartobio.js

@@ -201,6 +201,7 @@ async function createOrUpdateOperatorRecord (record, context = {}, customClient)
                 )
                 AND cartobio_operators.record_id = $18
                 AND cartobio_operators.deleted_at IS NULL
+                AND cartobio_parcelles.deleted_at IS NULL
                 AND $17
               ORDER BY created_at DESC
               LIMIT 1
@@ -295,8 +296,9 @@ async function createOrUpdateOperatorRecord (record, context = {}, customClient)
                         SELECT record_id
                         FROM cartobio_operators
                         WHERE numerobio = $2
-                          AND cartobio_operators.record_id = $1
+                          AND cartobio_operators.record_id = $3
                           AND cartobio_operators.deleted_at IS NULL
+                          AND cartobio_parcelles.deleted_at IS NULL
                         ORDER BY created_at DESC
                         LIMIT 1
                     )
@@ -305,7 +307,7 @@ async function createOrUpdateOperatorRecord (record, context = {}, customClient)
           ON CONFLICT (record_id, id) DO NOTHING
           RETURNING *, ST_AsGeoJSON(geometry)::json as geometry
         `,
-        [context.previousRecordId, result.rows.at(0).numerobio]
+        [result.rows.at(0).record_id, result.rows.at(0).numerobio, context.previousRecordId]
       )
       parcelles.push(...addedParcelles.rows)
     }

migrations/20241105140322-add-delete-column-parcelles.js

@@ -0,0 +1,32 @@
+"use strict";
+
+var dbm;
+var type;
+var seed;
+
+exports.setup = function (options, seedLink) {
+  dbm = options.dbmigrate;
+  type = dbm.dataType;
+  seed = seedLink;
+};
+
+exports.up = async function (db) {
+  await db.addColumn("cartobio_parcelles", "deleted_at", {
+    type: "datetime",
+    notNull: false,
+  });
+  await db.addColumn("cartobio_parcelles", "from_parcelles", {
+    type: "string",
+    length: 255,
+    notNull: false,
+  });
+};
+
+exports.down = async function (db) {
+  await db.removeColumn("cartobio_parcelles", "deleted_at");
+  await db.removeColumn("cartobio_parcelles", "from_parcelles");
+};
+
+exports._meta = {
+  version: 1,
+};