From 016acced6e5889012f942139e1dfd11855faeb27 Mon Sep 17 00:00:00 2001 From: bcastrogallardo Date: Tue, 1 Jul 2025 15:43:03 -0400 Subject: [PATCH] fix logs y envio de registros --- BLL/Integracion_DGA/BusinessLogic.cs | 10 +-- BLL/Recuperacion_DGA/EnvioDGA.cs | 86 +++++++++++++------------- DAL/LogMedicionScadaRepository.cs | 5 +- DAS/RegistrarMedicion.cs | 6 +- Integracion_DGA/Program.cs | 1 + Recuperacion_DGA/Program.cs | 1 - SHARED/DTO/Envios_DGA/MedicionScada.cs | 1 + 7 files changed, 54 insertions(+), 56 deletions(-) diff --git a/BLL/Integracion_DGA/BusinessLogic.cs b/BLL/Integracion_DGA/BusinessLogic.cs index caecaa2..3f97a85 100644 --- a/BLL/Integracion_DGA/BusinessLogic.cs +++ b/BLL/Integracion_DGA/BusinessLogic.cs @@ -40,11 +40,11 @@ namespace BLL.Integracion_DGA { string apiUrlBase = NexusApiUrl.ApiUrl; Dictionary headers = new Dictionary - { - { "nexustoken", NexusApiUrl.ApiKey }, - { "nexusapiversion", NexusApiUrl.Version }, - { "accept", "application/json" } - }; + { + { "nexustoken", NexusApiUrl.ApiKey }, + { "nexusapiversion", NexusApiUrl.Version }, + { "accept", "application/json" } + }; WriteLineAndLog($"Obteniendo Documentos"); string apiUrlDocuments = apiUrlBase + "/api/Documents"; diff --git a/BLL/Recuperacion_DGA/EnvioDGA.cs b/BLL/Recuperacion_DGA/EnvioDGA.cs index 32d61ac..0aad658 100644 --- a/BLL/Recuperacion_DGA/EnvioDGA.cs +++ b/BLL/Recuperacion_DGA/EnvioDGA.cs @@ -60,7 +60,7 @@ namespace BLL.Recuperacion_DGA Caudal = medicion.Caudal.ToString() ?? "", FechaMedicion = medicion.DateOrigen?.ToString("yyyy-MM-dd") ?? "", HoraMedicion = medicion.DateOrigen?.ToString("HH:mm:ss") ?? "", - NivelFreaticoDelPozo = medicion.Nivel.ToString() ?? "", + NivelFreaticoDelPozo = medicion.nivelFreaticoDelPozo?.ToString() ?? "", Totalizador = medicion.Totalizador.ToString() ?? "", } }; @@ -75,52 +75,52 @@ namespace BLL.Recuperacion_DGA } } - var medicionesVilos = await _dgaMedicionScadaVilosRepository.ObtenerMedicionesVilosAsync(); - foreach (var medicionVilos in medicionesVilos) - { - try - { - if (!string.IsNullOrEmpty(medicionVilos.Code)) - { - var rutEmpresa = string.Empty; + //var medicionesVilos = await _dgaMedicionScadaVilosRepository.ObtenerMedicionesVilosAsync(); + //foreach (var medicionVilos in medicionesVilos) + //{ + // try + // { + // if (!string.IsNullOrEmpty(medicionVilos.Code)) + // { + // var rutEmpresa = string.Empty; - if (medicionVilos.tipo_empresa.Equals("AV")) - { - rutEmpresa = CredencialDGA.RutAv; - } - else if (medicionVilos.tipo_empresa.Equals("EV")) - { - rutEmpresa = CredencialDGA.RutEsval; - } + // if (medicionVilos.tipo_empresa.Equals("AV")) + // { + // rutEmpresa = CredencialDGA.RutAv; + // } + // else if (medicionVilos.tipo_empresa.Equals("EV")) + // { + // rutEmpresa = CredencialDGA.RutEsval; + // } - var body = new MedicionSubterraneaRequest - { - Autenticacion = new Autenticacion - { - Password = CredencialDGA.Password, - RutEmpresa = rutEmpresa, - RutUsuario = CredencialDGA.RutUsuario - }, - MedicionSubterranea = new Medicion - { - Caudal = medicionVilos.Caudal.ToString() ?? "", - FechaMedicion = medicionVilos.DateOrigen?.ToString("yyyy-MM-dd") ?? "", - HoraMedicion = medicionVilos.DateOrigen?.ToString("HH:mm:ss") ?? "", - NivelFreaticoDelPozo = medicionVilos.Nivel.ToString() ?? "", - Totalizador = medicionVilos.Totalizador.ToString() ?? "", - } - }; + // var body = new MedicionSubterraneaRequest + // { + // Autenticacion = new Autenticacion + // { + // Password = CredencialDGA.Password, + // RutEmpresa = rutEmpresa, + // RutUsuario = CredencialDGA.RutUsuario + // }, + // MedicionSubterranea = new Medicion + // { + // Caudal = medicionVilos.Caudal.ToString() ?? "", + // FechaMedicion = medicionVilos.DateOrigen?.ToString("yyyy-MM-dd") ?? "", + // HoraMedicion = medicionVilos.DateOrigen?.ToString("HH:mm:ss") ?? "", + // NivelFreaticoDelPozo = medicionVilos?.nivelFreaticoDelPozo.ToString() ?? "", + // Totalizador = medicionVilos.Totalizador.ToString() ?? "", + // } + // }; - await _registrarMedicion.EnviarMedicionAsync(medicionVilos.Code, body, medicionVilos.Id); - } + // await _registrarMedicion.EnviarMedicionAsync(medicionVilos.Code, body, medicionVilos.Id); + // } - } - catch (Exception ex) - { - FileLoggerHelper.LogError($"[Error] {ex.Message}.", ex); - WriteLineAndLog($"Error al enviar la medición vilos con ID {medicionVilos.Code}.", ConsoleColor.Red); - } - } + // } + // catch (Exception ex) + // { + // FileLoggerHelper.LogError($"[Error] {ex.Message}.", ex); + // WriteLineAndLog($"Error al enviar la medición vilos con ID {medicionVilos.Code}.", ConsoleColor.Red); + // } + //} return true; } diff --git a/DAL/LogMedicionScadaRepository.cs b/DAL/LogMedicionScadaRepository.cs index e7a67a0..548f83a 100644 --- a/DAL/LogMedicionScadaRepository.cs +++ b/DAL/LogMedicionScadaRepository.cs @@ -13,10 +13,7 @@ namespace DAL { using (var connection = new SqlConnection(BdConexion.StringConnection)) { - await connection.OpenAsync(); - - // Truncar la tabla antes de insertar - await connection.ExecuteAsync("TRUNCATE TABLE DGA_LOGS_OPERACION"); + await connection.OpenAsync(); // Insertar todos los datos de la lista usando Dapper var sql = @"INSERT INTO dbo.DGA_LOGS_OPERACION (estado_envio, json_enviado, json_recibido, comprobante, fecha_envio, id_medicion_smartscada_operacion) diff --git a/DAS/RegistrarMedicion.cs b/DAS/RegistrarMedicion.cs index 531c5fc..168998a 100644 --- a/DAS/RegistrarMedicion.cs +++ b/DAS/RegistrarMedicion.cs @@ -27,7 +27,7 @@ namespace DAS content.Headers.Add("codigoObra", codigoObra); content.Headers.Add("timeStampOrigen", timeStamp); - /*var response = await _httpClient.PostAsync($"{SubterraneaApiUrl.BaseUrl}{SubterraneaApiUrl.EndPoint}", content); + var response = await _httpClient.PostAsync($"{SubterraneaApiUrl.BaseUrl}{SubterraneaApiUrl.EndPoint}SSSSSSSSSSSSSSSSS", content); string jsonRecibido = await response.Content.ReadAsStringAsync(); string estado = response.IsSuccessStatusCode ? "OK" : "ERROR"; string comprobante = string.Empty; @@ -57,8 +57,8 @@ namespace DAS FechaEnvio = DateTime.UtcNow, IdMedicionSmartscadaOperacion = idMedicion }; - */ - //await _logMedicionScadaRepository.InsertarLogMedicionScadaAsync(logMedicionScada); + + await _logMedicionScadaRepository.InsertarLogMedicionScadaAsync(logMedicionScada); return true; } diff --git a/Integracion_DGA/Program.cs b/Integracion_DGA/Program.cs index 328d5ac..2117aa9 100644 --- a/Integracion_DGA/Program.cs +++ b/Integracion_DGA/Program.cs @@ -47,6 +47,7 @@ namespace Integracion_DGA services.AddScoped(); services.AddScoped(); services.AddScoped(); + services.AddScoped(); }) .Build(); diff --git a/Recuperacion_DGA/Program.cs b/Recuperacion_DGA/Program.cs index d8342f2..580a484 100644 --- a/Recuperacion_DGA/Program.cs +++ b/Recuperacion_DGA/Program.cs @@ -42,7 +42,6 @@ namespace Recuperacion_DGA services.AddScoped(); services.AddScoped(); services.AddHttpClient(); - services.AddScoped(); }) .Build(); diff --git a/SHARED/DTO/Envios_DGA/MedicionScada.cs b/SHARED/DTO/Envios_DGA/MedicionScada.cs index b26301a..4127a3f 100644 --- a/SHARED/DTO/Envios_DGA/MedicionScada.cs +++ b/SHARED/DTO/Envios_DGA/MedicionScada.cs @@ -22,5 +22,6 @@ public decimal? Nivel { get; set; } public string? tipo_empresa { get; set; } + public string? nivelFreaticoDelPozo { get; set; } } }