diff --git a/BLL/Recuperacion_DGA/EnvioDGA.cs b/BLL/Recuperacion_DGA/EnvioDGA.cs index f727b1d..b53695a 100644 --- a/BLL/Recuperacion_DGA/EnvioDGA.cs +++ b/BLL/Recuperacion_DGA/EnvioDGA.cs @@ -37,15 +37,16 @@ namespace BLL.Recuperacion_DGA var logsEnviado = new LogMedicionEnvio(); + var pageNumber = 1; var fechaInicio = DateTime.UtcNow; var cont = 1; while (true) { - var mediciones = await _dGAMedicionRepository.ObtenerMedicionesPorLoteAsync(1, fechaInicio); + var mediciones = await _dGAMedicionRepository.ObtenerMedicionesPorLoteAsync(pageNumber, fechaInicio); var totalMediciones = await _dGAMedicionRepository.ObtenerTotalMediciones(fechaInicio); if (mediciones == null || mediciones.Count == 0) - { - break; + { + break; } foreach (var medicion in mediciones) @@ -79,21 +80,28 @@ namespace BLL.Recuperacion_DGA await _logEnvioRepository.InsertarLogRespuesta(logsEnviado); - 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); + 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", ""); + ConsoleLoggerHelper.WriteLineAndLogEventoAsync("FIN","Fin proceso de recuperación DGA",""); } catch (Exception ex) { diff --git a/SHARED/Helper/FileLoggerHelper.cs b/SHARED/Helper/FileLoggerHelper.cs index afd78f5..720cbb1 100644 --- a/SHARED/Helper/FileLoggerHelper.cs +++ b/SHARED/Helper/FileLoggerHelper.cs @@ -8,26 +8,12 @@ namespace Shared.Helper { public static void ConfigureLogger(IConfiguration configuration) { - 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); - } + var logFilePath = configuration.GetSection("Logging:LogFile:Path").Value ?? ""; + var logFileFullPath = Path.Combine(Directory.GetCurrentDirectory(), logFilePath); Log.Logger = new LoggerConfiguration() .ReadFrom.Configuration(configuration) - .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}" - ) + .WriteTo.File(logFileFullPath, rollingInterval: RollingInterval.Day) .CreateLogger(); }