Integracion_DGA/BLL/Recuperacion_DGA/EnvioDGA.cs

using System;
using System.Text.Json;
using DAL;
using DAS;
using Shared.DTO;
using Shared.DTO.Envios_DGA;
using Shared.DTO.VariablesEntorno;
using Shared.Helper;

namespace BLL.Recuperacion_DGA
{
    public class EnvioDGA
    {
        private readonly MedicionDGARepository _dGAMedicionRepository;
        private readonly RegistrarMedicion _registrarMedicion;
        private readonly LogEnvioRepository _logEnvioRepository;

        public EnvioDGA(MedicionDGARepository dGAMedicionRepository, RegistrarMedicion registrarMedicion, LogEnvioRepository logEnvioRepository)
        {
            _dGAMedicionRepository = dGAMedicionRepository;
            _registrarMedicion = registrarMedicion;
            _logEnvioRepository = logEnvioRepository;
        }

        public async Task<bool> RegistrarMedicionesAsync()
        {
            try
            {
                await _logEnvioRepository.InsertarLogProcesoAsync(new LogProceso
                {
                    FechaEjecucion = DateTime.UtcNow,
                    NombreProceso = "ENVIO DATOS DGA"
                });

                ConsoleLoggerHelper.WriteLineAndLogEventoAsync("INICIO", "Inicio proceso de recuperación DGA", "");
                ConsoleLoggerHelper.WriteLineAndLogInfo("Obteniendo Mediciones Scada", ConsoleColor.Green);

                var logsEnviado = new LogMedicionEnvio();

                var pageNumber = 1;
                var fechaInicio = DateTime.UtcNow;
                var cont = 1;
                while (true)
                {
                    var mediciones = await _dGAMedicionRepository.ObtenerMedicionesPorLoteAsync(pageNumber, fechaInicio);
                    var totalMediciones = await _dGAMedicionRepository.ObtenerTotalMediciones(fechaInicio);
                    if (mediciones == null || mediciones.Count == 0)
                    {   
                        break;  
                    }

                    foreach (var medicion in mediciones)
                    {
                        try
                        {
                            var fechaEnvio = DateTime.UtcNow;

                            var body = new MedicionSubterraneaRequest
                            {
                                Autenticacion = new Autenticacion
                                {
                                    Password = medicion.Password ?? "",
                                    RutEmpresa = medicion.Empresa_Informante == "EV" ? CredencialDGA.RutEsval : CredencialDGA.RutAv,
                                    RutUsuario = medicion.RUT ?? ""
                                },
                                MedicionSubterranea = new Medicion
                                {
                                    Caudal = medicion.CAUDAL ?? "",
                                    FechaMedicion = medicion.FECHA_MEDICION_CAUDAL?.ToString("yyyy-MM-dd") ?? "",
                                    HoraMedicion = medicion.FECHA_MEDICION_CAUDAL?.ToString("HH:mm:ss") ?? "",
                                    NivelFreaticoDelPozo = medicion.NIVEL_FREATICO_DEL_POZO ?? "",
                                    Totalizador = medicion.TOTALIZADOR_CAUDAL ?? "",
                                }
                            };

                            ConsoleLoggerHelper.WriteLineAndLogInfo($"Enviando medición DGA {cont} - {totalMediciones}", ConsoleColor.Yellow);
                            var response = await _registrarMedicion.EnviarMedicionAsync(medicion, body, fechaEnvio);

                            logsEnviado = response;

                            await _logEnvioRepository.InsertarLogRespuesta(logsEnviado);

                            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","");
            }
            catch (Exception ex)
            {
                FileLoggerHelper.LogError($"[Error] {ex.Message}.", ex);
                ConsoleLoggerHelper.WriteLineAndLogInfo($"Error al procesar las mediciones.", ConsoleColor.Red);
                return false;
            }

            return true;
        }
    }
}