From f62bb133c55f3e1934b3bc51f3b4c7c2a0370e35 Mon Sep 17 00:00:00 2001 From: bcastrogallardo Date: Thu, 11 Sep 2025 13:05:43 -0300 Subject: [PATCH 1/2] prueba logs --- BLL/Recuperacion_DGA/EnvioDGA.cs | 172 ++++++++++++++++++------------ SHARED/Helper/FileLoggerHelper.cs | 20 +++- 2 files changed, 118 insertions(+), 74 deletions(-) diff --git a/BLL/Recuperacion_DGA/EnvioDGA.cs b/BLL/Recuperacion_DGA/EnvioDGA.cs index b53695a..df155c2 100644 --- a/BLL/Recuperacion_DGA/EnvioDGA.cs +++ b/BLL/Recuperacion_DGA/EnvioDGA.cs @@ -24,91 +24,121 @@ namespace BLL.Recuperacion_DGA public async Task RegistrarMedicionesAsync() { - try - { - await _logEnvioRepository.InsertarLogProcesoAsync(new LogProceso - { - FechaEjecucion = DateTime.UtcNow, - NombreProceso = "ENVIO DATOS DGA" - }); + //try + //{ + // await _logEnvioRepository.InsertarLogProcesoAsync(new LogProceso + // { + // FechaEjecucion = DateTime.UtcNow, + // NombreProceso = "ENVIO DATOS DGA" + // }); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("INICIO", "Inicio proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogInfo("Obteniendo Mediciones Scada", ConsoleColor.Green); + // ConsoleLoggerHelper.WriteLineAndLogEventoAsync("INICIO", "Inicio proceso de recuperación DGA", ""); + // ConsoleLoggerHelper.WriteLineAndLogInfo("Obteniendo Mediciones Scada", ConsoleColor.Green); - var logsEnviado = new LogMedicionEnvio(); + // var logsEnviado = new LogMedicionEnvio(); - var pageNumber = 1; - var fechaInicio = DateTime.UtcNow; - var cont = 1; - while (true) - { - var mediciones = await _dGAMedicionRepository.ObtenerMedicionesPorLoteAsync(pageNumber, fechaInicio); - var totalMediciones = await _dGAMedicionRepository.ObtenerTotalMediciones(fechaInicio); - if (mediciones == null || mediciones.Count == 0) - { - break; - } + // var pageNumber = 1; + // var fechaInicio = DateTime.UtcNow; + // var cont = 1; + // while (true) + // { + // var mediciones = await _dGAMedicionRepository.ObtenerMedicionesPorLoteAsync(pageNumber, fechaInicio); + // var totalMediciones = await _dGAMedicionRepository.ObtenerTotalMediciones(fechaInicio); + // if (mediciones == null || mediciones.Count == 0) + // { + // break; + // } - foreach (var medicion in mediciones) - { - try - { - var fechaEnvio = DateTime.UtcNow; + // foreach (var medicion in mediciones) + // { + // try + // { + // var fechaEnvio = DateTime.UtcNow; - var body = new MedicionSubterraneaRequest - { - Autenticacion = new Autenticacion - { - Password = medicion.Password ?? "", - RutEmpresa = medicion.Empresa_Informante == "EV" ? CredencialDGA.RutEsval : CredencialDGA.RutAv, - RutUsuario = medicion.RUT ?? "" - }, - MedicionSubterranea = new Medicion - { - Caudal = medicion.CAUDAL ?? "", - FechaMedicion = medicion.FECHA_MEDICION_CAUDAL?.ToString("yyyy-MM-dd") ?? "", - HoraMedicion = medicion.FECHA_MEDICION_CAUDAL?.ToString("HH:mm:ss") ?? "", - NivelFreaticoDelPozo = medicion.NIVEL_FREATICO_DEL_POZO ?? "", - Totalizador = medicion.TOTALIZADOR_CAUDAL ?? "", - } - }; + // var body = new MedicionSubterraneaRequest + // { + // Autenticacion = new Autenticacion + // { + // Password = medicion.Password ?? "", + // RutEmpresa = medicion.Empresa_Informante == "EV" ? CredencialDGA.RutEsval : CredencialDGA.RutAv, + // RutUsuario = medicion.RUT ?? "" + // }, + // MedicionSubterranea = new Medicion + // { + // Caudal = medicion.CAUDAL ?? "", + // FechaMedicion = medicion.FECHA_MEDICION_CAUDAL?.ToString("yyyy-MM-dd") ?? "", + // HoraMedicion = medicion.FECHA_MEDICION_CAUDAL?.ToString("HH:mm:ss") ?? "", + // NivelFreaticoDelPozo = medicion.NIVEL_FREATICO_DEL_POZO ?? "", + // Totalizador = medicion.TOTALIZADOR_CAUDAL ?? "", + // } + // }; - ConsoleLoggerHelper.WriteLineAndLogInfo($"Enviando medición DGA {cont} - {totalMediciones}", ConsoleColor.Yellow); - var response = await _registrarMedicion.EnviarMedicionAsync(medicion, body, fechaEnvio); + // ConsoleLoggerHelper.WriteLineAndLogInfo($"Enviando medición DGA {cont} - {totalMediciones}", ConsoleColor.Yellow); + // var response = await _registrarMedicion.EnviarMedicionAsync(medicion, body, fechaEnvio); - logsEnviado = response; + // logsEnviado = response; - await _logEnvioRepository.InsertarLogRespuesta(logsEnviado); + // await _logEnvioRepository.InsertarLogRespuesta(logsEnviado); - if (logsEnviado.ESTADO_ENVIO == "EXITO") - { - await _dGAMedicionRepository.GuardarMedicionesEnviadaAsync(medicion.ID); - } + // if (logsEnviado.ESTADO_ENVIO == "EXITO") + // { + // await _dGAMedicionRepository.GuardarMedicionesEnviadaAsync(medicion.ID); + // } - ConsoleLoggerHelper.WriteLineAndLogInfo($"Estado medición enviada {logsEnviado.ESTADO_ENVIO ?? ""}", ConsoleColor.Yellow); + // ConsoleLoggerHelper.WriteLineAndLogInfo($"Estado medición enviada {logsEnviado.ESTADO_ENVIO ?? ""}", ConsoleColor.Yellow); - cont++; + // cont++; - } - catch (Exception ex) - { - ConsoleLoggerHelper.WriteLineAndLogInfo($"[Error]: medicion[{medicion.ID}], mensaje: {ex.Message}"); - } - } - - mediciones.Clear(); - pageNumber++; + // } + // catch (Exception ex) + // { + // ConsoleLoggerHelper.WriteLineAndLogInfo($"[Error]: medicion[{medicion.ID}], mensaje: {ex.Message}"); + // } + // } - } + // mediciones.Clear(); + // pageNumber++; - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN","Fin proceso de recuperación DGA",""); - } - catch (Exception ex) - { - FileLoggerHelper.LogError($"[Error] {ex.Message}.", ex); - ConsoleLoggerHelper.WriteLineAndLogInfo($"Error al procesar las mediciones.", ConsoleColor.Red); - return false; - } + // } + + // ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN","Fin proceso de recuperación DGA",""); + //} + //catch (Exception ex) + //{ + // FileLoggerHelper.LogError($"[Error] {ex.Message}.", ex); + // ConsoleLoggerHelper.WriteLineAndLogInfo($"Error al procesar las mediciones.", ConsoleColor.Red); + // return false; + //} + + + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + await Task.Delay(5000); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + + await Task.Delay(5000); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + await Task.Delay(5000); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + await Task.Delay(5000); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); return true; } diff --git a/SHARED/Helper/FileLoggerHelper.cs b/SHARED/Helper/FileLoggerHelper.cs index 720cbb1..afd78f5 100644 --- a/SHARED/Helper/FileLoggerHelper.cs +++ b/SHARED/Helper/FileLoggerHelper.cs @@ -8,12 +8,26 @@ namespace Shared.Helper { public static void ConfigureLogger(IConfiguration configuration) { - var logFilePath = configuration.GetSection("Logging:LogFile:Path").Value ?? ""; - var logFileFullPath = Path.Combine(Directory.GetCurrentDirectory(), logFilePath); + var logFilePath = configuration.GetSection("Logging:LogFile:Path").Value ?? "logs/log-.txt"; + + var exePath = AppContext.BaseDirectory; + var logFileFullPath = Path.Combine(exePath, logFilePath); + + var logDirectory = Path.GetDirectoryName(logFileFullPath); + if (!string.IsNullOrEmpty(logDirectory)) + { + Directory.CreateDirectory(logDirectory); + } Log.Logger = new LoggerConfiguration() .ReadFrom.Configuration(configuration) - .WriteTo.File(logFileFullPath, rollingInterval: RollingInterval.Day) + .WriteTo.File( + path: logFileFullPath, + rollingInterval: RollingInterval.Day, + shared: true, + retainedFileCountLimit: 30, + outputTemplate: "{Timestamp:yyyy-MM-dd HH:mm:ss} [{Level:u3}] {Message:lj}{NewLine}{Exception}" + ) .CreateLogger(); } From ecafbdfa021f52335586a4b7342a3b1e570120b3 Mon Sep 17 00:00:00 2001 From: bcastrogallardo Date: Thu, 11 Sep 2025 15:25:01 -0300 Subject: [PATCH 2/2] cambios logs --- BLL/Recuperacion_DGA/EnvioDGA.cs | 170 ++++++++++++------------------- 1 file changed, 66 insertions(+), 104 deletions(-) diff --git a/BLL/Recuperacion_DGA/EnvioDGA.cs b/BLL/Recuperacion_DGA/EnvioDGA.cs index df155c2..f727b1d 100644 --- a/BLL/Recuperacion_DGA/EnvioDGA.cs +++ b/BLL/Recuperacion_DGA/EnvioDGA.cs @@ -24,121 +24,83 @@ namespace BLL.Recuperacion_DGA public async Task RegistrarMedicionesAsync() { - //try - //{ - // await _logEnvioRepository.InsertarLogProcesoAsync(new LogProceso - // { - // FechaEjecucion = DateTime.UtcNow, - // NombreProceso = "ENVIO DATOS DGA" - // }); + try + { + await _logEnvioRepository.InsertarLogProcesoAsync(new LogProceso + { + FechaEjecucion = DateTime.UtcNow, + NombreProceso = "ENVIO DATOS DGA" + }); - // ConsoleLoggerHelper.WriteLineAndLogEventoAsync("INICIO", "Inicio proceso de recuperación DGA", ""); - // ConsoleLoggerHelper.WriteLineAndLogInfo("Obteniendo Mediciones Scada", ConsoleColor.Green); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("INICIO", "Inicio proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogInfo("Obteniendo Mediciones Scada", ConsoleColor.Green); - // var logsEnviado = new LogMedicionEnvio(); + var logsEnviado = new LogMedicionEnvio(); - // var pageNumber = 1; - // var fechaInicio = DateTime.UtcNow; - // var cont = 1; - // while (true) - // { - // var mediciones = await _dGAMedicionRepository.ObtenerMedicionesPorLoteAsync(pageNumber, fechaInicio); - // var totalMediciones = await _dGAMedicionRepository.ObtenerTotalMediciones(fechaInicio); - // if (mediciones == null || mediciones.Count == 0) - // { - // break; - // } + var fechaInicio = DateTime.UtcNow; + var cont = 1; + while (true) + { + var mediciones = await _dGAMedicionRepository.ObtenerMedicionesPorLoteAsync(1, fechaInicio); + var totalMediciones = await _dGAMedicionRepository.ObtenerTotalMediciones(fechaInicio); + if (mediciones == null || mediciones.Count == 0) + { + break; + } - // foreach (var medicion in mediciones) - // { - // try - // { - // var fechaEnvio = DateTime.UtcNow; + foreach (var medicion in mediciones) + { + try + { + var fechaEnvio = DateTime.UtcNow; - // var body = new MedicionSubterraneaRequest - // { - // Autenticacion = new Autenticacion - // { - // Password = medicion.Password ?? "", - // RutEmpresa = medicion.Empresa_Informante == "EV" ? CredencialDGA.RutEsval : CredencialDGA.RutAv, - // RutUsuario = medicion.RUT ?? "" - // }, - // MedicionSubterranea = new Medicion - // { - // Caudal = medicion.CAUDAL ?? "", - // FechaMedicion = medicion.FECHA_MEDICION_CAUDAL?.ToString("yyyy-MM-dd") ?? "", - // HoraMedicion = medicion.FECHA_MEDICION_CAUDAL?.ToString("HH:mm:ss") ?? "", - // NivelFreaticoDelPozo = medicion.NIVEL_FREATICO_DEL_POZO ?? "", - // Totalizador = medicion.TOTALIZADOR_CAUDAL ?? "", - // } - // }; + var body = new MedicionSubterraneaRequest + { + Autenticacion = new Autenticacion + { + Password = medicion.Password ?? "", + RutEmpresa = medicion.Empresa_Informante == "EV" ? CredencialDGA.RutEsval : CredencialDGA.RutAv, + RutUsuario = medicion.RUT ?? "" + }, + MedicionSubterranea = new Medicion + { + Caudal = medicion.CAUDAL ?? "", + FechaMedicion = medicion.FECHA_MEDICION_CAUDAL?.ToString("yyyy-MM-dd") ?? "", + HoraMedicion = medicion.FECHA_MEDICION_CAUDAL?.ToString("HH:mm:ss") ?? "", + NivelFreaticoDelPozo = medicion.NIVEL_FREATICO_DEL_POZO ?? "", + Totalizador = medicion.TOTALIZADOR_CAUDAL ?? "", + } + }; - // ConsoleLoggerHelper.WriteLineAndLogInfo($"Enviando medición DGA {cont} - {totalMediciones}", ConsoleColor.Yellow); - // var response = await _registrarMedicion.EnviarMedicionAsync(medicion, body, fechaEnvio); + ConsoleLoggerHelper.WriteLineAndLogInfo($"Enviando medición DGA {cont} - {totalMediciones}", ConsoleColor.Yellow); + var response = await _registrarMedicion.EnviarMedicionAsync(medicion, body, fechaEnvio); - // logsEnviado = response; + logsEnviado = response; - // await _logEnvioRepository.InsertarLogRespuesta(logsEnviado); + await _logEnvioRepository.InsertarLogRespuesta(logsEnviado); - // if (logsEnviado.ESTADO_ENVIO == "EXITO") - // { - // await _dGAMedicionRepository.GuardarMedicionesEnviadaAsync(medicion.ID); - // } + await _dGAMedicionRepository.GuardarMedicionesEnviadaAsync(medicion.ID); + + ConsoleLoggerHelper.WriteLineAndLogInfo($"Estado medición enviada {logsEnviado.ESTADO_ENVIO ?? ""}", ConsoleColor.Yellow); + cont++; + } + catch (Exception ex) + { + ConsoleLoggerHelper.WriteLineAndLogInfo($"[Error]: medicion[{medicion.ID}], mensaje: {ex.Message}"); + } + } - // ConsoleLoggerHelper.WriteLineAndLogInfo($"Estado medición enviada {logsEnviado.ESTADO_ENVIO ?? ""}", ConsoleColor.Yellow); + mediciones.Clear(); + } - // cont++; - - // } - // catch (Exception ex) - // { - // ConsoleLoggerHelper.WriteLineAndLogInfo($"[Error]: medicion[{medicion.ID}], mensaje: {ex.Message}"); - // } - // } - - // mediciones.Clear(); - // pageNumber++; - - // } - - // ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN","Fin proceso de recuperación DGA",""); - //} - //catch (Exception ex) - //{ - // FileLoggerHelper.LogError($"[Error] {ex.Message}.", ex); - // ConsoleLoggerHelper.WriteLineAndLogInfo($"Error al procesar las mediciones.", ConsoleColor.Red); - // return false; - //} - - - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - await Task.Delay(5000); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - - await Task.Delay(5000); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - await Task.Delay(5000); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - await Task.Delay(5000); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); - ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", ""); + } + catch (Exception ex) + { + FileLoggerHelper.LogError($"[Error] {ex.Message}.", ex); + ConsoleLoggerHelper.WriteLineAndLogInfo($"Error al procesar las mediciones.", ConsoleColor.Red); + return false; + } return true; }