MarioRamirezC/Integracion_DGA
1
0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

cambios logs

Browse source
This commit is contained in:
bcastrogallardo 2025-09-11 15:25:01 -03:00
parent f62bb133c5
commit ecafbdfa02
1 changed files with 66 additions and 104 deletions
Download patch file Download diff file Expand all files Collapse all files

168
BLL/Recuperacion_DGA/EnvioDGA.cs
View file

@ -24,121 +24,83 @@ namespace BLL.Recuperacion_DGA
public async Task<bool> RegistrarMedicionesAsync() public async Task<bool> RegistrarMedicionesAsync()
{ {
//try try
//{ {
// await _logEnvioRepository.InsertarLogProcesoAsync(new LogProceso await _logEnvioRepository.InsertarLogProcesoAsync(new LogProceso
// { {
// FechaEjecucion = DateTime.UtcNow, FechaEjecucion = DateTime.UtcNow,
// NombreProceso = "ENVIO DATOS DGA" NombreProceso = "ENVIO DATOS DGA"
// }); });
// ConsoleLoggerHelper.WriteLineAndLogEventoAsync("INICIO", "Inicio proceso de recuperación DGA", ""); ConsoleLoggerHelper.WriteLineAndLogEventoAsync("INICIO", "Inicio proceso de recuperación DGA", "");
// ConsoleLoggerHelper.WriteLineAndLogInfo("Obteniendo Mediciones Scada", ConsoleColor.Green); ConsoleLoggerHelper.WriteLineAndLogInfo("Obteniendo Mediciones Scada", ConsoleColor.Green);
// var logsEnviado = new LogMedicionEnvio(); var logsEnviado = new LogMedicionEnvio();
// var pageNumber = 1; var fechaInicio = DateTime.UtcNow;
// var fechaInicio = DateTime.UtcNow; var cont = 1;
// var cont = 1; while (true)
// while (true) {
// { var mediciones = await _dGAMedicionRepository.ObtenerMedicionesPorLoteAsync(1, fechaInicio);
// var mediciones = await _dGAMedicionRepository.ObtenerMedicionesPorLoteAsync(pageNumber, fechaInicio); var totalMediciones = await _dGAMedicionRepository.ObtenerTotalMediciones(fechaInicio);
// var totalMediciones = await _dGAMedicionRepository.ObtenerTotalMediciones(fechaInicio); if (mediciones == null || mediciones.Count == 0)
// if (mediciones == null || mediciones.Count == 0) {
// { break;
// break; }
// }
// foreach (var medicion in mediciones) foreach (var medicion in mediciones)
// { {
// try try
// { {
// var fechaEnvio = DateTime.UtcNow; var fechaEnvio = DateTime.UtcNow;
// var body = new MedicionSubterraneaRequest var body = new MedicionSubterraneaRequest
// { {
// Autenticacion = new Autenticacion Autenticacion = new Autenticacion
// { {
// Password = medicion.Password ?? "", Password = medicion.Password ?? "",
// RutEmpresa = medicion.Empresa_Informante == "EV" ? CredencialDGA.RutEsval : CredencialDGA.RutAv, RutEmpresa = medicion.Empresa_Informante == "EV" ? CredencialDGA.RutEsval : CredencialDGA.RutAv,
// RutUsuario = medicion.RUT ?? "" RutUsuario = medicion.RUT ?? ""
// }, },
// MedicionSubterranea = new Medicion MedicionSubterranea = new Medicion
// { {
// Caudal = medicion.CAUDAL ?? "", Caudal = medicion.CAUDAL ?? "",
// FechaMedicion = medicion.FECHA_MEDICION_CAUDAL?.ToString("yyyy-MM-dd") ?? "", FechaMedicion = medicion.FECHA_MEDICION_CAUDAL?.ToString("yyyy-MM-dd") ?? "",
// HoraMedicion = medicion.FECHA_MEDICION_CAUDAL?.ToString("HH:mm:ss") ?? "", HoraMedicion = medicion.FECHA_MEDICION_CAUDAL?.ToString("HH:mm:ss") ?? "",
// NivelFreaticoDelPozo = medicion.NIVEL_FREATICO_DEL_POZO ?? "", NivelFreaticoDelPozo = medicion.NIVEL_FREATICO_DEL_POZO ?? "",
// Totalizador = medicion.TOTALIZADOR_CAUDAL ?? "", Totalizador = medicion.TOTALIZADOR_CAUDAL ?? "",
// } }
// }; };
// ConsoleLoggerHelper.WriteLineAndLogInfo($"Enviando medición DGA {cont} - {totalMediciones}", ConsoleColor.Yellow); ConsoleLoggerHelper.WriteLineAndLogInfo($"Enviando medición DGA {cont} - {totalMediciones}", ConsoleColor.Yellow);
// var response = await _registrarMedicion.EnviarMedicionAsync(medicion, body, fechaEnvio); 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); ConsoleLoggerHelper.WriteLineAndLogInfo($"Estado medición enviada {logsEnviado.ESTADO_ENVIO ?? ""}", ConsoleColor.Yellow);
cont++;
}
catch (Exception ex)
{
ConsoleLoggerHelper.WriteLineAndLogInfo($"[Error]: medicion[{medicion.ID}], mensaje: {ex.Message}");
}
}
// cont++; mediciones.Clear();
}
// } ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN", "Fin proceso de recuperación DGA", "");
// catch (Exception ex) }
// { catch (Exception ex)
// ConsoleLoggerHelper.WriteLineAndLogInfo($"[Error]: medicion[{medicion.ID}], mensaje: {ex.Message}"); {
// } FileLoggerHelper.LogError($"[Error] {ex.Message}.", ex);
// } ConsoleLoggerHelper.WriteLineAndLogInfo($"Error al procesar las mediciones.", ConsoleColor.Red);
return false;
// 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", "");
return true; return true;
} }