Implementar la sonda

CREATE TABLE pagos_zonapagos (
  id BIGSERIAL PRIMARY KEY,
  str_id_pago VARCHAR(30) UNIQUE NOT NULL,
  flt_total_con_iva NUMERIC(12, 2) NOT NULL,
  int_id_forma_pago INT,                 -- Lo conoces al primer VerificacionPago
  estado_local VARCHAR(20) NOT NULL,     -- pendiente | aprobado | rechazado
  int_estado_pago_zp INT,                -- El valor de Zonapagos
  str_codigo_transaccion VARCHAR(100),   -- CUS para PSE
  dt_inicio_pago TIMESTAMP NOT NULL,
  dt_ultima_consulta TIMESTAMP,
  dt_cierre TIMESTAMP,
  es_presencial BOOLEAN DEFAULT false,   -- Para pagos 41, 77 (consulta cada 1h)
  intentos_sonda INT DEFAULT 0,
  respuesta_completa JSONB,              -- str_res_pago parseado
  creado_en TIMESTAMP DEFAULT NOW()
);

CREATE INDEX idx_pagos_pendientes ON pagos_zonapagos(estado_local, dt_inicio_pago)
  WHERE estado_local = 'pendiente';

SELECT id, str_id_pago, dt_ultima_consulta, es_presencial
FROM pagos_zonapagos
WHERE estado_local = 'pendiente'
  AND dt_inicio_pago < NOW() - INTERVAL '7 minutes'
  AND (
    (es_presencial = false AND (dt_ultima_consulta IS NULL OR dt_ultima_consulta < NOW() - INTERVAL '10 minutes'))
    OR
    (es_presencial = true AND (dt_ultima_consulta IS NULL OR dt_ultima_consulta < NOW() - INTERVAL '1 hour'))
  )
ORDER BY dt_inicio_pago ASC
LIMIT 100;

// sonda.js - correr con cron, k8s CronJob, AWS EventBridge, etc.
import axios from "axios";
import { parseStrResPago } from "./parser.js";

const API_URL = process.env.ZP_API_URL;
const CREDS = {
  int_id_comercio: Number(process.env.ZP_ID_COMERCIO),
  str_usr_comercio: process.env.ZP_USUARIO,
  str_pwd_Comercio: process.env.ZP_CLAVE
};

const ESTADOS_DEFINITIVOS = [1, 1000, 1001, 4000, 4003];

export async function ejecutarSonda(db, logger) {
  const pagosPendientes = await db.query(`
    SELECT id, str_id_pago, es_presencial
    FROM pagos_zonapagos
    WHERE estado_local = 'pendiente'
      AND dt_inicio_pago < NOW() - INTERVAL '7 minutes'
      AND (dt_ultima_consulta IS NULL 
           OR dt_ultima_consulta < NOW() - (CASE WHEN es_presencial THEN INTERVAL '1 hour' 
                                                ELSE INTERVAL '10 minutes' END))
    ORDER BY dt_inicio_pago ASC
    LIMIT 100
  `);

  logger.info(`Sonda: ${pagosPendientes.length} pagos a verificar`);

  for (const pago of pagosPendientes) {
    try {
      const { data } = await axios.post(`${API_URL}/VerificacionPago`, {
        ...CREDS,
        str_id_pago: pago.str_id_pago,
        int_no_pago: -1
      }, { timeout: 15000 });

      await db.query(
        `UPDATE pagos_zonapagos 
         SET dt_ultima_consulta = NOW(), 
             intentos_sonda = intentos_sonda + 1 
         WHERE id = $1`,
        [pago.id]
      );

      if (data.int_estado !== 1 || data.int_error !== 0) {
        logger.warn("Verificación con error", { pago: pago.str_id_pago, data });
        continue;
      }

      if (data.int_cantidad_pagos === 0) {
        // Sin intentos registrados — el usuario nunca inició el pago
        // Si ya pasaron >30min desde inicio, marcar como abandonado
        await marcarAbandonadoSiAplica(db, pago.id);
        continue;
      }

      const intentos = parseStrResPago(data.str_res_pago);
      const ultimo = intentos[intentos.length - 1];
      const estado = Number(ultimo.int_estado_pago);

      // Marcar medio de pago si es la primera vez que lo sabemos
      if (ultimo.int_id_forma_pago) {
        const esPresencial = [41, 77].includes(Number(ultimo.int_id_forma_pago));
        await db.query(
          `UPDATE pagos_zonapagos 
           SET int_id_forma_pago = $1, es_presencial = $2
           WHERE id = $3`,
          [ultimo.int_id_forma_pago, esPresencial, pago.id]
        );
      }

      if (estado === 1) {
        await cerrarComoAprobado(db, pago.id, ultimo);
        await notificarCliente(pago.str_id_pago, "aprobado");
      } else if (ESTADOS_DEFINITIVOS.includes(estado)) {
        await cerrarComoRechazado(db, pago.id, ultimo);
        await notificarCliente(pago.str_id_pago, "rechazado");
      }
      // Si sigue en 999, 4001 → no hacer nada, esperar próxima iteración

    } catch (err) {
      logger.error("Error en sonda", { pago: pago.str_id_pago, error: err.message });
      // No abortar la sonda entera por un pago fallido
    }
  }
}

async function cerrarComoAprobado(db, id, detalle) {
  await db.query(
    `UPDATE pagos_zonapagos 
     SET estado_local = 'aprobado',
         int_estado_pago_zp = $1,
         str_codigo_transaccion = $2,
         dt_cierre = NOW(),
         respuesta_completa = $3
     WHERE id = $4`,
    [detalle.int_estado_pago, detalle.str_codigo_transaccion || null, 
     JSON.stringify(detalle), id]
  );
}