BLL/Recuperacion_DGA/EnvioDGA.cs

@@ -38,16 +38,12 @@ namespace BLL.Recuperacion_DGA
                 var logsEnviados = new List<LogMedicionEnvio>();
 
                 var pageNumber = 1;
-                var fechaInicio = DateTime.UtcNow;
 
                 while (true)
                 {
-                    var mediciones = await _dGAMedicionRepository.ObtenerMedicionesPorLoteAsync(pageNumber, fechaInicio);
+                    var mediciones = await _dGAMedicionRepository.ObtenerMedicionesPorLoteAsync(pageNumber);
 
-                    if (mediciones == null || mediciones.Count == 0)
+                    if (mediciones == null || !mediciones.Any()){   break;  }
-                    {   
-                        break;  
-                    }
 
                     foreach (var medicion in mediciones)
                     {

DAL/LogEnvioRepository.cs

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

DAL/MedicionDGARepository.cs

@@ -8,16 +8,27 @@ namespace DAL
 {
     public class MedicionDGARepository
     {
-        public async Task<List<DatoDGATemporal>> ObtenerMedicionesPorLoteAsync(int pageNumber, DateTime fecha)
+        public async Task<List<DatoDGA>> ObtenerMedicionesAsync()
         {
-            var parameters = new DynamicParameters();
+            await using var connection = new SqlConnection(BdConexion.StringConnection);
-            parameters.Add("@PageNumber", pageNumber);
+
-            parameters.Add("@FechaInicio", fecha);
+            var result = await connection.QueryAsync<DatoDGA>(
+                "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",
-                parameters,
+                nroPagina,
                 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}");
+                var req = new HttpRequestMessage(HttpMethod.Post, $"{SubterraneaApiUrl.BaseUrl}{SubterraneaApiUrl.EndPoint}SSSSS");
                 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,5 +20,7 @@
         public string? HoraMedicion { get; set; }
         public string? NivelFreaticoDelPozo { get; set; }
         public string? Totalizador { get; set; }
+        public string? TipoEmpresa { get; set; }
+
     }
 }