diff --git a/BLL/Recuperacion_DGA/EnvioDGA.cs b/BLL/Recuperacion_DGA/EnvioDGA.cs index 351dc8e..7b8cbdc 100644 --- a/BLL/Recuperacion_DGA/EnvioDGA.cs +++ b/BLL/Recuperacion_DGA/EnvioDGA.cs @@ -38,10 +38,11 @@ namespace BLL.Recuperacion_DGA var logsEnviados = new List(); var pageNumber = 1; + var fechaInicio = DateTime.UtcNow; while (true) { - var mediciones = await _dGAMedicionRepository.ObtenerMedicionesPorLoteAsync(pageNumber); + var mediciones = await _dGAMedicionRepository.ObtenerMedicionesPorLoteAsync(pageNumber, fechaInicio); if (mediciones == null || mediciones.Count == 0) { diff --git a/DAL/MedicionDGARepository.cs b/DAL/MedicionDGARepository.cs index fa470f0..72ddb8d 100644 --- a/DAL/MedicionDGARepository.cs +++ b/DAL/MedicionDGARepository.cs @@ -8,27 +8,16 @@ namespace DAL { public class MedicionDGARepository { - public async Task> ObtenerMedicionesAsync() + public async Task> ObtenerMedicionesPorLoteAsync(int pageNumber, DateTime fecha) { - await using var connection = new SqlConnection(BdConexion.StringConnection); - - var result = await connection.QueryAsync( - "SP_OBTENER_DGA_DATOS", - commandType: CommandType.StoredProcedure); - - return result.ToList(); - } - - public async Task> ObtenerMedicionesPorLoteAsync(int pageNumber) - { - var nroPagina = new DynamicParameters(); - nroPagina.Add("@PageNumber", pageNumber); - + var parameters = new DynamicParameters(); + parameters.Add("@PageNumber", pageNumber); + parameters.Add("@FechaInicio", fecha); await using var connection = new SqlConnection(BdConexion.StringConnection); var resultado = await connection.QueryAsync( "SP_OBTENER_LOTE_DGA_DATOS", - nroPagina, + parameters, commandType: CommandType.StoredProcedure); return resultado.ToList(); diff --git a/SHARED/DTO/Envios_DGA/MedicionSubterraneaRequest.cs b/SHARED/DTO/Envios_DGA/MedicionSubterraneaRequest.cs index 001bb9e..7f9b2f2 100644 --- a/SHARED/DTO/Envios_DGA/MedicionSubterraneaRequest.cs +++ b/SHARED/DTO/Envios_DGA/MedicionSubterraneaRequest.cs @@ -20,7 +20,5 @@ public string? HoraMedicion { get; set; } public string? NivelFreaticoDelPozo { get; set; } public string? Totalizador { get; set; } - public string? TipoEmpresa { get; set; } - } }