<?php
require_once __DIR__ . '/../../vendor/autoload.php';

require_once __DIR__ . '/../helpers/session.php';
require_once __DIR__ . '/../../config/database.php';
require_once __DIR__ . '/../helpers/crypto.php';
require_once __DIR__ . '/../helpers/bitacoras.php';
require_once __DIR__ . '/../helpers/env.php';

function dashboard()
{
    include __DIR__ . '/../../views/patente/dashboard_patente.php';
}

function lista()
{
    if (!($_SESSION['usuario_id'] ?? false)) {
        header('Location: /IMPORTADORES/login');
        exit;
    }
    $usr  = $_SESSION['usuario_id'];
    $conn = getConnection();

    $sql = "
      SELECT 
        aa.*
      FROM dbo.agentes_aduanales aa
      JOIN dbo.usuarios_sistema u 
        ON aa.id_usuario = u.id_usuario
      WHERE u.id_usuario = ? 
        AND aa.activo = 1
      ORDER BY aa.creado_en DESC
    ";
    $stmt = sqlsrv_query($conn, $sql, [$usr]);
    if ($stmt === false) {
        die("Error en lista(): " . print_r(sqlsrv_errors(), true));
    }
    $agentes_aduanales = [];
    while ($r = sqlsrv_fetch_array($stmt, SQLSRV_FETCH_ASSOC)) {
        $agentes_aduanales[] = $r;
    }

    include __DIR__ . '/../../views/patente/lista.php';
}

function alta()
{
    include __DIR__ . '/../../views/patente/alta_patente.php';
}

function guardar()
{
    if (!($_SESSION['usuario_id'] ?? false)) {
        die("⚠️ No autorizado.");
    }

    $conn = getConnection();

    // Capturar campos del formulario - Datos generales
    $aduana         = trim($_POST['aduana'] ?? '');
    $patente        = trim($_POST['patente'] ?? '');
    $agente_aduanal = trim($_POST['agente_aduanal'] ?? '');
    $rfc            = trim($_POST['rfc'] ?? '');
    $curp           = trim($_POST['curp'] ?? '');
    $razon_social   = trim($_POST['razon_social'] ?? '');
    $id_usuario     = $_SESSION['usuario_id'];

    $mf_nombre      = trim($_POST['mf_nombre'] ?? '');
    $mf_paterno     = trim($_POST['mf_paterno'] ?? '');
    $mf_materno     = trim($_POST['mf_materno'] ?? '');

    $vp_inicio      = (int)($_POST['vp_inicio'] ?? 0);
    $vp_final       = (int)($_POST['vp_final'] ?? 0);
    $vp_siguiente   = (int)($_POST['vp_siguiente'] ?? 0);

    $vpe_inicio     = (int)($_POST['vpe_inicio'] ?? 0);
    $vpe_final      = (int)($_POST['vpe_final'] ?? 0);
    $vpe_siguiente  = (int)($_POST['vpe_siguiente'] ?? 0);

    $vat_pb_inicio  = (int)($_POST['vat_pb_inicio'] ?? 0);
    $vat_pb_final   = (int)($_POST['vat_pb_final'] ?? 0);
    $vat_pb_siguiente = (int)($_POST['vat_pb_siguiente'] ?? 0);

    $vcc_inicio     = (int)($_POST['vcc_inicio'] ?? 0);
    $vcc_final      = (int)($_POST['vcc_final'] ?? 0);
    $vcc_siguiente  = (int)($_POST['vcc_siguiente'] ?? 0);

    $vae_inicio     = (int)($_POST['vae_inicio'] ?? 0);
    $vae_final      = (int)($_POST['vae_final'] ?? 0);
    $vae_siguiente  = (int)($_POST['vae_siguiente'] ?? 0);

    // Validaciones generales
    if (empty($aduana) || empty($patente) || empty($agente_aduanal) || empty($rfc) || empty($curp) || empty($razon_social)) {
        die("❌ Todos los campos obligatorios deben ser completados.");
    }

    if (!is_numeric($aduana) || strlen($aduana) > 3) die("❌ La aduana debe ser numérica y máximo 3 dígitos.");
    if (!is_numeric($patente) || strlen($patente) > 4) die("❌ La patente debe ser numérica y máximo 4 dígitos.");
    if (strlen($rfc) > 13) die("❌ El RFC no puede exceder 13 caracteres.");
    if (strlen($curp) > 18) die("❌ El CURP no puede exceder 18 caracteres.");

    // Validar duplicado para este usuario
    $sqlCheck = "SELECT COUNT(*) as count FROM dbo.agentes_aduanales WHERE aduana = ? AND patente = ? AND id_usuario = ?";
    $stmtCheck = sqlsrv_query($conn, $sqlCheck, [$aduana, $patente, $id_usuario]);

    if ($stmtCheck === false) die("❌ Error al verificar duplicados: " . print_r(sqlsrv_errors(), true));

    $row = sqlsrv_fetch_array($stmtCheck, SQLSRV_FETCH_ASSOC);
    if ($row['count'] > 0) die("❌ Ya existe un agente aduanal con esta combinación de aduana y patente.");

    sqlsrv_free_stmt($stmtCheck);

    // Insertar registro
    $sql = "INSERT INTO dbo.agentes_aduanales 
        (aduana, patente, agente_aduanal, rfc, curp, razon_social, id_usuario, activo,
         mf_nombre, mf_paterno, mf_materno,
         vp_inicio, vp_final, vp_siguiente,
         vpe_inicio, vpe_final, vpe_siguiente,
         vat_pb_inicio, vat_pb_final, vat_pb_siguiente,
         vcc_inicio, vcc_final, vcc_siguiente,
         vae_inicio, vae_final, vae_siguiente)
        VALUES (?, ?, ?, ?, ?, ?, ?, 1, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";

    $params = [
        $aduana, $patente, $agente_aduanal, $rfc, $curp, $razon_social, $id_usuario,
        $mf_nombre, $mf_paterno, $mf_materno,
        $vp_inicio, $vp_final, $vp_siguiente,
        $vpe_inicio, $vpe_final, $vpe_siguiente,
        $vat_pb_inicio, $vat_pb_final, $vat_pb_siguiente,
        $vcc_inicio, $vcc_final, $vcc_siguiente,
        $vae_inicio, $vae_final, $vae_siguiente
    ];

    $stmt = sqlsrv_query($conn, $sql, $params);
    if ($stmt === false) die("❌ Error al guardar agente aduanal.");

    sqlsrv_free_stmt($stmt);
    sqlsrv_close($conn);

    header("Location: /IMPORTADORES/patente/lista?success=1");
    exit;
}

function editar()
{
    if (!($_SESSION['usuario_id'] ?? false)) {
        header('Location: /IMPORTADORES/login');
        exit;
    }

    $usr = $_SESSION['usuario_id'];
    $id = $_GET['id'] ?? null;

    if (!$id || !is_numeric($id)) {
        die("❌ ID inválido.");
    }

    $conn = getConnection();

    $sql = "
      SELECT aa.*
      FROM dbo.agentes_aduanales aa
      WHERE aa.id_agente = ? 
        AND aa.id_usuario = ?
    ";

    $stmt = sqlsrv_query($conn, $sql, [(int)$id, $_SESSION['usuario_id']]);

    if ($stmt === false) {
        die("Error en editar(): " . print_r(sqlsrv_errors(), true));
    }

    $agente = sqlsrv_fetch_array($stmt, SQLSRV_FETCH_ASSOC);

    if (!$agente) {
        die("❌ Agente no encontrado o no autorizado.");
    }

    include __DIR__ . '/../../views/patente/editar.php';
}

function actualizar()
{
    if (!($_SESSION['usuario_id'] ?? false)) {
        die("⚠️ No autorizado.");
    }

    $conn = getConnection();

    $id_agente      = (int)($_POST['id_agente'] ?? 0);
    $aduana         = trim($_POST['aduana'] ?? '');
    $patente        = trim($_POST['patente'] ?? '');
    $agente_aduanal = trim($_POST['agente_aduanal'] ?? '');
    $rfc            = trim($_POST['rfc'] ?? '');
    $curp           = trim($_POST['curp'] ?? '');
    $razon_social   = trim($_POST['razon_social'] ?? '');
    $id_usuario     = $_SESSION['usuario_id'];

    $mf_nombre      = trim($_POST['mf_nombre'] ?? '');
    $mf_paterno     = trim($_POST['mf_paterno'] ?? '');
    $mf_materno     = trim($_POST['mf_materno'] ?? '');

    $vp_inicio      = (int)($_POST['vp_inicio'] ?? 0);
    $vp_final       = (int)($_POST['vp_final'] ?? 0);
    $vp_siguiente   = (int)($_POST['vp_siguiente'] ?? 0);

    $vpe_inicio     = (int)($_POST['vpe_inicio'] ?? 0);
    $vpe_final      = (int)($_POST['vpe_final'] ?? 0);
    $vpe_siguiente  = (int)($_POST['vpe_siguiente'] ?? 0);

    $vat_pb_inicio  = (int)($_POST['vat_pb_inicio'] ?? 0);
    $vat_pb_final   = (int)($_POST['vat_pb_final'] ?? 0);
    $vat_pb_siguiente = (int)($_POST['vat_pb_siguiente'] ?? 0);

    $vcc_inicio     = (int)($_POST['vcc_inicio'] ?? 0);
    $vcc_final      = (int)($_POST['vcc_final'] ?? 0);
    $vcc_siguiente  = (int)($_POST['vcc_siguiente'] ?? 0);

    $vae_inicio     = (int)($_POST['vae_inicio'] ?? 0);
    $vae_final      = (int)($_POST['vae_final'] ?? 0);
    $vae_siguiente  = (int)($_POST['vae_siguiente'] ?? 0);

    if (!$id_agente || empty($aduana) || empty($patente) || empty($agente_aduanal) || empty($rfc) || empty($curp) || empty($razon_social)) {
        die("❌ Datos inválidos o incompletos.");
    }

    if (!is_numeric($aduana) || strlen($aduana) > 3) die("❌ La aduana debe ser numérica y máximo 3 dígitos.");
    if (!is_numeric($patente) || strlen($patente) > 4) die("❌ La patente debe ser numérica y máximo 4 dígitos.");
    if (strlen($rfc) > 13) die("❌ El RFC no puede exceder 13 caracteres.");
    if (strlen($curp) > 18) die("❌ El CURP no puede exceder 18 caracteres.");

    // Validar duplicado (excepto el propio id)
    $sqlCheck = "SELECT COUNT(*) as count FROM dbo.agentes_aduanales 
                 WHERE aduana = ? AND patente = ? AND id_usuario = ? AND id_agente != ?";
    $stmtCheck = sqlsrv_query($conn, $sqlCheck, [$aduana, $patente, $id_usuario, $id_agente]);

    if ($stmtCheck === false) die("❌ Error al verificar duplicados.");

    $row = sqlsrv_fetch_array($stmtCheck, SQLSRV_FETCH_ASSOC);
    if ($row['count'] > 0) die("❌ Ya existe un agente aduanal con esta combinación de aduana y patente.");

    sqlsrv_free_stmt($stmtCheck);

    // UPDATE
    $sql = "UPDATE dbo.agentes_aduanales SET 
        aduana = ?, patente = ?, agente_aduanal = ?, rfc = ?, curp = ?, razon_social = ?,
        mf_nombre = ?, mf_paterno = ?, mf_materno = ?,
        vp_inicio = ?, vp_final = ?, vp_siguiente = ?,
        vpe_inicio = ?, vpe_final = ?, vpe_siguiente = ?,
        vat_pb_inicio = ?, vat_pb_final = ?, vat_pb_siguiente = ?,
        vcc_inicio = ?, vcc_final = ?, vcc_siguiente = ?,
        vae_inicio = ?, vae_final = ?, vae_siguiente = ?
        WHERE id_agente = ? AND id_usuario = ?";

    $params = [
        $aduana, $patente, $agente_aduanal, $rfc, $curp, $razon_social,
        $mf_nombre, $mf_paterno, $mf_materno,
        $vp_inicio, $vp_final, $vp_siguiente,
        $vpe_inicio, $vpe_final, $vpe_siguiente,
        $vat_pb_inicio, $vat_pb_final, $vat_pb_siguiente,
        $vcc_inicio, $vcc_final, $vcc_siguiente,
        $vae_inicio, $vae_final, $vae_siguiente,
        $id_agente, $id_usuario
    ];

    $stmt = sqlsrv_query($conn, $sql, $params);
    if ($stmt === false) die("❌ Error al actualizar agente aduanal.");

    sqlsrv_free_stmt($stmt);
    sqlsrv_close($conn);

    header("Location: /IMPORTADORES/patente/lista?updated=ok");
    exit;
}

/** Borrar de un chofer **/
function eliminar()
{
    if (!($_SESSION['usuario_id'] ?? false)) {
        header('Location: /IMPORTADORES/login');
        exit;
    }

    $usr = $_SESSION['usuario_id'];
    $id = $_GET['id'] ?? null;
    if (!$id || !is_numeric($id)) {
        die("❌ ID inválido.");
    }

    $conn = getConnection();

    // Verificar que el transportista exista y pertenezca al usuario
    $sqlChk = "SELECT COUNT(*) AS cnt
               FROM dbo.agentes_aduanales
               WHERE id_agente = ? AND id_usuario = ?";
    $stmtChk = sqlsrv_query($conn, $sqlChk, [$id, $usr]);
    $rowChk  = sqlsrv_fetch_array($stmtChk, SQLSRV_FETCH_ASSOC);
    if ($rowChk['cnt'] == 0) {
        die("❌ Agente no encontrado o no autorizado.");
    }

    $sql = "UPDATE dbo.agentes_aduanales SET activo = 0 WHERE id_agente = ?";
    $stmt = sqlsrv_query($conn, $sql, [(int)$id]);
    if ($stmt === false) {
        die("❌ Error en eliminar(): " . print_r(sqlsrv_errors(), true));
    }

    header('Location: /IMPORTADORES/patente/lista?deleted=ok');
    exit;
}