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

Compare commits

base: MarioRamirezC:36bd2ff4f329222d28490f28ec5f41509ef84b87
Branches Tags
MarioRamirezC:main
MarioRamirezC:Desarrollo
MarioRamirezC:integracion-dga
MarioRamirezC:fix-dga
MarioRamirezC:DEV-LT
MarioRamirezC:QA
..
compare: MarioRamirezC:d51d3e1f02b3c766573aac1450889c0f21c1d205
Branches Tags
MarioRamirezC:Desarrollo
MarioRamirezC:integracion-dga
MarioRamirezC:fix-dga
MarioRamirezC:DEV-LT
MarioRamirezC:main
MarioRamirezC:QA

No commits in common. "36bd2ff4f329222d28490f28ec5f41509ef84b87" and "d51d3e1f02b3c766573aac1450889c0f21c1d205" have entirely different histories.
36bd2ff4f3 ... d51d3e1f02

3 changed files with 91 additions and 199 deletions
Show stats Expand all files Collapse all files

167
BLL/Recuperacion_DGA/EnvioDGA.cs
View file

@ -21,11 +21,10 @@ namespace BLL.Recuperacion_DGA
public async Task<bool> RegistrarMedicionesAsync() public async Task<bool> RegistrarMedicionesAsync()
{ {
try WriteLineAndLog("Iniciando el proceso de recuperación DGA...");
{
await WriteLineAndLog("INICIO", "Inicio proceso de recuperación DGA", "");
WriteLineAndLog("Obteniendo Mediciones Scada", ConsoleColor.Green); WriteLineAndLog("Obteniendo Mediciones Scada", ConsoleColor.Green);
var mediciones = await _dGAMedicionScadaRepository.ObtenerMedicionesAsync(); var mediciones = await _dGAMedicionScadaRepository.ObtenerMedicionesAsync();
foreach (var medicion in mediciones) foreach (var medicion in mediciones)
{ {
try try
@ -46,31 +45,7 @@ namespace BLL.Recuperacion_DGA
rutEmpresa = CredencialDGA.RutEsval; rutEmpresa = CredencialDGA.RutEsval;
} }
List<string> vacios = new List<string>();
if (medicion.Caudal == null || medicion.Caudal.Equals(""))
{
vacios.Add("caudal");
}
if (medicion.DateOrigen == null)
{
vacios.Add("fecha origen");
}
if (medicion.nivelFreaticoDelPozo == null || medicion.nivelFreaticoDelPozo.ToString().Equals(""))
{
vacios.Add("nivel freatico");
}
if (medicion.Totalizador == null || medicion.Totalizador.Equals(""))
{
vacios.Add("totalizador");
}
if (vacios.Count > 0)
{
await FileLoggerHelper.InsertarLogsAsync("REGISTRAR", $"Medicion {medicion.Code} no registra {string.Join(", ", vacios)}","");
}
var body = new MedicionSubterraneaRequest var body = new MedicionSubterraneaRequest
{ {
@ -89,7 +64,7 @@ namespace BLL.Recuperacion_DGA
Totalizador = medicion.Totalizador.ToString() ?? "", Totalizador = medicion.Totalizador.ToString() ?? "",
} }
}; };
//await _registrarMedicion.EnviarMedicionAsync(medicion.Code, body, medicion.Id); await _registrarMedicion.EnviarMedicionAsync(medicion.Code, body, medicion.Id);
} }
} }
@ -99,90 +74,54 @@ namespace BLL.Recuperacion_DGA
WriteLineAndLog($"Error al enviar la medición con ID {medicion.Code}.", ConsoleColor.Red); WriteLineAndLog($"Error al enviar la medición con ID {medicion.Code}.", ConsoleColor.Red);
} }
} }
await WriteLineAndLog("FIN","Fin proceso de recuperación DGA","");
await WriteLineAndLog("INICIO", "Inicio proceso de recuperación DGA los Vilos", "VILOS"); //var medicionesVilos = await _dgaMedicionScadaVilosRepository.ObtenerMedicionesVilosAsync();
WriteLineAndLog("Obteniendo Mediciones Scada los Vilos", ConsoleColor.Green); //foreach (var medicionVilos in medicionesVilos)
var medicionesVilos = await _dgaMedicionScadaVilosRepository.ObtenerMedicionesVilosAsync(); //{
foreach (var medicionVilos in medicionesVilos) // try
{ // {
try // if (!string.IsNullOrEmpty(medicionVilos.Code))
{ // {
if (!string.IsNullOrEmpty(medicionVilos.Code)) // var rutEmpresa = string.Empty;
{
var rutEmpresa = string.Empty;
if (medicionVilos.tipo_empresa.Equals("AV")) // if (medicionVilos.tipo_empresa.Equals("AV"))
{ // {
rutEmpresa = CredencialDGA.RutAv; // rutEmpresa = CredencialDGA.RutAv;
} // }
else if (medicionVilos.tipo_empresa.Equals("EV")) // else if (medicionVilos.tipo_empresa.Equals("EV"))
{ // {
rutEmpresa = CredencialDGA.RutEsval; // rutEmpresa = CredencialDGA.RutEsval;
} // }
List<string> vacios = new List<string>(); // var body = new MedicionSubterraneaRequest
if (medicionVilos.Caudal == null || medicionVilos.Caudal.Equals("")) // {
{ // Autenticacion = new Autenticacion
vacios.Add("caudal"); // {
} // Password = CredencialDGA.Password,
// RutEmpresa = rutEmpresa,
if (medicionVilos.DateOrigen == null) // RutUsuario = CredencialDGA.RutUsuario
{ // },
vacios.Add("fecha origen"); // MedicionSubterranea = new Medicion
} // {
// Caudal = medicionVilos.Caudal.ToString() ?? "",
if (medicionVilos.nivelFreaticoDelPozo == null || medicionVilos.nivelFreaticoDelPozo.ToString().Equals("")) // FechaMedicion = medicionVilos.DateOrigen?.ToString("yyyy-MM-dd") ?? "",
{ // HoraMedicion = medicionVilos.DateOrigen?.ToString("HH:mm:ss") ?? "",
vacios.Add("nivel freatico"); // NivelFreaticoDelPozo = medicionVilos?.nivelFreaticoDelPozo.ToString() ?? "",
} // Totalizador = medicionVilos.Totalizador.ToString() ?? "",
// }
if (medicionVilos.Totalizador == null || medicionVilos.Totalizador.Equals("")) // };
{
vacios.Add("totalizador");
}
if (vacios.Count > 0)
{
await FileLoggerHelper.InsertarLogsAsync("REGISTRAR", $"Medicion {medicionVilos.Code} no registra {string.Join(", ", vacios)}", "VILOS");
}
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);
}
}
await WriteLineAndLog("FIN", "Fin proceso de recuperación DGA los Vilos", "VILOS");
}
catch (Exception ex)
{
FileLoggerHelper.LogError($"[Error] {ex.Message}.", ex);
WriteLineAndLog($"Error al procesar las mediciones.", ConsoleColor.Red);
return false;
}
return true; return true;
} }
@ -201,21 +140,5 @@ namespace BLL.Recuperacion_DGA
FileLoggerHelper.LogInformation($"{msj}"); FileLoggerHelper.LogInformation($"{msj}");
} }
static async Task WriteLineAndLog(string evento, string proceso, string operacion = null, ConsoleColor? color = null)
{
if (color.HasValue && Enum.IsDefined(typeof(ConsoleColor), color.Value))
{
Console.ForegroundColor = (ConsoleColor)color;
Console.WriteLine($"{proceso}");
Console.ResetColor();
}
else
{
Console.WriteLine($"{proceso}");
}
FileLoggerHelper.LogInformation($"{proceso}");
await FileLoggerHelper.InsertarLogsAsync(evento,proceso,operacion);
}
} }
} }

31
SHARED/Helper/FileLoggerHelper.cs
View file

@ -1,8 +1,5 @@
using Dapper; using Microsoft.Extensions.Configuration;
using Microsoft.Data.SqlClient;
using Microsoft.Extensions.Configuration;
using Serilog; using Serilog;
using Shared.DTO.VariablesEntorno;
namespace Shared.Helper namespace Shared.Helper
{ {
@ -28,31 +25,5 @@ namespace Shared.Helper
{ {
Log.Error(ex, message); Log.Error(ex, message);
} }
public static async Task<bool> InsertarLogsAsync(string evento, string proceso, string operacion)
{
try
{
using var connection = new SqlConnection(BdConexion.StringConnection);
await connection.OpenAsync();
string sql = @"INSERT INTO DGA_LOGS_REGISTROS_ENVIOS (evento, proceso, operacion)
VALUES (@evento, @proceso, @operacion)";
await connection.ExecuteAsync(sql, new
{
evento,
proceso,
operacion
});
return true;
}
catch (Exception e)
{
LogError("Error al insertar logs", e);
return false;
}
}
} }
} }

2
SHARED/Shared.csproj
View file

@ -7,8 +7,6 @@
</PropertyGroup> </PropertyGroup>
<ItemGroup> <ItemGroup>
<PackageReference Include="Dapper" Version="2.1.66" />
<PackageReference Include="Microsoft.Data.SqlClient" Version="6.0.2" />
<PackageReference Include="Microsoft.Extensions.Configuration" Version="9.0.6" /> <PackageReference Include="Microsoft.Extensions.Configuration" Version="9.0.6" />
<PackageReference Include="Serilog.Settings.Configuration" Version="9.0.0" /> <PackageReference Include="Serilog.Settings.Configuration" Version="9.0.0" />
<PackageReference Include="Serilog.Sinks.File" Version="7.0.0" /> <PackageReference Include="Serilog.Sinks.File" Version="7.0.0" />