Merge pull request 'integracion-dga' (#6) from integracion-dga into Desarrollo

Reviewed-on: #6

BLL/Recuperacion_DGA/EnvioDGA.cs

@@ -38,12 +38,16 @@ namespace BLL.Recuperacion_DGA
                 var logsEnviados = new List<LogMedicionEnvio>();
 
                 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.Any()){   break;  }
+                    if (mediciones == null || mediciones.Count == 0)
+                    {   
+                        break;  
+                    }
 
                     foreach (var medicion in mediciones)
                     {

DAL/LogEnvioRepository.cs

@@ -30,7 +30,7 @@ namespace DAL
                 await connection.ExecuteAsync(sql, log);
                 return true;
             }
-            catch (Exception ex)
+            catch (Exception)
             {
                 return false;
             }

DAL/MedicionDGARepository.cs

@@ -8,27 +8,16 @@ namespace DAL
 {
     public class MedicionDGARepository
     {
-        public async Task<List<DatoDGA>> ObtenerMedicionesAsync()
+        public async Task<List<DatoDGATemporal>> ObtenerMedicionesPorLoteAsync(int pageNumber, DateTime fecha)
         {
-            await using var connection = new SqlConnection(BdConexion.StringConnection);
+            var parameters = new DynamicParameters();
-
+            parameters.Add("@PageNumber", pageNumber);
-            var result = await connection.QueryAsync<DatoDGA>(
+            parameters.Add("@FechaInicio", fecha);
-                "SP_OBTENER_DGA_DATOS",
-                commandType: CommandType.StoredProcedure);
-
-            return result.ToList();
-        }
-
-        public async Task<List<DatoDGATemporal>> ObtenerMedicionesPorLoteAsync(int pageNumber)
-        {
-            var nroPagina = new DynamicParameters();
-            nroPagina.Add("@PageNumber", pageNumber);
-
             await using var connection = new SqlConnection(BdConexion.StringConnection);
 
             var resultado = await connection.QueryAsync<DatoDGATemporal>(
                 "SP_OBTENER_LOTE_DGA_DATOS",
-                nroPagina,
+                parameters,
                 commandType: CommandType.StoredProcedure);
 
             return resultado.ToList();

DAS/RegistrarMedicion.cs

@@ -28,7 +28,7 @@ namespace DAS
                 var timeStamp = DateTime.UtcNow.ToString("yyyy-MM-dd'T'HH:mm:ss-0000", CultureInfo.InvariantCulture);
                 var json = JsonSerializer.Serialize(request);
 
-                var req = new HttpRequestMessage(HttpMethod.Post, $"{SubterraneaApiUrl.BaseUrl}{SubterraneaApiUrl.EndPoint}SSSSS");
+                var req = new HttpRequestMessage(HttpMethod.Post, $"{SubterraneaApiUrl.BaseUrl}{SubterraneaApiUrl.EndPoint}");
                 req.Headers.Add("codigoObra", medicion.CODIGO_DGA);
                 req.Headers.Add("timeStampOrigen", timeStamp);
                 req.Content = new StringContent(json, Encoding.UTF8, "application/json");
@@ -55,7 +55,7 @@ namespace DAS
                     log.ESTADO_ENVIO = "ERROR";
                 }
 
-                log.COMPROBANTE = apiResponse.Data.NumeroComprobante ?? null;
+                log.COMPROBANTE = apiResponse!.Data!.NumeroComprobante ?? null;
                 log.ESTADO_ENVIO = "EXITO";
             }
             catch (Exception)

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; }
-
     }
 }