feat: modelado BD con schema, seeds y docker-compose

2026-05-22 19:29:05 -06:00
parent e3f659cac8
commit bc395edf20
164 changed files with 17258 additions and 0 deletions
--- a/init/03_seed_json.js
+++ b/init/03_seed_json.js
@@ -0,0 +1,146 @@
+/**
+ * SEED JSON - App Recolección Inteligente
+ * Uso: npm run seed
+ */
+
+require('dotenv').config();
+const { Pool } = require('pg');
+const fs   = require('fs');
+const path = require('path');
+
+const pool = new Pool({
+  host:     process.env.DB_HOST     || 'localhost',
+  port:     parseInt(process.env.DB_PORT || '5433'),
+  database: process.env.DB_NAME     || 'recoleccion_db',
+  user:     process.env.DB_USER     || 'recoleccion',
+  password: process.env.DB_PASSWORD || 'recoleccion123',
+});
+
+function readJson(filename) {
+  const filepath = path.join(__dirname, '..', 'data', filename);
+  return JSON.parse(fs.readFileSync(filepath, 'utf-8'));
+}
+
+function parseHorario(str) {
+  const match = str.match(/^(\w+)\s*\((\d{2}:\d{2})\s*-\s*(\d{2}:\d{2})\)/);
+  if (!match) throw new Error(`Horario no reconocido: "${str}"`);
+  return { turno: match[1], inicio: match[2], fin: match[3] };
+}
+
+async function seed() {
+  const client = await pool.connect();
+
+  try {
+    await client.query('BEGIN');
+
+    const rutas    = readJson('rutas.json');
+    const colonias = readJson('colonias-rutas.json');
+
+    console.log(`\n📦 Sembrando ${rutas.length} rutas...`);
+
+    for (const ruta of rutas) {
+      const pos1 = ruta.positions.find(p => p.positionId === 1);
+      const pos8 = ruta.positions.find(p => p.positionId === 8);
+
+      const horaInicio = new Date(pos1.timestamp).toISOString().substring(11, 16);
+      const horaFin    = new Date(pos8.timestamp).toISOString().substring(11, 16);
+
+      // ── Insertar ruta ──────────────────────────────────────
+      const { rows: [rutaRow] } = await client.query(
+        `INSERT INTO rutas (route_id, nombre, truck_id, hora_inicio, hora_fin_ref)
+         VALUES ($1, $2, $3, $4::TIME, $5::TIME)
+         ON CONFLICT (route_id) DO UPDATE
+           SET nombre       = EXCLUDED.nombre,
+               truck_id     = EXCLUDED.truck_id,
+               hora_inicio  = EXCLUDED.hora_inicio,
+               hora_fin_ref = EXCLUDED.hora_fin_ref
+         RETURNING id`,
+        [ruta.routeId, ruta.name, ruta.truckId, horaInicio, horaFin]
+      );
+      const rutaId = rutaRow.id;
+
+      // ── Estado inicial ─────────────────────────────────────
+      await client.query(
+        `INSERT INTO estado_ruta (ruta_id, estado, position_id_actual)
+         VALUES ($1, 'INACTIVA', 1)
+         ON CONFLICT (ruta_id) DO NOTHING`,
+        [rutaId]
+      );
+
+      // ── Posiciones ─────────────────────────────────────────
+      const tsBase = new Date(pos1.timestamp).getTime();
+
+      for (const pos of ruta.positions) {
+        const offsetSeg = Math.round((new Date(pos.timestamp).getTime() - tsBase) / 1000);
+
+        // IMPORTANTE: punto va al final ($8) para que los parámetros
+        // sean estrictamente secuenciales $1..$8 sin saltos
+        const wkt = `SRID=4326;POINT(${pos.lng} ${pos.lat})`;
+
+        await client.query(
+          `INSERT INTO ruta_posiciones
+               (ruta_id, position_id, lat, lng, speed_kmh, ts_referencia, offset_seg, punto)
+           VALUES
+               ($1,      $2,          $3,  $4,  $5,        $6::timestamptz,$7,         $8::geography)
+           ON CONFLICT (ruta_id, position_id) DO UPDATE
+             SET lat           = EXCLUDED.lat,
+                 lng           = EXCLUDED.lng,
+                 speed_kmh     = EXCLUDED.speed_kmh,
+                 ts_referencia = EXCLUDED.ts_referencia,
+                 offset_seg    = EXCLUDED.offset_seg,
+                 punto         = EXCLUDED.punto`,
+          [rutaId, pos.positionId, pos.lat, pos.lng,
+           pos.speed, pos.timestamp, offsetSeg, wkt]
+        );
+      }
+
+      console.log(`  ✓ ${ruta.routeId} — ${ruta.name}`);
+    }
+
+    // ── Colonias ───────────────────────────────────────────────
+    console.log(`\n🗺️  Sembrando ${colonias.length} colonias...`);
+
+    for (const col of colonias) {
+      const { rows: [rutaRow] } = await client.query(
+        'SELECT id FROM rutas WHERE route_id = $1',
+        [col.routeId]
+      );
+
+      if (!rutaRow) {
+        console.warn(`  ⚠️  ${col.routeId} no encontrada para "${col.colonia}". Omitida.`);
+        continue;
+      }
+
+      const h = parseHorario(col.horarioEstimado);
+
+      await client.query(
+        `INSERT INTO colonias (nombre, ruta_id, horario_turno, hora_inicio_est, hora_fin_est)
+         VALUES ($1, $2, $3, $4::TIME, $5::TIME)
+         ON CONFLICT (nombre) DO UPDATE
+           SET ruta_id         = EXCLUDED.ruta_id,
+               horario_turno   = EXCLUDED.horario_turno,
+               hora_inicio_est = EXCLUDED.hora_inicio_est,
+               hora_fin_est    = EXCLUDED.hora_fin_est`,
+        [col.colonia, rutaRow.id, h.turno, h.inicio, h.fin]
+      );
+
+      console.log(`  ✓ ${col.colonia} → ${col.routeId} (${h.turno} ${h.inicio}-${h.fin})`);
+    }
+
+    await client.query('COMMIT');
+    console.log('\n✅ Seed completado exitosamente.\n');
+
+  } catch (err) {
+    await client.query('ROLLBACK');
+    console.error('\n❌ Error en el seed, se hizo ROLLBACK:', err.message);
+    throw err;
+  } finally {
+    client.release();
+    await pool.end();
+  }
+}
+
+seed().catch((err) => {
+  console.error('💥 Error fatal:', err.message);
+  process.exit(1);
+});