From 82dc00150a23e9024aee8a9af255a998c18a5b41 Mon Sep 17 00:00:00 2001
From: Lucas Vaz <lucasvazlira14@gmail.com>
Date: Wed, 13 May 2026 17:36:18 -0300
Subject: [PATCH] =?UTF-8?q?Migra=C3=A7=C3=A3o=20para=20resolver=20problema?=
 =?UTF-8?q?=20de=20herb=C3=A1rios=20duplicados=20rela=C3=A7=C3=A3o=20nome?=
 =?UTF-8?q?=20e=20sigla.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ...0513201913_remover-herbarios-duplicados.ts | 89 +++++++++++++++++++
 1 file changed, 89 insertions(+)
 create mode 100644 src/database/migration/20260513201913_remover-herbarios-duplicados.ts

diff --git a/src/database/migration/20260513201913_remover-herbarios-duplicados.ts b/src/database/migration/20260513201913_remover-herbarios-duplicados.ts
new file mode 100644
index 00000000..c0054c71
--- /dev/null
+++ b/src/database/migration/20260513201913_remover-herbarios-duplicados.ts
@@ -0,0 +1,89 @@
+import { Knex } from 'knex'
+
+type DupGroupRow = {
+  nome_norm: string
+  sigla_norm: string
+  keep_id: number
+  ids: number[]
+  qtde: number
+}
+
+export async function run(knex: Knex): Promise<void> {
+  await knex.transaction(async trx => {
+    // Agrupa por nome e sigla normalizados; mantém o menor id
+    const dupGroups = (await trx('herbarios')
+      .select([
+        trx.raw('TRIM(LOWER(nome)) as nome_norm'),
+        trx.raw('TRIM(LOWER(COALESCE(sigla, \'\'))) as sigla_norm'),
+        trx.raw('MIN(id)::int as keep_id'),
+        trx.raw('ARRAY_AGG(id ORDER BY id) as ids'),
+        trx.raw('COUNT(*)::int as qtde')
+      ])
+      .groupByRaw('TRIM(LOWER(nome)), TRIM(LOWER(COALESCE(sigla, \'\')))')
+      .havingRaw('COUNT(*) > 1')) as unknown as DupGroupRow[]
+
+    if (!dupGroups.length) return
+
+    const pairs: Array<{ keep_id: number; drop_id: number }> = []
+
+    for (const g of dupGroups) {
+      const keepId = Number(g.keep_id)
+      const ids = (g.ids ?? []).map(n => Number(n)).filter(Number.isFinite)
+
+      for (const id of ids) {
+        if (id !== keepId) pairs.push({ keep_id: keepId, drop_id: id })
+      }
+    }
+
+    if (!pairs.length) return
+
+    await trx.raw('DROP TABLE IF EXISTS herbario_merge')
+
+    await trx.schema.createTable('herbario_merge', table => {
+      table.integer('keep_id').notNullable()
+      table.integer('drop_id').notNullable().primary()
+    })
+
+    await trx('herbario_merge').insert(pairs)
+
+    // Atualiza tombos.entidade_id
+    await trx.raw(`
+      UPDATE tombos t
+      SET entidade_id = m.keep_id
+      FROM herbario_merge m
+      WHERE t.entidade_id = m.drop_id
+    `)
+
+    // Atualiza remessas
+    await trx.raw(`
+      UPDATE remessas r
+      SET herbario_id = m.keep_id
+      FROM herbario_merge m
+      WHERE r.herbario_id = m.drop_id
+    `)
+
+    await trx.raw(`
+      UPDATE remessas r
+      SET entidade_destino_id = m.keep_id
+      FROM herbario_merge m
+      WHERE r.entidade_destino_id = m.drop_id
+    `)
+
+    // Atualiza usuarios.herbario_id
+    await trx.raw(`
+      UPDATE usuarios u
+      SET herbario_id = m.keep_id
+      FROM herbario_merge m
+      WHERE u.herbario_id = m.drop_id
+    `)
+
+    // Remove os herbários duplicados
+    await trx.raw(`
+      DELETE FROM herbarios h
+      USING herbario_merge m
+      WHERE h.id = m.drop_id
+    `)
+
+    await trx.schema.dropTable('herbario_merge')
+  })
+}