From ecafbdfa021f52335586a4b7342a3b1e570120b3 Mon Sep 17 00:00:00 2001 From: bcastrogallardo Date: Thu, 11 Sep 2025 15:25:01 -0300 Subject: [PATCH] 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; }