Callback del comercio (GET)

GET https://micomercio.com/retorno-pago?id_comercio=678&id_pago=ORDEN-TEST-001

import express from "express";
import axios from "axios";

const app = express();

app.get("/retorno-pago", async (req, res) => {
  const { id_comercio, id_pago } = req.query;
  
  // 1. Validar
  if (Number(id_comercio) !== Number(process.env.ZP_ID_COMERCIO)) {
    return res.status(403).send("id_comercio no coincide");
  }
  
  // 2. Buscar el pedido
  const pedido = await db.pedidos.findOne({ str_id_pago: id_pago });
  if (!pedido) return res.status(404).send("Pedido no encontrado");
  
  // 3. Verificar estado contra Zonapagos
  const verif = await axios.post(
    `${process.env.ZP_API_URL}/VerificacionPago`,
    {
      int_id_comercio: Number(process.env.ZP_ID_COMERCIO),
      str_usr_comercio: process.env.ZP_USUARIO,
      str_pwd_Comercio: process.env.ZP_CLAVE,
      str_id_pago: id_pago,
      int_no_pago: -1
    }
  );
  
  const pagos = parseStrResPago(verif.data.str_res_pago); // ver parser en la página del endpoint
  const ultimoIntento = pagos[pagos.length - 1];
  
  // 4. Actualizar BD
  if (ultimoIntento?.int_estado_pago === "1") {
    await db.pedidos.update(pedido.id, { estado: "pagado" });
    return res.redirect(`/gracias?id=${pedido.id}`);
  }
  
  if (["999", "4001", "4000", "4003"].includes(ultimoIntento?.int_estado_pago)) {
    return res.redirect(`/pago-pendiente?id=${pedido.id}`);
  }
  
  return res.redirect(`/pago-rechazado?id=${pedido.id}`);
});