feat(Worker): Adaptación integral para la API de Elecciones Nacionales
Este commit refactoriza por completo el sistema de recolección de datos para asegurar la compatibilidad con la nueva API nacional, pasando de un modelo de distrito único a uno multi-distrito. Cambios principales: - **Refactorización de `SondearResumenProvincialAsync`:** - Se elimina la dependencia del endpoint obsoleto `/getResumen`. - El método ahora itera sobre todas las provincias (`NivelId=10`) y categorías, utilizando `GetResultadosAsync` para obtener los datos agregados. - **Expansión de `SondearResultadosMunicipalesAsync`:** - Se renombra a `SondearResultadosPorAmbitosAsync` para reflejar su nueva responsabilidad. - La lógica ahora sondea múltiples niveles jerárquicos (`NivelId` 10, 20, 30), capturando resultados detallados para Provincias, Secciones Electorales y Municipios. - **Modificación del Modelo de Datos:** - Se añade la columna `CategoriaId` a la entidad y tabla `ResumenVoto`. - Se crea la migración de base de datos `AddCategoriaIdToResumenVoto` para aplicar el cambio. - **Ajustes de Nulabilidad en API Service:** - Se actualizan las firmas de `GetResultadosAsync` en `IElectoralApiService` y `ElectoralApiService` para permitir que `seccionId` y `municipioId` sean nulables (`string?`), resolviendo errores de compilación CS8625. - **Deshabilitación de Seeders de Ejemplo:** - Se introduce una bandera `generarDatosDeEjemplo` en `Program.cs` de la API, establecida en `false`, para prevenir la ejecución de código de simulación en entornos de producción o pruebas.
This commit is contained in:
@@ -473,119 +473,89 @@ public class CriticalDataWorker : BackgroundService
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Obtiene y actualiza el resumen de votos y el estado del recuento a nivel provincial.
|
||||
/// Esta versión actualizada guarda tanto los votos por agrupación (en ResumenesVotos)
|
||||
/// como el estado general del recuento, incluyendo la fecha de totalización (en EstadosRecuentosGenerales),
|
||||
/// asegurando que toda la operación sea atómica mediante una transacción de base de datos.
|
||||
/// Obtiene y actualiza el resumen de votos y el estado del recuento a nivel provincial para CADA categoría.
|
||||
/// Este método itera sobre todas las provincias y categorías, obteniendo sus resultados consolidados
|
||||
/// y guardándolos en las tablas 'ResumenesVotos' y 'EstadosRecuentosGenerales'.
|
||||
/// </summary>
|
||||
/// <param name="authToken">El token de autenticación válido para la sesión.</param>
|
||||
/// <param name="stoppingToken">El token de cancelación para detener la operación.</param>
|
||||
private async Task SondearResumenProvincialAsync(string authToken, CancellationToken stoppingToken)
|
||||
{
|
||||
try
|
||||
{
|
||||
// Creamos un scope de DbContext para esta operación.
|
||||
_logger.LogInformation("Iniciando sondeo de Resúmenes Provinciales...");
|
||||
|
||||
using var scope = _serviceProvider.CreateScope();
|
||||
var dbContext = scope.ServiceProvider.GetRequiredService<EleccionesDbContext>();
|
||||
|
||||
// Obtenemos el registro de la Provincia (NivelId 10).
|
||||
var provincia = await dbContext.AmbitosGeograficos
|
||||
var provinciasASondear = await dbContext.AmbitosGeograficos
|
||||
.AsNoTracking()
|
||||
.FirstOrDefaultAsync(a => a.NivelId == 10, stoppingToken);
|
||||
.Where(a => a.NivelId == 10 && a.DistritoId != null)
|
||||
.ToListAsync(stoppingToken);
|
||||
|
||||
// Si no encontramos el ámbito de la provincia, no podemos continuar.
|
||||
if (provincia == null)
|
||||
var todasLasCategorias = await dbContext.CategoriasElectorales
|
||||
.AsNoTracking()
|
||||
.ToListAsync(stoppingToken);
|
||||
|
||||
if (!provinciasASondear.Any() || !todasLasCategorias.Any())
|
||||
{
|
||||
_logger.LogWarning("No se encontró el ámbito 'Provincia' (NivelId 10) para el sondeo de resumen.");
|
||||
_logger.LogWarning("No se encontraron Provincias o Categorías para sondear resúmenes.");
|
||||
return;
|
||||
}
|
||||
|
||||
// Llamamos a la API para obtener el resumen de datos provincial.
|
||||
var resumenDto = await _apiService.GetResumenAsync(authToken, provincia.DistritoId!);
|
||||
|
||||
// Solo procedemos si la API devolvió una respuesta válida y no nula.
|
||||
if (resumenDto != null)
|
||||
foreach (var provincia in provinciasASondear)
|
||||
{
|
||||
// Iniciamos una transacción explícita. Esto garantiza que todas las operaciones de base de datos
|
||||
// dentro de este bloque (el DELETE, los INSERTs y los UPDATEs) se completen con éxito,
|
||||
// o si algo falla, se reviertan todas, manteniendo la consistencia de los datos.
|
||||
await using var transaction = await dbContext.Database.BeginTransactionAsync(stoppingToken);
|
||||
if (stoppingToken.IsCancellationRequested) break;
|
||||
|
||||
// --- 1. ACTUALIZAR LA TABLA 'ResumenesVotos' ---
|
||||
|
||||
// Verificamos si la respuesta contiene una lista de votos positivos.
|
||||
if (resumenDto.ValoresTotalizadosPositivos is { Count: > 0 } nuevosVotos)
|
||||
{
|
||||
// Estrategia "Borrar y Reemplazar": vaciamos la tabla antes de insertar los nuevos datos.
|
||||
await dbContext.Database.ExecuteSqlRawAsync("DELETE FROM ResumenesVotos", stoppingToken);
|
||||
|
||||
// Añadimos cada nuevo registro de voto al DbContext.
|
||||
foreach (var voto in nuevosVotos)
|
||||
{
|
||||
dbContext.ResumenesVotos.Add(new ResumenVoto
|
||||
{
|
||||
AmbitoGeograficoId = provincia.Id,
|
||||
AgrupacionPoliticaId = voto.IdAgrupacion,
|
||||
Votos = voto.Votos,
|
||||
VotosPorcentaje = voto.VotosPorcentaje
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
// --- 2. ACTUALIZAR LA TABLA 'EstadosRecuentosGenerales' ---
|
||||
|
||||
// El endpoint de Resumen no especifica una categoría, por lo que aplicamos sus datos de estado de recuento
|
||||
// a todas las categorías que tenemos en nuestra base de datos.
|
||||
var todasLasCategorias = await dbContext.CategoriasElectorales.AsNoTracking().ToListAsync(stoppingToken);
|
||||
foreach (var categoria in todasLasCategorias)
|
||||
{
|
||||
// Buscamos el registro existente usando la clave primaria compuesta.
|
||||
var registroDb = await dbContext.EstadosRecuentosGenerales.FindAsync(new object[] { provincia.Id, categoria.Id }, stoppingToken);
|
||||
if (stoppingToken.IsCancellationRequested) break;
|
||||
|
||||
// Si no existe, lo creamos.
|
||||
if (registroDb == null)
|
||||
// Usamos GetResultados sin seccionId/municipioId para obtener el resumen del distrito.
|
||||
var resultadosDto = await _apiService.GetResultadosAsync(authToken, provincia.DistritoId!, null, null, categoria.Id);
|
||||
|
||||
if (resultadosDto?.ValoresTotalizadosPositivos is { Count: > 0 } nuevosVotos)
|
||||
{
|
||||
registroDb = new EstadoRecuentoGeneral { AmbitoGeograficoId = provincia.Id, CategoriaId = categoria.Id };
|
||||
dbContext.EstadosRecuentosGenerales.Add(registroDb);
|
||||
// Usamos una transacción para asegurar que el borrado y la inserción sean atómicos.
|
||||
await using var transaction = await dbContext.Database.BeginTransactionAsync(stoppingToken);
|
||||
|
||||
// A. Borrar los resúmenes viejos SOLO para esta provincia y categoría.
|
||||
await dbContext.ResumenesVotos
|
||||
.Where(rv => rv.AmbitoGeograficoId == provincia.Id && rv.CategoriaId == categoria.Id)
|
||||
.ExecuteDeleteAsync(stoppingToken);
|
||||
|
||||
// B. Añadir los nuevos resúmenes.
|
||||
foreach (var voto in nuevosVotos)
|
||||
{
|
||||
dbContext.ResumenesVotos.Add(new ResumenVoto
|
||||
{
|
||||
AmbitoGeograficoId = provincia.Id,
|
||||
CategoriaId = categoria.Id,
|
||||
AgrupacionPoliticaId = voto.IdAgrupacion,
|
||||
Votos = voto.Votos,
|
||||
VotosPorcentaje = voto.VotosPorcentaje
|
||||
});
|
||||
}
|
||||
|
||||
// C. Guardar los cambios en la tabla ResumenesVotos.
|
||||
await dbContext.SaveChangesAsync(stoppingToken);
|
||||
|
||||
// No es necesario actualizar EstadosRecuentosGenerales aquí,
|
||||
// ya que el método SondearEstadoRecuentoGeneralAsync se encarga de eso
|
||||
// de forma más específica y eficiente.
|
||||
|
||||
await transaction.CommitAsync(stoppingToken);
|
||||
}
|
||||
} // Fin bucle categorías
|
||||
} // Fin bucle provincias
|
||||
|
||||
// Parseamos la fecha de forma segura para evitar errores con cadenas vacías o nulas.
|
||||
if (DateTime.TryParse(resumenDto.FechaTotalizacion, out var parsedDate))
|
||||
{
|
||||
registroDb.FechaTotalizacion = parsedDate.ToUniversalTime();
|
||||
}
|
||||
|
||||
// Mapeamos el resto de los datos del estado del recuento.
|
||||
registroDb.MesasEsperadas = resumenDto.EstadoRecuento.MesasEsperadas;
|
||||
registroDb.MesasTotalizadas = resumenDto.EstadoRecuento.MesasTotalizadas;
|
||||
registroDb.MesasTotalizadasPorcentaje = resumenDto.EstadoRecuento.MesasTotalizadasPorcentaje;
|
||||
registroDb.CantidadElectores = resumenDto.EstadoRecuento.CantidadElectores;
|
||||
registroDb.CantidadVotantes = resumenDto.EstadoRecuento.CantidadVotantes;
|
||||
registroDb.ParticipacionPorcentaje = resumenDto.EstadoRecuento.ParticipacionPorcentaje;
|
||||
}
|
||||
|
||||
// 3. CONFIRMAR Y GUARDAR
|
||||
// Guardamos todos los cambios preparados (DELETEs, INSERTs, UPDATEs) en la base de datos.
|
||||
await dbContext.SaveChangesAsync(stoppingToken);
|
||||
// Confirmamos la transacción para hacer los cambios permanentes.
|
||||
await transaction.CommitAsync(stoppingToken);
|
||||
|
||||
_logger.LogInformation("Sondeo de Resumen Provincial completado. Las tablas han sido actualizadas.");
|
||||
}
|
||||
else
|
||||
{
|
||||
// Si la API no devolvió datos (ej. devuelve null), no hacemos nada en la BD.
|
||||
_logger.LogInformation("Sondeo de Resumen Provincial completado. No se recibieron datos nuevos.");
|
||||
}
|
||||
_logger.LogInformation("Sondeo de Resúmenes Provinciales completado.");
|
||||
}
|
||||
catch (OperationCanceledException)
|
||||
{
|
||||
_logger.LogInformation("Sondeo de resumen provincial cancelado.");
|
||||
_logger.LogInformation("Sondeo de resúmenes provinciales cancelado.");
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
// Capturamos cualquier otro error inesperado para que el worker no se detenga.
|
||||
_logger.LogError(ex, "Ocurrió un error CRÍTICO en el sondeo de Resumen Provincial.");
|
||||
_logger.LogError(ex, "Ocurrió un error CRÍTICO en el sondeo de Resúmenes Provinciales.");
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user