Correo respaldo y notificaciones

This commit is contained in:
2025-05-26 12:34:40 -06:00
parent dfaa8fa499
commit 738c9b07df
7 changed files with 520 additions and 95 deletions

View File

@@ -88,7 +88,7 @@ function validar()
}
$codigo = rand(100000, 999999);
$expiracion = date('Y-m-d H:i:s', strtotime('+1 minutes'));
$expiracion = date('Y-m-d H:i:s', strtotime('+5 minutes'));
$usuarioId = $row['id_usuario'];
$sql = "INSERT INTO verificaciones (id_usuario, codigo, expiracion) VALUES (?, ?, ?)";
@@ -170,6 +170,10 @@ function enviarConfirmacion($email, $codigo)
function confirmarAcceso()
{
$conn = getConnection(); // Asegúrate que esta función retorne una conexión válida
if (!$conn) {
http_response_code(500);
exit('Error de conexión');
}
$codigoIngresado = trim($_POST['codigo'] ?? '');
$usuarioId = $_SESSION['usuario_id'] ?? null;
@@ -225,22 +229,21 @@ function recuperar()
function enviarCodigo()
{
header('Content-Type: application/json');
$conn = getConnection();
if (!$conn) {
echo json_encode(['success' => false, 'message' => '❌ Error de conexión con la base de datos.']);
exit;
}
// Obtener el correo proporcionado en el formulario
$email = trim($_POST['email'] ?? '');
// Verificar si el correo es válido
if (!filter_var($email, FILTER_VALIDATE_EMAIL)) {
echo json_encode(['success' => false, 'message' => '❌ Correo inválido.']);
exit;
}
// Encriptar el correo ingresado para comparar con el de la base de datos
$emailEncrypted = encrypt($email);
// Consultar si el correo encriptado existe en la base de datos
$sql = "SELECT id_usuario FROM usuarios_sistema WHERE email = ?";
$stmt = sqlsrv_query($conn, $sql, [$emailEncrypted]);
@@ -248,9 +251,9 @@ function enviarCodigo()
echo json_encode(['success' => false, 'message' => '❌ Correo no encontrado.']);
exit;
}
$id_usuario = $row['id_usuario'];
// 🧠 Verificar si ya hay un código activo y no expirado
$now = date('Y-m-d H:i:s');
$now = (new DateTime())->format('Y-m-d H:i:s');
$sqlCheck = "SELECT COUNT(*) AS total FROM recuperacion_password
WHERE email = ? AND estatus = 0 AND expiracion > ?";
$checkStmt = sqlsrv_query($conn, $sqlCheck, [$emailEncrypted, $now]);
@@ -261,12 +264,10 @@ function enviarCodigo()
exit;
}
// Generar el código de recuperación y la expiración
$codigo = strval(rand(100000, 999999)); // Convertir a string
$expira = date('Y-m-d H:i:s', strtotime('+10 minutes'));
$estatus = 0; // Estatus inicial
$codigo = strval(random_int(100000, 999999));
$expira = (new DateTime('+10 minutes'))->format('Y-m-d H:i:s');
$estatus = 0;
// Guardar el código y la expiración en la tabla de recuperación de contraseñas
$insert = "INSERT INTO recuperacion_password (email, codigo, expiracion, estatus) VALUES (?, ?, ?, ?)";
$params = [$emailEncrypted, $codigo, $expira, $estatus];
$result = sqlsrv_query($conn, $insert, $params);
@@ -276,7 +277,68 @@ function enviarCodigo()
exit;
}
// Enviar correo con el código utilizando PHPMailer
// ✅ AGREGAR ESTAS LÍNEAS PARA ESTABLECER LA SESIÓN
$_SESSION['email_recuperacion'] = $email;
$_SESSION['id_usuario'] = $id_usuario;
try {
$mail = new PHPMailer(true);
$mail->isSMTP();
$mail->Host = 'secure.emailsrvr.com';
$mail->SMTPAuth = true;
$mail->Username = 'noreply@aduanasoft.com.mx';
$mail->Password = $_ENV['SMTP_PASS'];
$mail->SMTPSecure = PHPMailer::ENCRYPTION_STARTTLS;
$mail->Port = 587;
$mail->setFrom('noreply@aduanasoft.com.mx', 'SIIH | AduanaSoft');
$mail->addAddress($email);
$mail->CharSet = 'UTF-8';
$mail->isHTML(true);
$mail->Subject = 'Código de recuperación de contraseña';
$mail->Body = "
<div style='font-family: Segoe UI, sans-serif; background-color: #f4f6f9; padding: 40px;'>
<div style='max-width: 600px; margin: auto; background: #fff; border: 1px solid #ddd; border-radius: 10px; overflow: hidden;'>
<div style='background: linear-gradient(to right, #003366, #0055A5); padding: 20px; text-align: center;'>
<h2 style='color: white;'>Recuperación de contraseña</h2>
</div>
<div style='padding: 30px; color: #333; font-size: 16px;'>
<p>Has solicitado recuperar tu contraseña.</p>
<div style='text-align: center; margin: 30px 0;'>
<p>Tu código de recuperación es:</p>
<h2 style='color:#333;'>$codigo</h2>
</div>
<p>Este código expirará en 10 minutos.</p>
</div>
<div style='background: #e9ecef; text-align: center; padding: 15px; font-size: 13px; color: #666;'>
&copy; " . date('Y') . " SIIH · Desarrollado por AduanaSoft
</div>
</div>
</div>";
$mail->send();
echo json_encode(['success' => true, 'message' => '✅ Código enviado. Revisa tu correo.']);
} catch (Exception $e) {
error_log("Error al enviar correo de recuperación: {$mail->ErrorInfo}");
echo json_encode(['success' => false, 'message' => '❌ Error al enviar el correo. Intenta más tarde.']);
}
}
function enviarCorreoRespaldo($conn, $id_usuario, $codigo)
{
// Obtener correo de respaldo
$sql = "SELECT TOP 1 correo FROM correo_respaldo WHERE id_usuario = ?";
$stmt = sqlsrv_query($conn, $sql, [$id_usuario]);
if (!$stmt || !($row = sqlsrv_fetch_array($stmt, SQLSRV_FETCH_ASSOC))) {
error_log("❌ No se encontró correo de respaldo para el usuario ID $id_usuario.");
return false; // No hay correo de respaldo
}
$correoRespaldo = $row['correo'];
try {
$mail = new PHPMailer(true);
// ConfigEuración de servidor SMTP
@@ -290,7 +352,7 @@ function enviarCodigo()
// Configuración del correo
$mail->setFrom('noreply@aduanasoft.com.mx', 'SIIH | AduanaSoft');
$mail->addAddress($email);
$mail->addAddress($correoRespaldo);
$mail->CharSet = 'UTF-8';
$mail->isHTML(true);
$mail->Subject = 'Código de recuperación de contraseña';
@@ -316,16 +378,55 @@ function enviarCodigo()
// Enviar el correo
$mail->send();
} catch (Exception $e) {
error_log("Error al enviar correo: {$mail->ErrorInfo}");
echo json_encode(['success' => false, 'message' => '❌ Hubo un error al enviar el correo. Intenta más tarde.']);
return false;
}
return true;
}
function reenviarCodigo()
{
header('Content-Type: application/json');
// Validar sesión y datos requeridos
if (!isset($_SESSION['id_usuario'], $_SESSION['email_recuperacion'])) {
echo json_encode(['success' => false, 'message' => '⚠️ Sesión expirada. Vuelve a ingresar tu correo.']);
exit;
}
$_SESSION['email_recuperacion'] = $email; // email sin cifrar
$_SESSION['intentos_codigo'] = 0; // Inicializa intentos
$conn = getConnection();
if (!$conn) {
echo json_encode(['success' => false, 'message' => '❌ Error de conexión con la base de datos.']);
exit;
}
$id_usuario = $_SESSION['id_usuario'];
$emailEncrypted = encrypt($_SESSION['email_recuperacion']);
// Obtener el último código activo de recuperación
$now = (new DateTime())->format('Y-m-d H:i:s');
$sql = "SELECT TOP 1 codigo FROM recuperacion_password
WHERE email = ? AND estatus = 0 AND expiracion > ?
ORDER BY expiracion DESC";
$stmt = sqlsrv_query($conn, $sql, [$emailEncrypted, $now]);
if (!$stmt || !($row = sqlsrv_fetch_array($stmt, SQLSRV_FETCH_ASSOC))) {
echo json_encode(['success' => false, 'message' => '❌ No se encontró un código activo para reenviar.']);
exit;
}
$codigo = $row['codigo'];
// Llamar a la función para reenviar el correo al respaldo
if (enviarCorreoRespaldo($conn, $id_usuario, $codigo)) {
echo json_encode(['success' => true, 'message' => '📤 Código reenviado al correo de respaldo.']);
} else {
echo json_encode(['success' => false, 'message' => '❌ Error al reenviar el código al correo de respaldo.']);
}
echo json_encode(['success' => true, 'message' => '✅ Código enviado correctamente. Revisa tu correo.']);
exit;
}
@@ -336,25 +437,33 @@ function verificarCodigoVista()
function verificarCodigo()
{
// ❌ REMOVER session_start() - ya se maneja en session.php
header('Content-Type: application/json');
$conn = getConnection();
$codigo = trim($_POST['codigo'] ?? '');
// Validar existencia de conexión, código y email en sesión
$codigo = isset($_POST['codigo']) ? trim($_POST['codigo']) : '';
$email = $_SESSION['email_recuperacion'] ?? '';
if (!$codigo || !$email) {
if (!$conn || empty($codigo) || empty($email)) {
echo json_encode(['success' => false, 'message' => '❌ Código o correo faltante.']);
exit;
}
// Encriptar el correo ingresado
// Encriptar el correo (asegurar que coincida con formato en base)
$emailEncrypted = encrypt($email);
// Consultar el código de recuperación y su expiración desde la base de datos
$sql = "SELECT id, codigo, expiracion FROM recuperacion_password
// Consulta el último código válido para ese email
$sql = "SELECT TOP 1 id, codigo, expiracion FROM recuperacion_password
WHERE email = ? AND estatus = 0 ORDER BY id DESC";
$stmt = sqlsrv_query($conn, $sql, [$emailEncrypted]);
if ($stmt === false) {
echo json_encode(['success' => false, 'message' => '❌ Error al consultar el código.']);
exit;
}
$row = sqlsrv_fetch_array($stmt, SQLSRV_FETCH_ASSOC);
if (!$row) {
@@ -362,36 +471,49 @@ function verificarCodigo()
exit;
}
// Manejo de intentos fallidos
$_SESSION['intentos_codigo'] = ($_SESSION['intentos_codigo'] ?? 0) + 1;
// Manejo de intentos fallidos en sesión
if (!isset($_SESSION['intentos_codigo'])) {
$_SESSION['intentos_codigo'] = 0;
}
$_SESSION['intentos_codigo']++;
if ($_SESSION['intentos_codigo'] > 5) {
$update = "UPDATE recuperacion_password SET estatus = 1 WHERE id = ?";
sqlsrv_query($conn, $update, [$row['id']]);
// Bloquea el código en la base y resetea intentos
sqlsrv_query($conn, "UPDATE recuperacion_password SET estatus = 1 WHERE id = ?", [$row['id']]);
unset($_SESSION['intentos_codigo']);
echo json_encode(['success' => false, 'message' => '🚫 Has excedido el número de intentos. Solicita un nuevo código.']);
exit;
}
if ($codigo != $row['codigo']) {
echo json_encode(['success' => false, 'message' => '❌ Código incorrecto. Intento {$_SESSION["intentos_codigo"]} de 5.']);
// Compara códigos - asegurando que no haya problemas con mayúsculas o espacios
if (strcasecmp($codigo, $row['codigo']) !== 0) {
echo json_encode(['success' => false, 'message' => "❌ Código incorrecto. Intento {$_SESSION['intentos_codigo']} de 5."]);
exit;
}
// Validar expiración
$expiracionTimestamp = strtotime($row['expiracion']->format('Y-m-d H:i:s'));
if ($expiracionTimestamp < time()) {
$update = "UPDATE recuperacion_password SET estatus = 1 WHERE id = ?";
sqlsrv_query($conn, $update, [$row['id']]);
// Validar expiración - puede venir como DateTime o string
$expiracion = $row['expiracion'];
$expiracionTimestamp = null;
if ($expiracion instanceof DateTime) {
$expiracionTimestamp = $expiracion->getTimestamp();
} else {
$expiracionTimestamp = strtotime($expiracion);
}
if ($expiracionTimestamp === false || $expiracionTimestamp < time()) {
// Código expirado: marcar como usado y enviar mensaje
sqlsrv_query($conn, "UPDATE recuperacion_password SET estatus = 1 WHERE id = ?", [$row['id']]);
echo json_encode(['success' => false, 'message' => '⏰ El código ha expirado.']);
exit;
}
// Código correcto
$update = "UPDATE recuperacion_password SET estatus = 1 WHERE id = ?";
sqlsrv_query($conn, $update, [$row['id']]);
// Código correcto: actualizar estado y permitir cambio de contraseña
sqlsrv_query($conn, "UPDATE recuperacion_password SET estatus = 1 WHERE id = ?", [$row['id']]);
// Habilitar cambio de contraseña
$_SESSION['recuperacion_autorizada'] = true;
$_SESSION['recuperacion_autorizada'] = true;
unset($_SESSION['intentos_codigo']);
echo json_encode(['success' => true, 'message' => '✅ Código verificado. Redirigiendo...']);
@@ -400,9 +522,6 @@ function verificarCodigo()
function cambiarPasswordVista()
{
if (session_status() === PHP_SESSION_NONE) {
session_start();
}
if (!isset($_SESSION['recuperacion_autorizada'])) {
header('Location: /IMPORTADORES/login');
exit;

View File

@@ -5,5 +5,126 @@ require_once __DIR__ . '/../helpers/crypto.php';
function index()
{
// Asegúrate de tener conexión
$conn = getConnection(); // Suponiendo que tienes una función getConnection()
// Verifica si la sesión tiene el id_usuario
if (!isset($_SESSION['usuario_id']) || ($_SESSION['pendiente_confirmacion'] ?? true)) {
die("Usuario no autenticado.");
}
$id_usuario = $_SESSION['usuario_id'];
// Obtener correos
$correos = obtenerCorreos($conn, $id_usuario);
// Cargar vista y pasar datos
include __DIR__ . '/../../views/seguridad/dashboard_seguridad.php';
}
function opciones()
{
include __DIR__ . '/../../views/seguridad/agregar.php';
}
function correoExtra()
{
if (!isset($_SESSION['usuario_id']) || ($_SESSION['pendiente_confirmacion'] ?? true)) {
echo "Error: no se ha iniciado sesión o falta el ID de usuario.";
exit;
}
$id_usuario = $_SESSION['usuario_id'];
$conn = getConnection();
$sql_check = "SELECT COUNT(*) AS total FROM correo_extra WHERE id_usuario = ?";
$stmt_check = sqlsrv_query($conn, $sql_check, [$id_usuario]);
$row = sqlsrv_fetch_array($stmt_check, SQLSRV_FETCH_ASSOC);
if ($row['total'] > 0) {
echo "Ya tienes un correo adicional registrado.";
return;
}
$correo = $_POST['email-extra'] ?? '';
if (!filter_var($correo, FILTER_VALIDATE_EMAIL)) {
echo "Correo inválido.";
return;
}
$query = "INSERT INTO correo_extra (id_usuario, correo) VALUES (?, ?)";
$stmt = sqlsrv_prepare($conn, $query, [$id_usuario, $correo]);
if ($stmt && sqlsrv_execute($stmt)) {
header('Location: /IMPORTADORES/seguridad/index');
exit;
} else {
echo "Error al registrar el correo extra.";
}
}
function correoRespaldo()
{
if (!isset($_SESSION['usuario_id']) || ($_SESSION['pendiente_confirmacion'] ?? true)) {
echo "Error: no se ha iniciado sesión o falta el ID de usuario.";
exit;
}
$id_usuario = $_SESSION['usuario_id'];
$conn = getConnection();
$sql_check = "SELECT COUNT(*) AS total FROM correo_respaldo WHERE id_usuario = ?";
$stmt_check = sqlsrv_query($conn, $sql_check, [$id_usuario]);
$row = sqlsrv_fetch_array($stmt_check, SQLSRV_FETCH_ASSOC);
if ($row['total'] > 0) {
echo "Ya tienes un correo adicional registrado.";
return;
}
$correo = $_POST['email-respaldo'] ?? '';
if (!filter_var($correo, FILTER_VALIDATE_EMAIL)) {
echo "Correo inválido.";
return;
}
$query = "INSERT INTO correo_respaldo (id_usuario, correo) VALUES (?, ?)";
$stmt = sqlsrv_prepare($conn, $query, [$id_usuario, $correo]);
if ($stmt && sqlsrv_execute($stmt)) {
header('Location: /IMPORTADORES/seguridad/index');
exit;
} else {
echo "Error al registrar el correo extra.";
}
}
function obtenerCorreos($conn, $id_usuario)
{
$correos = [
'correo_extra' => '',
'correo_respaldo' => ''
];
// Obtener correo_extra
$sql_extra = "SELECT correo FROM correo_extra WHERE id_usuario = ?";
$stmt_extra = sqlsrv_prepare($conn, $sql_extra, [$id_usuario]);
if ($stmt_extra && sqlsrv_execute($stmt_extra)) {
if ($row = sqlsrv_fetch_array($stmt_extra, SQLSRV_FETCH_ASSOC)) {
$correos['correo_extra'] = $row['correo'];
}
}
// Obtener correo_respaldo
$sql_respaldo = "SELECT correo FROM correo_respaldo WHERE id_usuario = ?";
$stmt_respaldo = sqlsrv_prepare($conn, $sql_respaldo, [$id_usuario]);
if ($stmt_respaldo && sqlsrv_execute($stmt_respaldo)) {
if ($row = sqlsrv_fetch_array($stmt_respaldo, SQLSRV_FETCH_ASSOC)) {
$correos['correo_respaldo'] = $row['correo'];
}
}
return $correos;
}