diff --git a/app/controllers/solicitud_importacion.php b/app/controllers/solicitud_importacion.php index 64c2eab..99253d9 100644 --- a/app/controllers/solicitud_importacion.php +++ b/app/controllers/solicitud_importacion.php @@ -8,7 +8,6 @@ require_once __DIR__ . '/../../vendor/autoload.php'; require_once __DIR__ . '/../helpers/env.php'; loadEnv(); -require_once __DIR__ . '/../../vendor/autoload.php'; require_once __DIR__ . '/../helpers/crypto.php'; /** Obtiene (y cachea en sesión) el JWT de la API usando las credenciales de $_ENV **/ @@ -814,9 +813,130 @@ function update_status() { exit; } - // 3) Si el status actualizado es 2, hacer POST a /pedimentos/crearPedimento + // 3) Obtener datos del usuario y solicitud para notificación + try { + $sqlNotif = " + SELECT + u.nombre, + u.email, + u.notificaciones, + u.notificaciones_extra, + COALESCE(p.cambio_estado, 0) as cambio_estado, + ce.correo as correo_extra, + s.numero_factura, + s.fecha_factura, + s.valor_factura, + s.tipo_moneda + FROM usuarios_sistema u + LEFT JOIN preferencias_notificaciones_usuario p ON u.id_usuario = p.id_usuario + LEFT JOIN correo_extra ce ON u.id_usuario = ce.id_usuario + INNER JOIN solicitud_importacion_factura s ON s.id_importador = u.id_usuario + WHERE u.id_usuario = ? AND s.id_solicitud = ?"; + + $stmtNotif = sqlsrv_prepare($conn, $sqlNotif, [$_SESSION['usuario_id'], $id]); + + if ($stmtNotif && sqlsrv_execute($stmtNotif)) { + $notifConfig = sqlsrv_fetch_array($stmtNotif, SQLSRV_FETCH_ASSOC); + sqlsrv_free_stmt($stmtNotif); + + // 🔐 Desencriptar datos + if ($notifConfig) { + $notifConfig['email'] = decrypt($notifConfig['email']); + $notifConfig['nombre'] = decrypt($notifConfig['nombre']); + } + + // Verificar si debe enviar notificaciones de cambio de status + if ($notifConfig && + $notifConfig['notificaciones'] == 1 && + $notifConfig['cambio_estado'] == 1) { + + // Formatear fecha si es DateTime + $fechaFactura = ($notifConfig['fecha_factura'] instanceof DateTime) + ? $notifConfig['fecha_factura']->format('Y-m-d') + : $notifConfig['fecha_factura']; + + // Preparar datos para la notificación + $datosSolicitud = [ + 'id_solicitud' => $id, + 'numero_factura' => $notifConfig['numero_factura'], + 'fecha_factura' => $fechaFactura, + 'valor_factura' => $notifConfig['valor_factura'], + 'tipo_moneda' => $notifConfig['tipo_moneda'], + 'nuevo_status' => $status + ]; + + $notificacionesEnviadas = 0; + $erroresNotificacion = []; + + // Enviar al correo principal + if (!empty($notifConfig['email']) && filter_var($notifConfig['email'], FILTER_VALIDATE_EMAIL)) { + $resultadoPrincipal = enviarNotificacionCambioStatus( + $notifConfig['email'], + $notifConfig['nombre'], + $datosSolicitud, + false // No es correo adicional + ); + + if ($resultadoPrincipal) { + $notificacionesEnviadas++; + } else { + $erroresNotificacion[] = 'correo principal'; + } + } + + // Enviar al correo adicional si está configurado + if ($notifConfig['notificaciones_extra'] == 1 && + !empty($notifConfig['correo_extra']) && + filter_var($notifConfig['correo_extra'], FILTER_VALIDATE_EMAIL)) { + + $resultadoExtra = enviarNotificacionCambioStatus( + $notifConfig['correo_extra'], + $notifConfig['nombre'], + $datosSolicitud, + true // Es correo adicional + ); + + if ($resultadoExtra) { + $notificacionesEnviadas++; + } else { + $erroresNotificacion[] = 'correo adicional'; + } + } + + // Log consolidado del resultado + if ($notificacionesEnviadas > 0) { + error_log("✅ Notificaciones de cambio de status enviadas ($notificacionesEnviadas) para solicitud ID: $id → Status: $status"); + } + + if (!empty($erroresNotificacion)) { + error_log("⚠️ Errores al enviar notificaciones (" . implode(', ', $erroresNotificacion) . ") para solicitud ID: $id"); + } + + } else { + // Log informativo cuando las notificaciones están deshabilitadas + $razon = []; + if (!$notifConfig) { + $razon[] = 'configuración no encontrada'; + } else { + if ($notifConfig['notificaciones'] != 1) $razon[] = 'notificaciones generales deshabilitadas'; + if ($notifConfig['cambio_estado'] != 1) $razon[] = 'notificaciones de cambio de estado deshabilitadas'; + } + + error_log("ℹ️ Usuario ID: {$_SESSION['usuario_id']} no recibirá notificación de cambio de status. Razón: " . implode(', ', $razon)); + } + } else { + error_log("⚠️ No se pudo consultar configuración de notificaciones para usuario ID: {$_SESSION['usuario_id']} - Error SQL: " . print_r(sqlsrv_errors(), true)); + } + + } catch (Exception $e) { + // No fallar el proceso principal por errores de notificación + error_log("❌ Error en sistema de notificaciones de cambio de status para solicitud ID: $id - " . $e->getMessage()); + error_log("Stack trace: " . $e->getTraceAsString()); + } + + // 4) Si el status actualizado es 2, hacer POST a /pedimentos/crearPedimento if ($status === 2) { - // 3.1) Obtener o renovar el token de la API + // 4.1) Obtener o renovar el token de la API $token = getApiToken(); if (!$token) { error_log("[update_status] No se pudo obtener token para crearPedimento"); @@ -824,7 +944,7 @@ function update_status() { exit; } - // 3.2) Leer de la BD todos los campos de la cabecera de la solicitud + // 4.2) Leer de la BD todos los campos de la cabecera de la solicitud $sqlSel = " SELECT s.id_solicitud, @@ -864,7 +984,7 @@ function update_status() { exit; } - // 3.3) Formatear fechas (si vienen como DateTime) antes de construir JSON + // 4.3) Formatear fechas (si vienen como DateTime) antes de construir JSON $fechaFactura = ($solicitud['fecha_factura'] instanceof DateTime) ? $solicitud['fecha_factura']->format('Y-m-d') : $solicitud['fecha_factura']; @@ -877,7 +997,7 @@ function update_status() { ? $solicitud['updated_at']->format('Y-m-d\TH:i:s') : $solicitud['updated_at']; - // 3.4) Obtener todas las partidas asociadas a esta solicitud + // 4.4) Obtener todas las partidas asociadas a esta solicitud $sqlPart = " SELECT p.id_partida, @@ -914,7 +1034,7 @@ function update_status() { } sqlsrv_free_stmt($stmtPart); - // 3.5) Construir el arreglo PHP con la misma estructura JSON que envías + // 4.5) Construir el arreglo PHP con la misma estructura JSON que envías $payload = [ "id_solicitud" => intval($solicitud['id_solicitud']), "id_importador" => intval($solicitud['id_importador']), @@ -961,7 +1081,7 @@ function update_status() { $curlErr = curl_error($ch); curl_close($ch); - // 3.7) Verificar respuesta del endpoint pedimentos + // 4.7) Verificar respuesta del endpoint pedimentos if ($httpPed === 201 || $httpPed === 200) { $decoded = json_decode($respPed, true); // Si existe PEDIMENTO dentro de la clave 'pedimento' @@ -1002,11 +1122,199 @@ function update_status() { } } - // 4) Si el status no es 2, devolvemos normal + // 5) Si el status no es 2, devolvemos normal echo json_encode(['success' => true]); exit; } +/** Envía notificación de cambio de estado de solicitud de importación **/ +function enviarNotificacionCambioStatus($email, $nombreCompleto, $datosSolicitud, $esCorreoExtra = false) { + // Validar datos de entrada + if (empty($email) || !filter_var($email, FILTER_VALIDATE_EMAIL)) { + error_log("❌ Email inválido para notificación: $email"); + return false; + } + + if (empty($datosSolicitud) || !isset($datosSolicitud['nuevo_status'])) { + error_log("❌ Datos de solicitud incompletos para notificación"); + return false; + } + + $mail = new PHPMailer(true); + + try { + // Configuración SMTP + $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->CharSet = 'UTF-8'; + + // Configuración del mensaje + $mail->setFrom('noreply@aduanasoft.com.mx', 'SIIH | AduanaSoft'); + $mail->addAddress($email); + $mail->isHTML(true); + + // Obtener descripción y emoji del status + $statusInfo = obtenerInfoStatus($datosSolicitud['nuevo_status']); + + // Personalizar subject si es correo adicional + $subjectPrefix = $esCorreoExtra ? '[COPIA] ' : ''; + $mail->Subject = $subjectPrefix . '📊 Cambio de Estado en Solicitud de Importación'; + + // Preparar datos para el template + $datosTemplate = prepararDatosTemplate($datosSolicitud, $nombreCompleto, $statusInfo, $esCorreoExtra); + + // Generar el HTML del email + $mail->Body = generarHtmlNotificacion($datosTemplate); + + // Enviar el email + $envioExitoso = $mail->send(); + + if ($envioExitoso) { + $tipoCorreo = $esCorreoExtra ? 'correo adicional' : 'correo principal'; + error_log("✅ Notificación de cambio de status enviada al $tipoCorreo: $email para solicitud ID: {$datosSolicitud['id_solicitud']}"); + return true; + } + + return false; + + } catch (Exception $e) { + $tipoCorreo = $esCorreoExtra ? 'correo adicional' : 'correo principal'; + error_log("❌ Error al enviar notificación de cambio de status al $tipoCorreo ($email): {$mail->ErrorInfo} | Exception: {$e->getMessage()}"); + return false; + } +} + +/** Obtiene información del status (descripción y emoji) **/ +function obtenerInfoStatus($status) { + $statusMap = [ + 1 => ['emoji' => '🔄', 'descripcion' => 'En proceso', 'color' => '#17a2b8'], + 2 => ['emoji' => '📋', 'descripcion' => 'Solicitar importación', 'color' => '#ffc107'], + 3 => ['emoji' => '🏢', 'descripcion' => 'Con agencia aduana', 'color' => '#6f42c1'], + 4 => ['emoji' => '💳', 'descripcion' => 'En proceso de pago', 'color' => '#fd7e14'], + 5 => ['emoji' => '✅', 'descripcion' => 'Pedimento generado', 'color' => '#28a745'], + 6 => ['emoji' => '📦', 'descripcion' => 'En tránsito', 'color' => '#007bff'], + 7 => ['emoji' => '🏁', 'descripcion' => 'Entregado', 'color' => '#28a745'], + 8 => ['emoji' => '❌', 'descripcion' => 'Cancelado', 'color' => '#dc3545'], + 9 => ['emoji' => '⏸️', 'descripcion' => 'Suspendido', 'color' => '#6c757d'] + ]; + + return $statusMap[$status] ?? [ + 'emoji' => '📝', + 'descripcion' => 'Estado actualizado', + 'color' => '#6c757d' + ]; +} + +/** Prepara los datos para el template del email **/ +function prepararDatosTemplate($datosSolicitud, $nombreCompleto, $statusInfo, $esCorreoExtra) { + return [ + 'nombreCompleto' => htmlspecialchars($nombreCompleto ?? 'Usuario'), + 'idSolicitud' => intval($datosSolicitud['id_solicitud'] ?? 0), + 'numeroFactura' => htmlspecialchars($datosSolicitud['numero_factura'] ?? 'N/A'), + 'fechaFactura' => htmlspecialchars($datosSolicitud['fecha_factura'] ?? 'N/A'), + 'valorFactura' => number_format(floatval($datosSolicitud['valor_factura'] ?? 0), 2), + 'tipoMoneda' => htmlspecialchars($datosSolicitud['tipo_moneda'] ?? 'USD'), + 'statusEmoji' => $statusInfo['emoji'], + 'statusDescripcion' => $statusInfo['descripcion'], + 'statusColor' => $statusInfo['color'], + 'esCorreoExtra' => $esCorreoExtra, + 'fechaActual' => date('Y-m-d H:i:s'), + 'anioActual' => date('Y') + ]; +} + +/** Genera el HTML para la notificación **/ +function generarHtmlNotificacion($datos) { + $tipoNotificacion = $datos['esCorreoExtra'] ? + '