| | | 1 | | using FAU.DataAccess.Repositories; |
| | | 2 | | using FAU.Entidades; |
| | | 3 | | using FAU.Logica.DTOs; |
| | | 4 | | using Microsoft.Extensions.Logging; |
| | | 5 | | |
| | | 6 | | namespace FAU.Logica.Services; |
| | | 7 | | |
| | | 8 | | public class CompensacionService : ICompensacionService |
| | | 9 | | { |
| | 1 | 10 | | private static readonly HashSet<string> UnidadesValidas = new(StringComparer.Ordinal) { "dia", "hora", "monto" }; |
| | 1 | 11 | | private static readonly HashSet<string> FormulasValidas = new(StringComparer.Ordinal) { "fijo", "tabla", "prorrateo" |
| | | 12 | | // Estados válidos para lotes |
| | 1 | 13 | | private static readonly HashSet<string> EstadosLoteValidos = new(StringComparer.Ordinal) { "borrador", "validado", " |
| | | 14 | | // Estados que permiten editar ítems (agregar/modificar/eliminar) |
| | | 15 | | // Cualquier edición en un lote 'validado' lo regresa automáticamente a 'borrador' |
| | 1 | 16 | | private static readonly HashSet<string> EstadosEditablesLote = new(StringComparer.Ordinal) { "borrador", "validado" |
| | | 17 | | |
| | | 18 | | private readonly ICompensacionRepository _repo; |
| | | 19 | | private readonly IPersonalRepository _personalRepo; |
| | | 20 | | private readonly ILogger<CompensacionService> _logger; |
| | | 21 | | |
| | 92 | 22 | | public CompensacionService( |
| | 92 | 23 | | ICompensacionRepository repo, |
| | 92 | 24 | | IPersonalRepository personalRepo, |
| | 92 | 25 | | ILogger<CompensacionService> logger) |
| | | 26 | | { |
| | 92 | 27 | | _repo = repo; |
| | 92 | 28 | | _personalRepo = personalRepo; |
| | 92 | 29 | | _logger = logger; |
| | 92 | 30 | | } |
| | | 31 | | |
| | | 32 | | // ── Tipos ──────────────────────────────────────────────────────────────── |
| | | 33 | | |
| | | 34 | | public async Task<IEnumerable<TipoCompensacionDto>> GetTiposAsync(bool? vigente = null) |
| | | 35 | | { |
| | 2 | 36 | | var tipos = await _repo.GetTiposAsync(vigente); |
| | 2 | 37 | | return tipos.Select(MapTipoToDto); |
| | 2 | 38 | | } |
| | | 39 | | |
| | | 40 | | public async Task<TipoCompensacionDto?> GetTipoByIdAsync(long id) |
| | | 41 | | { |
| | 2 | 42 | | var tipo = await _repo.GetTipoByIdAsync(id); |
| | 2 | 43 | | return tipo == null ? null : MapTipoToDto(tipo); |
| | 2 | 44 | | } |
| | | 45 | | |
| | | 46 | | public async Task<(bool Success, TipoCompensacion? Tipo, string? Error)> CreateTipoAsync(CreateTipoCompensacionReque |
| | | 47 | | { |
| | 4 | 48 | | if (string.IsNullOrWhiteSpace(request.Codigo)) |
| | 1 | 49 | | return (false, null, "codigo es obligatorio"); |
| | | 50 | | |
| | 3 | 51 | | if (!UnidadesValidas.Contains(request.UnidadMedida)) |
| | 1 | 52 | | return (false, null, $"unidad_medida inválida. Valores aceptados: {string.Join(", ", UnidadesValidas)}"); |
| | | 53 | | |
| | 2 | 54 | | if (await _repo.GetTipoByCodigoAsync(request.Codigo) != null) |
| | 1 | 55 | | return (false, null, $"Ya existe un tipo de compensación con código '{request.Codigo}'"); |
| | | 56 | | |
| | 1 | 57 | | var tipo = new TipoCompensacion |
| | 1 | 58 | | { |
| | 1 | 59 | | Codigo = request.Codigo.Trim().ToUpper(), |
| | 1 | 60 | | Nombre = request.Nombre, |
| | 1 | 61 | | UnidadMedida = request.UnidadMedida, |
| | 1 | 62 | | RequiereFuente = request.RequiereFuente, |
| | 1 | 63 | | Vigente = true |
| | 1 | 64 | | }; |
| | | 65 | | |
| | 1 | 66 | | var creado = await _repo.CreateTipoAsync(tipo); |
| | 1 | 67 | | _logger.LogInformation("Tipo compensación {Codigo} creado", creado.Codigo); |
| | 1 | 68 | | return (true, creado, null); |
| | 4 | 69 | | } |
| | | 70 | | |
| | | 71 | | public async Task<(bool Success, TipoCompensacion? Tipo, string? Error)> UpdateTipoAsync(long id, UpdateTipoCompensa |
| | | 72 | | { |
| | 3 | 73 | | var tipo = await _repo.GetTipoByIdAsync(id); |
| | 4 | 74 | | if (tipo == null) return (false, null, "Tipo de compensación no encontrado"); |
| | | 75 | | |
| | 4 | 76 | | if (request.Nombre != null) tipo.Nombre = request.Nombre; |
| | 3 | 77 | | if (request.RequiereFuente.HasValue) tipo.RequiereFuente = request.RequiereFuente.Value; |
| | 3 | 78 | | if (request.Vigente.HasValue) tipo.Vigente = request.Vigente.Value; |
| | | 79 | | |
| | 2 | 80 | | var actualizado = await _repo.UpdateTipoAsync(tipo); |
| | 2 | 81 | | return (true, actualizado, null); |
| | 3 | 82 | | } |
| | | 83 | | |
| | | 84 | | public async Task<(bool Success, string? Error)> DeleteTipoAsync(long id) |
| | | 85 | | { |
| | 4 | 86 | | var tipo = await _repo.GetTipoByIdAsync(id); |
| | 5 | 87 | | if (tipo == null) return (false, "Tipo de compensación no encontrado"); |
| | | 88 | | |
| | | 89 | | // Verificar si tiene configuraciones asociadas |
| | 3 | 90 | | if (await _repo.TieneConfiguracionesAsync(id)) |
| | 1 | 91 | | return (false, "No se puede eliminar el tipo porque tiene configuraciones asociadas. Desactive las configura |
| | | 92 | | |
| | | 93 | | // Verificar si tiene lotes asociados |
| | 2 | 94 | | if (await _repo.TieneLotesAsync(id)) |
| | 1 | 95 | | return (false, "No se puede eliminar el tipo porque tiene lotes asociados. Elimine los lotes primero."); |
| | | 96 | | |
| | 1 | 97 | | await _repo.DeleteTipoAsync(id); |
| | 1 | 98 | | _logger.LogInformation("Tipo compensación {Id} eliminado", id); |
| | 1 | 99 | | return (true, null); |
| | 4 | 100 | | } |
| | | 101 | | |
| | | 102 | | // ── Configs ────────────────────────────────────────────────────────────── |
| | | 103 | | |
| | | 104 | | public async Task<IEnumerable<ConfigCompensacionDto>> GetConfigsAsync( |
| | | 105 | | long? tipoId = null, long? regimenId = null, long? gradoId = null, bool? activo = null) |
| | | 106 | | { |
| | 3 | 107 | | var configs = await _repo.GetConfigsAsync(tipoId, regimenId, gradoId, activo); |
| | 3 | 108 | | return configs.Select(MapConfigToDto); |
| | 3 | 109 | | } |
| | | 110 | | |
| | | 111 | | public async Task<ConfigCompensacionDto?> GetConfigByIdAsync(long id) |
| | | 112 | | { |
| | 2 | 113 | | var config = await _repo.GetConfigByIdAsync(id); |
| | 2 | 114 | | return config == null ? null : MapConfigToDto(config); |
| | 2 | 115 | | } |
| | | 116 | | |
| | | 117 | | public async Task<(bool Success, ConfigCompensacion? Config, string? Error)> CreateConfigAsync(CreateConfigCompensac |
| | | 118 | | { |
| | 5 | 119 | | var validacion = ValidarFormula(request.Formula, request.Monto, request.ValorPorUnidad, request.ValorMinimo, req |
| | 8 | 120 | | if (validacion != null) return (false, null, validacion); |
| | | 121 | | |
| | 2 | 122 | | var tipo = await _repo.GetTipoByIdAsync(request.TipoCompensacionId); |
| | 3 | 123 | | if (tipo == null) return (false, null, "No se encontró el tipo de compensación indicado"); |
| | | 124 | | |
| | | 125 | | // Desactivar configs anteriores: solo puede haber una activa por tipo |
| | 1 | 126 | | await _repo.DesactivarConfigsActivasAsync(request.TipoCompensacionId); |
| | | 127 | | |
| | 1 | 128 | | var config = new ConfigCompensacion |
| | 1 | 129 | | { |
| | 1 | 130 | | TipoCompensacionId = request.TipoCompensacionId, |
| | 1 | 131 | | RegimenId = request.RegimenId, |
| | 1 | 132 | | GradoId = request.GradoId, |
| | 1 | 133 | | EscalafonId = request.EscalafonId, |
| | 1 | 134 | | Funcion = request.Funcion, |
| | 1 | 135 | | UnidadMedida = request.UnidadMedida, |
| | 1 | 136 | | Formula = request.Formula, |
| | 1 | 137 | | ValorPorUnidad = request.ValorPorUnidad, |
| | 1 | 138 | | Monto = request.Monto, |
| | 1 | 139 | | Tope = request.Tope, |
| | 1 | 140 | | TopeUnidades = request.TopeUnidades, |
| | 1 | 141 | | ValorMinimo = request.ValorMinimo, |
| | 1 | 142 | | ValorMaximo = request.ValorMaximo, |
| | 1 | 143 | | VigenteDesde = request.VigenteDesde, |
| | 1 | 144 | | VigenteHasta = request.VigenteHasta, |
| | 1 | 145 | | SujetoDescLegales = request.SujetoDescLegales, |
| | 1 | 146 | | CatalogoItemId = request.CatalogoItemId, |
| | 1 | 147 | | Activo = true |
| | 1 | 148 | | }; |
| | | 149 | | |
| | 1 | 150 | | var creada = await _repo.CreateConfigAsync(config); |
| | 1 | 151 | | return (true, creada, null); |
| | 5 | 152 | | } |
| | | 153 | | |
| | | 154 | | public async Task<(bool Success, ConfigCompensacion? Config, string? Error)> UpdateConfigAsync(long id, UpdateConfig |
| | | 155 | | { |
| | 4 | 156 | | var config = await _repo.GetConfigByIdAsync(id); |
| | 5 | 157 | | if (config == null) return (false, null, "Configuración no encontrada"); |
| | | 158 | | |
| | 3 | 159 | | var monto = request.Monto ?? config.Monto; |
| | 3 | 160 | | var valorPorUnidad = request.ValorPorUnidad ?? config.ValorPorUnidad; |
| | 3 | 161 | | var valorMinimo = request.ValorMinimo ?? config.ValorMinimo; |
| | 3 | 162 | | var valorMaximo = request.ValorMaximo ?? config.ValorMaximo; |
| | 3 | 163 | | var topeUnidades = request.TopeUnidades ?? config.TopeUnidades; |
| | | 164 | | |
| | 3 | 165 | | var validacion = ValidarFormula(config.Formula, monto, valorPorUnidad, valorMinimo, valorMaximo, topeUnidades); |
| | 3 | 166 | | if (validacion != null) return (false, null, validacion); |
| | | 167 | | |
| | 3 | 168 | | if (request.ValorPorUnidad.HasValue) config.ValorPorUnidad = request.ValorPorUnidad; |
| | 3 | 169 | | if (request.Monto.HasValue) config.Monto = request.Monto; |
| | 3 | 170 | | if (request.Tope.HasValue) config.Tope = request.Tope; |
| | 3 | 171 | | if (request.TopeUnidades.HasValue) config.TopeUnidades = request.TopeUnidades; |
| | 3 | 172 | | if (request.ValorMinimo.HasValue) config.ValorMinimo = request.ValorMinimo; |
| | 3 | 173 | | if (request.ValorMaximo.HasValue) config.ValorMaximo = request.ValorMaximo; |
| | 3 | 174 | | if (request.VigenteHasta.HasValue) config.VigenteHasta = request.VigenteHasta; |
| | 4 | 175 | | if (request.SujetoDescLegales.HasValue) config.SujetoDescLegales = request.SujetoDescLegales.Value; |
| | 4 | 176 | | if (request.CatalogoItemId.HasValue) config.CatalogoItemId = request.CatalogoItemId; |
| | 3 | 177 | | if (request.Activo.HasValue) |
| | | 178 | | { |
| | 2 | 179 | | if (!request.Activo.Value && config.Activo && await _repo.EsUnicaConfigActivaAsync(id, config.TipoCompensaci |
| | 1 | 180 | | return (false, null, "No se puede desactivar la única configuración activa del tipo. Cree otra antes de |
| | | 181 | | |
| | | 182 | | // Si se activa una config inactiva, desactivar las demás del mismo tipo |
| | 1 | 183 | | if (request.Activo.Value && !config.Activo) |
| | 1 | 184 | | await _repo.DesactivarConfigsActivasAsync(config.TipoCompensacionId); |
| | 1 | 185 | | config.Activo = request.Activo.Value; |
| | | 186 | | } |
| | | 187 | | |
| | 2 | 188 | | var actualizada = await _repo.UpdateConfigAsync(config); |
| | 2 | 189 | | return (true, actualizada, null); |
| | 4 | 190 | | } |
| | | 191 | | |
| | | 192 | | public async Task<(bool Success, string? Error)> DeleteConfigAsync(long id) |
| | | 193 | | { |
| | 4 | 194 | | var config = await _repo.GetConfigByIdAsync(id); |
| | 5 | 195 | | if (config == null) return (false, "Configuración no encontrada"); |
| | | 196 | | |
| | 3 | 197 | | if (config.Activo && await _repo.EsUnicaConfigActivaAsync(id, config.TipoCompensacionId)) |
| | 1 | 198 | | return (false, "No se puede eliminar la única configuración activa del tipo. Cree otra antes de eliminar est |
| | | 199 | | |
| | 2 | 200 | | await _repo.DeleteConfigAsync(id); |
| | 2 | 201 | | _logger.LogInformation("Configuración compensación {Id} eliminada", id); |
| | 2 | 202 | | return (true, null); |
| | 4 | 203 | | } |
| | | 204 | | |
| | | 205 | | // ── Lotes ──────────────────────────────────────────────────────────────── |
| | | 206 | | |
| | | 207 | | public async Task<PagedResult<LoteCompensacionDto>> GetLotesPagedAsync( |
| | | 208 | | int page, int pageSize, long? tipoId = null, int? anio = null, int? mes = null, string? estado = null) |
| | | 209 | | { |
| | 0 | 210 | | var (items, totalCount) = await _repo.GetLotesPagedAsync(page, pageSize, tipoId, anio, mes, estado); |
| | 0 | 211 | | return new PagedResult<LoteCompensacionDto> |
| | 0 | 212 | | { |
| | 0 | 213 | | Items = items.Select(MapLoteToDto), |
| | 0 | 214 | | Page = page, |
| | 0 | 215 | | PageSize = pageSize, |
| | 0 | 216 | | TotalCount = totalCount |
| | 0 | 217 | | }; |
| | 0 | 218 | | } |
| | | 219 | | |
| | | 220 | | public async Task<LoteCompensacionDto?> GetLoteByIdAsync(long id) |
| | | 221 | | { |
| | 0 | 222 | | var lote = await _repo.GetLoteByIdWithItemsAsync(id); |
| | 0 | 223 | | return lote == null ? null : MapLoteToDto(lote); |
| | 0 | 224 | | } |
| | | 225 | | |
| | | 226 | | public async Task<(bool Success, LoteCompensacion? Lote, string? Error)> CreateLoteAsync(long usuarioId, CreateLoteC |
| | | 227 | | { |
| | 2 | 228 | | var tipo = await _repo.GetTipoByIdAsync(request.TipoCompensacionId); |
| | 3 | 229 | | if (tipo == null) return (false, null, "No se encontró el tipo de compensación indicado"); |
| | | 230 | | |
| | 1 | 231 | | if (request.PeriodoMes < 1 || request.PeriodoMes > 12) |
| | 0 | 232 | | return (false, null, "periodoMes debe estar entre 1 y 12"); |
| | | 233 | | |
| | 1 | 234 | | var periodo = new DateTime(request.PeriodoAnio, request.PeriodoMes, 1, 0, 0, 0, DateTimeKind.Utc); |
| | | 235 | | |
| | | 236 | | // Validar unicidad: un solo lote activo por tipo + período (igual que legacy) |
| | 1 | 237 | | if (await _repo.ExisteLoteActivoAsync(request.TipoCompensacionId, periodo)) |
| | 0 | 238 | | return (false, null, $"Ya existe un lote activo para ese tipo de compensación en {request.PeriodoAnio}/{requ |
| | | 239 | | |
| | 1 | 240 | | var lote = new LoteCompensacion |
| | 1 | 241 | | { |
| | 1 | 242 | | TipoCompensacionId = request.TipoCompensacionId, |
| | 1 | 243 | | Periodo = periodo, |
| | 1 | 244 | | Estado = "borrador", |
| | 1 | 245 | | Fuente = request.Fuente, |
| | 1 | 246 | | NombreArchivo = request.NombreArchivo, |
| | 1 | 247 | | HashArchivo = request.HashArchivo, |
| | 1 | 248 | | UsuarioId = usuarioId, |
| | 1 | 249 | | CreadoEn = DateTime.UtcNow |
| | 1 | 250 | | }; |
| | | 251 | | |
| | 1 | 252 | | var creado = await _repo.CreateLoteAsync(lote); |
| | 1 | 253 | | _logger.LogInformation("Lote compensación {Id} creado para tipo {TipoId}", creado.Id, creado.TipoCompensacionId) |
| | 1 | 254 | | return (true, creado, null); |
| | 2 | 255 | | } |
| | | 256 | | |
| | | 257 | | // Transiciones manuales vía PUT (aprobar/rechazar/revertir tienen endpoints dedicados) |
| | 1 | 258 | | private static readonly Dictionary<string, string[]> TransicionesPermitidas = new() |
| | 1 | 259 | | { |
| | 1 | 260 | | ["borrador"] = new[] { "validado" }, |
| | 1 | 261 | | ["validado"] = new[] { "borrador" } |
| | 1 | 262 | | // validado → aprobado: vía PUT /aprobar |
| | 1 | 263 | | // aprobado → borrador: vía PUT /revertir |
| | 1 | 264 | | // aprobado → rechazado: vía PUT /rechazar |
| | 1 | 265 | | // validado → rechazado: vía PUT /rechazar |
| | 1 | 266 | | }; |
| | | 267 | | |
| | | 268 | | public async Task<(bool Success, LoteCompensacion? Lote, string? Error)> UpdateLoteAsync(long id, UpdateLoteCompensa |
| | | 269 | | { |
| | 8 | 270 | | var lote = await _repo.GetLoteByIdAsync(id); |
| | 9 | 271 | | if (lote == null) return (false, null, "Lote no encontrado"); |
| | | 272 | | |
| | 7 | 273 | | if (!EstadosEditablesLote.Contains(lote.Estado)) |
| | 1 | 274 | | return (false, null, $"No se puede editar un lote en estado '{lote.Estado}'"); |
| | | 275 | | |
| | 6 | 276 | | if (request.Estado != null) |
| | | 277 | | { |
| | 6 | 278 | | if (!TransicionesPermitidas.TryGetValue(lote.Estado, out var permitidos) || |
| | 12 | 279 | | !Array.Exists(permitidos, e => e == request.Estado)) |
| | 1 | 280 | | return (false, null, $"Transición no permitida: '{lote.Estado}' → '{request.Estado}'. Permitidas: {strin |
| | | 281 | | |
| | | 282 | | // Validación al pasar a 'validado' |
| | 5 | 283 | | if (request.Estado == "validado") |
| | | 284 | | { |
| | 4 | 285 | | var (validOk, validError) = await ValidarLoteParaValidarAsync(lote); |
| | 7 | 286 | | if (!validOk) return (false, null, validError); |
| | | 287 | | } |
| | | 288 | | |
| | 2 | 289 | | lote.Estado = request.Estado; |
| | | 290 | | } |
| | | 291 | | |
| | 2 | 292 | | if (request.Fuente != null) lote.Fuente = request.Fuente; |
| | 2 | 293 | | if (request.NombreArchivo != null) lote.NombreArchivo = request.NombreArchivo; |
| | | 294 | | |
| | 2 | 295 | | var actualizado = await _repo.UpdateLoteAsync(lote); |
| | 2 | 296 | | return (true, actualizado, null); |
| | 8 | 297 | | } |
| | | 298 | | |
| | | 299 | | private async Task<(bool Success, string? Error)> ValidarLoteParaValidarAsync(LoteCompensacion lote) |
| | | 300 | | { |
| | 4 | 301 | | var totalItems = await _repo.GetItemCountAsync(lote.Id); |
| | 4 | 302 | | if (totalItems == 0) |
| | 1 | 303 | | return (false, "El lote no tiene ítems. Debe cargar al menos uno antes de validar."); |
| | | 304 | | |
| | 3 | 305 | | var itemsError = await _repo.GetItemsEnErrorCountAsync(lote.Id); |
| | 3 | 306 | | if (itemsError > 0) |
| | 1 | 307 | | return (false, $"El lote tiene {itemsError} ítem(s) en estado 'error'. Corrija o elimine esos ítems antes de |
| | | 308 | | |
| | 2 | 309 | | var config = await _repo.GetConfigVigenteAsync(lote.TipoCompensacionId, lote.Periodo); |
| | 2 | 310 | | if (config == null) |
| | 1 | 311 | | return (false, "No existe configuración activa para este tipo de compensación en el período del lote."); |
| | | 312 | | |
| | 1 | 313 | | return (true, null); |
| | 4 | 314 | | } |
| | | 315 | | |
| | | 316 | | public async Task<(bool Success, LoteCompensacion? Lote, string? Error)> AprobarLoteAsync(long id, long aprobadoPorI |
| | | 317 | | { |
| | 3 | 318 | | var lote = await _repo.GetLoteByIdAsync(id); |
| | 3 | 319 | | if (lote == null) return (false, null, "Lote no encontrado"); |
| | | 320 | | |
| | 3 | 321 | | if (lote.Estado != "validado") |
| | 2 | 322 | | return (false, null, $"Solo se pueden aprobar lotes en estado 'validado'. Estado actual: '{lote.Estado}'"); |
| | | 323 | | |
| | 1 | 324 | | lote.Estado = "aprobado"; |
| | 1 | 325 | | lote.AprobadoPor = aprobadoPorId; |
| | 1 | 326 | | lote.AprobadoEn = DateTime.UtcNow; |
| | | 327 | | |
| | 1 | 328 | | var actualizado = await _repo.UpdateLoteAsync(lote); |
| | 1 | 329 | | _logger.LogInformation("Lote {Id} aprobado por usuario {UsuarioId}", id, aprobadoPorId); |
| | 1 | 330 | | return (true, actualizado, null); |
| | 3 | 331 | | } |
| | | 332 | | |
| | | 333 | | public async Task<(bool Success, LoteCompensacion? Lote, string? Error)> RechazarLoteAsync(long id) |
| | | 334 | | { |
| | 5 | 335 | | var lote = await _repo.GetLoteByIdAsync(id); |
| | 6 | 336 | | if (lote == null) return (false, null, "Lote no encontrado"); |
| | | 337 | | |
| | 4 | 338 | | if (lote.Estado is "exportado" or "rechazado") |
| | 2 | 339 | | return (false, null, $"No se puede rechazar un lote en estado '{lote.Estado}'"); |
| | | 340 | | |
| | 2 | 341 | | lote.Estado = "rechazado"; |
| | 2 | 342 | | var actualizado = await _repo.UpdateLoteAsync(lote); |
| | 2 | 343 | | _logger.LogInformation("Lote {Id} rechazado", id); |
| | 2 | 344 | | return (true, actualizado, null); |
| | 5 | 345 | | } |
| | | 346 | | |
| | | 347 | | public async Task<(bool Success, LoteCompensacion? Lote, string? Error)> RevertirABorradorAsync(long id) |
| | | 348 | | { |
| | 4 | 349 | | var lote = await _repo.GetLoteByIdAsync(id); |
| | 5 | 350 | | if (lote == null) return (false, null, "Lote no encontrado"); |
| | | 351 | | |
| | 3 | 352 | | if (lote.Estado != "aprobado") |
| | 2 | 353 | | return (false, null, $"Solo se pueden revertir lotes en estado 'aprobado'. Estado actual: '{lote.Estado}'"); |
| | | 354 | | |
| | 1 | 355 | | lote.Estado = "borrador"; |
| | 1 | 356 | | lote.AprobadoPor = null; |
| | 1 | 357 | | lote.AprobadoEn = null; |
| | | 358 | | |
| | 1 | 359 | | var actualizado = await _repo.UpdateLoteAsync(lote); |
| | 1 | 360 | | _logger.LogInformation("Lote {Id} revertido a borrador", id); |
| | 1 | 361 | | return (true, actualizado, null); |
| | 4 | 362 | | } |
| | | 363 | | |
| | | 364 | | public async Task<(bool Success, string? Error)> CancelarLoteAsync(long id) |
| | | 365 | | { |
| | 5 | 366 | | var lote = await _repo.GetLoteByIdAsync(id); |
| | 6 | 367 | | if (lote == null) return (false, "Lote no encontrado"); |
| | | 368 | | |
| | 4 | 369 | | if (lote.Estado is not ("borrador" or "rechazado")) |
| | 2 | 370 | | return (false, $"Solo se pueden eliminar lotes en estado 'borrador' o 'rechazado'. Estado actual: '{lote.Est |
| | | 371 | | |
| | 2 | 372 | | await _repo.DeleteAllItemsAsync(id); |
| | 2 | 373 | | await _repo.DeleteLoteAsync(lote); |
| | 2 | 374 | | _logger.LogInformation("Lote {Id} cancelado y eliminado", id); |
| | 2 | 375 | | return (true, null); |
| | 5 | 376 | | } |
| | | 377 | | |
| | | 378 | | public async Task<PagedResult<ItemLoteCompensacionDto>> GetItemsPagedAsync(long loteId, int page, int pageSize) |
| | | 379 | | { |
| | 1 | 380 | | var lote = await _repo.GetLoteByIdAsync(loteId); |
| | 1 | 381 | | var unidadMedida = lote != null |
| | 1 | 382 | | ? (await _repo.GetTipoByIdAsync(lote.TipoCompensacionId))?.UnidadMedida ?? string.Empty |
| | 1 | 383 | | : string.Empty; |
| | | 384 | | |
| | 1 | 385 | | var (items, totalCount) = await _repo.GetItemsPagedAsync(loteId, page, pageSize); |
| | 1 | 386 | | return new PagedResult<ItemLoteCompensacionDto> |
| | 1 | 387 | | { |
| | 2 | 388 | | Items = items.Select(i => MapItemToDto(i, unidadMedida)), |
| | 1 | 389 | | Page = page, |
| | 1 | 390 | | PageSize = pageSize, |
| | 1 | 391 | | TotalCount = totalCount |
| | 1 | 392 | | }; |
| | 1 | 393 | | } |
| | | 394 | | |
| | | 395 | | // ── Items ──────────────────────────────────────────────────────────────── |
| | | 396 | | |
| | | 397 | | public async Task<(bool Success, ItemLoteCompensacion? Item, string? Error)> CreateItemAsync(long loteId, CreateItem |
| | | 398 | | { |
| | 23 | 399 | | var lote = await _repo.GetLoteByIdAsync(loteId); |
| | 23 | 400 | | if (lote == null) return (false, null, "Lote no encontrado"); |
| | | 401 | | |
| | 23 | 402 | | if (!EstadosEditablesLote.Contains(lote.Estado)) |
| | 1 | 403 | | return (false, null, $"No se pueden agregar ítems a un lote en estado '{lote.Estado}'"); |
| | | 404 | | |
| | | 405 | | // Resolver cédula → personaId |
| | 22 | 406 | | var relacion = await _personalRepo.GetByCedulaAsync(request.CedulaPersona); |
| | 22 | 407 | | if (relacion == null) |
| | 1 | 408 | | return (false, null, $"No se encontró personal activo con cédula {request.CedulaPersona}"); |
| | | 409 | | |
| | 21 | 410 | | var personaId = relacion.PersonaId; |
| | | 411 | | |
| | 21 | 412 | | if (await _repo.ExistePersonaEnLoteAsync(loteId, personaId)) |
| | 1 | 413 | | return (false, null, "Ya existe un ítem para esa persona en este lote"); |
| | | 414 | | |
| | 20 | 415 | | var config = await _repo.GetConfigVigenteAsync(lote.TipoCompensacionId, lote.Periodo); |
| | 20 | 416 | | if (config?.TopeUnidades.HasValue == true && request.UnidadCantidad > config.TopeUnidades.Value) |
| | 1 | 417 | | return (false, null, $"unidad_cantidad excede el tope máximo de {config.TopeUnidades} unidades"); |
| | | 418 | | |
| | | 419 | | // Aplicar fórmula de la configuración vigente |
| | 19 | 420 | | decimal? montoFinal = request.Monto; |
| | 19 | 421 | | if (config != null) |
| | | 422 | | { |
| | 19 | 423 | | var (formulaOk, montoCalculado, formulaError) = await AplicarFormulaAsync( |
| | 19 | 424 | | loteId, config, request.UnidadCantidad, request.Monto, |
| | 19 | 425 | | request.Ala, request.CategoriaCompensacion, relacion.GradoId, lote.Periodo); |
| | 26 | 426 | | if (!formulaOk) return (false, null, formulaError); |
| | 12 | 427 | | montoFinal = montoCalculado; |
| | | 428 | | } |
| | | 429 | | |
| | | 430 | | // SDL: derivado de la configuración del tipo — no del ítem individual |
| | 12 | 431 | | var sujetoDescLegales = config?.SujetoDescLegales ?? false; |
| | | 432 | | |
| | 12 | 433 | | var item = new ItemLoteCompensacion |
| | 12 | 434 | | { |
| | 12 | 435 | | LoteCompensacionId = loteId, |
| | 12 | 436 | | PersonaId = personaId, |
| | 12 | 437 | | UnidadCantidad = request.UnidadCantidad, |
| | 12 | 438 | | Monto = montoFinal, |
| | 12 | 439 | | Estado = "ok", |
| | 12 | 440 | | Incidencia = request.Incidencia, |
| | 12 | 441 | | Observaciones = request.Observaciones, |
| | 12 | 442 | | Funcion = request.Funcion, |
| | 12 | 443 | | Ala = request.Ala, |
| | 12 | 444 | | CategoriaCompensacion = request.CategoriaCompensacion, |
| | 12 | 445 | | SujetoDescLegales = sujetoDescLegales, |
| | 12 | 446 | | // Snapshots de la relación laboral activa al momento de carga |
| | 12 | 447 | | SnapshotGradoId = relacion.GradoId, |
| | 12 | 448 | | SnapshotSituacionId = relacion.SituacionId, |
| | 12 | 449 | | SnapshotUnidadId = relacion.UnidadId, |
| | 12 | 450 | | SnapshotProgramaId = relacion.ProgramaId |
| | 12 | 451 | | }; |
| | | 452 | | |
| | 12 | 453 | | var creado = await _repo.CreateItemAsync(item); |
| | 12 | 454 | | await RevertirABorradorSiValidadoAsync(lote); |
| | 12 | 455 | | return (true, creado, null); |
| | 23 | 456 | | } |
| | | 457 | | |
| | | 458 | | public async Task<(bool Success, ItemLoteCompensacion? Item, string? Error)> UpdateItemAsync(long loteId, long itemI |
| | | 459 | | { |
| | 2 | 460 | | var lote = await _repo.GetLoteByIdAsync(loteId); |
| | 2 | 461 | | if (lote == null) return (false, null, "Lote no encontrado"); |
| | | 462 | | |
| | 2 | 463 | | if (!EstadosEditablesLote.Contains(lote.Estado)) |
| | 0 | 464 | | return (false, null, $"No se pueden editar ítems de un lote en estado '{lote.Estado}'"); |
| | | 465 | | |
| | 2 | 466 | | var item = await _repo.GetItemByIdAsync(itemId); |
| | 2 | 467 | | if (item == null || item.LoteCompensacionId != loteId) |
| | 0 | 468 | | return (false, null, "Ítem no encontrado"); |
| | | 469 | | |
| | 2 | 470 | | if (request.Ala != null) item.Ala = request.Ala; |
| | 2 | 471 | | if (request.CategoriaCompensacion != null) item.CategoriaCompensacion = request.CategoriaCompensacion; |
| | | 472 | | |
| | 2 | 473 | | if (request.UnidadCantidad.HasValue || request.Monto.HasValue || request.Ala != null || request.CategoriaCompens |
| | | 474 | | { |
| | 2 | 475 | | var config = await _repo.GetConfigVigenteAsync(lote.TipoCompensacionId, lote.Periodo); |
| | | 476 | | |
| | 2 | 477 | | if (request.UnidadCantidad.HasValue) |
| | | 478 | | { |
| | 1 | 479 | | if (config?.TopeUnidades.HasValue == true && request.UnidadCantidad.Value > config.TopeUnidades.Value) |
| | 0 | 480 | | return (false, null, $"unidad_cantidad excede el tope máximo de {config.TopeUnidades} unidades"); |
| | 1 | 481 | | item.UnidadCantidad = request.UnidadCantidad.Value; |
| | | 482 | | } |
| | | 483 | | |
| | 2 | 484 | | if (config != null) |
| | | 485 | | { |
| | 2 | 486 | | var nuevaCantidad = item.UnidadCantidad; |
| | 2 | 487 | | var nuevoMonto = request.Monto ?? item.Monto; |
| | 2 | 488 | | var (formulaOk, montoCalculado, formulaError) = await AplicarFormulaAsync( |
| | 2 | 489 | | loteId, config, nuevaCantidad, nuevoMonto, |
| | 2 | 490 | | item.Ala, item.CategoriaCompensacion, item.SnapshotGradoId, lote.Periodo); |
| | 3 | 491 | | if (!formulaOk) return (false, null, formulaError); |
| | 1 | 492 | | item.Monto = montoCalculado; |
| | | 493 | | } |
| | 0 | 494 | | else if (request.Monto.HasValue) |
| | | 495 | | { |
| | 0 | 496 | | item.Monto = request.Monto; |
| | | 497 | | } |
| | | 498 | | } |
| | | 499 | | |
| | 1 | 500 | | if (request.Estado != null) item.Estado = request.Estado; |
| | 1 | 501 | | if (request.Incidencia != null) item.Incidencia = request.Incidencia; |
| | 1 | 502 | | if (request.Observaciones != null) item.Observaciones = request.Observaciones; |
| | 1 | 503 | | if (request.Funcion != null) item.Funcion = request.Funcion; |
| | | 504 | | |
| | 1 | 505 | | var actualizado = await _repo.UpdateItemAsync(item); |
| | 1 | 506 | | await RevertirABorradorSiValidadoAsync(lote); |
| | 1 | 507 | | return (true, actualizado, null); |
| | 2 | 508 | | } |
| | | 509 | | |
| | | 510 | | public async Task<(bool Success, string? Error)> DeleteItemAsync(long loteId, long itemId) |
| | | 511 | | { |
| | 6 | 512 | | var lote = await _repo.GetLoteByIdAsync(loteId); |
| | 7 | 513 | | if (lote == null) return (false, "Lote no encontrado"); |
| | | 514 | | |
| | 5 | 515 | | if (!EstadosEditablesLote.Contains(lote.Estado)) |
| | 1 | 516 | | return (false, $"No se pueden eliminar ítems de un lote en estado '{lote.Estado}'"); |
| | | 517 | | |
| | 4 | 518 | | var item = await _repo.GetItemByIdAsync(itemId); |
| | 4 | 519 | | if (item == null || item.LoteCompensacionId != loteId) |
| | 2 | 520 | | return (false, "Ítem no encontrado"); |
| | | 521 | | |
| | 2 | 522 | | await _repo.DeleteItemAsync(item); |
| | 2 | 523 | | await RevertirABorradorSiValidadoAsync(lote); |
| | 2 | 524 | | return (true, null); |
| | 6 | 525 | | } |
| | | 526 | | |
| | | 527 | | /// Si el lote estaba en 'validado', cualquier edición de ítems lo regresa a 'borrador' |
| | | 528 | | private async Task RevertirABorradorSiValidadoAsync(LoteCompensacion lote) |
| | | 529 | | { |
| | 15 | 530 | | if (lote.Estado == "validado") |
| | | 531 | | { |
| | 1 | 532 | | lote.Estado = "borrador"; |
| | 1 | 533 | | await _repo.UpdateLoteAsync(lote); |
| | 1 | 534 | | _logger.LogInformation("Lote {Id} revertido a borrador por edición de ítems", lote.Id); |
| | | 535 | | } |
| | 15 | 536 | | } |
| | | 537 | | |
| | | 538 | | // ── Bulk Import ────────────────────────────────────────────────────────── |
| | | 539 | | |
| | | 540 | | public async Task<BulkImportResultDto> CreateItemsBulkAsync(long loteId, IEnumerable<CreateItemLoteRequest> items, s |
| | | 541 | | { |
| | 0 | 542 | | var lote = await _repo.GetLoteByIdAsync(loteId); |
| | 0 | 543 | | if (lote == null) |
| | 0 | 544 | | return new BulkImportResultDto { Fallidos = 1, Procesados = 1, Resultados = [new() { Linea = 0, Cedula = "", |
| | | 545 | | |
| | 0 | 546 | | if (!dryRun && !EstadosEditablesLote.Contains(lote.Estado)) |
| | 0 | 547 | | return new BulkImportResultDto { Fallidos = 1, Procesados = 1, Resultados = [new() { Linea = 0, Cedula = "", |
| | | 548 | | |
| | 0 | 549 | | var resultado = new BulkImportResultDto { EsDryRun = dryRun, Modo = modo }; |
| | | 550 | | |
| | 0 | 551 | | if (!dryRun && modo == "reemplazar") |
| | | 552 | | { |
| | 0 | 553 | | await _repo.DeleteAllItemsAsync(loteId); |
| | 0 | 554 | | if (lote.Estado == "validado") { lote.Estado = "borrador"; await _repo.UpdateLoteAsync(lote); } |
| | | 555 | | } |
| | | 556 | | |
| | 0 | 557 | | int linea = 1; |
| | 0 | 558 | | foreach (var request in items) |
| | | 559 | | { |
| | 0 | 560 | | resultado.Procesados++; |
| | 0 | 561 | | var (success, item, error) = dryRun |
| | 0 | 562 | | ? await ValidarItemAsync(loteId, lote, request) |
| | 0 | 563 | | : await CreateItemAsync(loteId, request); |
| | | 564 | | |
| | 0 | 565 | | resultado.Resultados.Add(new BulkImportLineResultDto |
| | 0 | 566 | | { |
| | 0 | 567 | | Linea = linea++, |
| | 0 | 568 | | Cedula = request.CedulaPersona, |
| | 0 | 569 | | Exito = success, |
| | 0 | 570 | | Error = error, |
| | 0 | 571 | | ItemId = item?.Id |
| | 0 | 572 | | }); |
| | 0 | 573 | | if (success) resultado.Exitosos++; |
| | 0 | 574 | | else resultado.Fallidos++; |
| | 0 | 575 | | } |
| | | 576 | | |
| | 0 | 577 | | return resultado; |
| | 0 | 578 | | } |
| | | 579 | | |
| | | 580 | | public async Task<BulkImportResultDto> CreateItemsFromCsvAsync(long loteId, Stream csvStream, string modo = "reempla |
| | | 581 | | { |
| | 0 | 582 | | var lote = await _repo.GetLoteByIdAsync(loteId); |
| | 0 | 583 | | if (lote == null) |
| | 0 | 584 | | return new BulkImportResultDto { Fallidos = 1, Procesados = 1, Resultados = [new() { Linea = 0, Cedula = "", |
| | | 585 | | |
| | 0 | 586 | | if (!dryRun && !EstadosEditablesLote.Contains(lote.Estado)) |
| | 0 | 587 | | return new BulkImportResultDto { Fallidos = 1, Procesados = 1, Resultados = [new() { Linea = 0, Cedula = "", |
| | | 588 | | |
| | 0 | 589 | | if (!dryRun && modo == "reemplazar") |
| | | 590 | | { |
| | 0 | 591 | | await _repo.DeleteAllItemsAsync(loteId); |
| | 0 | 592 | | if (lote.Estado == "validado") { lote.Estado = "borrador"; await _repo.UpdateLoteAsync(lote); } |
| | | 593 | | } |
| | | 594 | | |
| | | 595 | | // Para fórmulas fijo y prorrateo el monto lo calcula el sistema; para las demás el CSV debe proveerlo |
| | 0 | 596 | | var configCsv = await _repo.GetConfigVigenteAsync(lote.TipoCompensacionId, lote.Periodo); |
| | 0 | 597 | | var formulaCalculaMontoAutomatico = configCsv?.Formula is "fijo" or "prorrateo"; |
| | | 598 | | // Para tabla con ala o categoria, el monto también se calcula desde la tarifa |
| | 0 | 599 | | var formulaTablaConLookup = configCsv?.Formula == "tabla" && configCsv.CatalogoItemId.HasValue; |
| | | 600 | | |
| | 0 | 601 | | var resultado = new BulkImportResultDto { EsDryRun = dryRun, Modo = modo }; |
| | 0 | 602 | | using var reader = new System.IO.StreamReader(csvStream); |
| | | 603 | | |
| | | 604 | | // Leer encabezados |
| | 0 | 605 | | var headerLine = await reader.ReadLineAsync(); |
| | 0 | 606 | | if (string.IsNullOrWhiteSpace(headerLine)) |
| | 0 | 607 | | return resultado; |
| | | 608 | | |
| | 0 | 609 | | var headers = headerLine.Split(',').Select(h => h.Trim().ToLower()).ToArray(); |
| | 0 | 610 | | int idxCedula = Array.IndexOf(headers, "cedula"); |
| | 0 | 611 | | int idxMonto = Array.IndexOf(headers, "monto"); |
| | 0 | 612 | | int idxUnidad = Array.IndexOf(headers, "unidad_cantidad"); |
| | 0 | 613 | | int idxFuncion = Array.IndexOf(headers, "funcion"); |
| | 0 | 614 | | int idxAla = Array.IndexOf(headers, "ala"); |
| | 0 | 615 | | int idxCategoria = Array.IndexOf(headers, "categoria"); |
| | 0 | 616 | | int idxIncidencia = Array.IndexOf(headers, "incidencia"); |
| | 0 | 617 | | int idxObservaciones = Array.IndexOf(headers, "observaciones"); |
| | | 618 | | |
| | 0 | 619 | | if (idxCedula < 0) |
| | 0 | 620 | | return new BulkImportResultDto { Fallidos = 1, Procesados = 1, Resultados = [new() { Linea = 1, Cedula = "", |
| | | 621 | | |
| | 0 | 622 | | int linea = 2; |
| | 0 | 623 | | while (!reader.EndOfStream) |
| | | 624 | | { |
| | 0 | 625 | | var line = await reader.ReadLineAsync(); |
| | 0 | 626 | | if (string.IsNullOrWhiteSpace(line)) { linea++; continue; } |
| | | 627 | | |
| | 0 | 628 | | var cols = line.Split(','); |
| | 0 | 629 | | var cedula = idxCedula < cols.Length ? cols[idxCedula].Trim() : ""; |
| | | 630 | | |
| | 0 | 631 | | resultado.Procesados++; |
| | | 632 | | |
| | 0 | 633 | | if (string.IsNullOrWhiteSpace(cedula)) |
| | | 634 | | { |
| | 0 | 635 | | resultado.Fallidos++; |
| | 0 | 636 | | resultado.Resultados.Add(new() { Linea = linea, Cedula = cedula, Exito = false, Error = "Cédula vacía" } |
| | 0 | 637 | | linea++; |
| | 0 | 638 | | continue; |
| | | 639 | | } |
| | | 640 | | |
| | 0 | 641 | | decimal monto = 0; |
| | 0 | 642 | | if (idxMonto >= 0 && idxMonto < cols.Length) |
| | 0 | 643 | | decimal.TryParse(cols[idxMonto].Trim(), System.Globalization.NumberStyles.Any, System.Globalization.Cult |
| | | 644 | | |
| | 0 | 645 | | var ala = idxAla < 0 || idxAla >= cols.Length ? null : NullIfEmpty(cols[idxAla].Trim()?.ToUpper()); |
| | 0 | 646 | | var categoria = idxCategoria < 0 || idxCategoria >= cols.Length ? null : NullIfEmpty(cols[idxCategoria].Trim |
| | | 647 | | |
| | | 648 | | // El monto no es requerido si la fórmula lo calcula automáticamente |
| | | 649 | | // (fijo, prorrateo, o tabla con ala/categoria) |
| | 0 | 650 | | var montoEsAutomatico = formulaCalculaMontoAutomatico || formulaTablaConLookup; |
| | | 651 | | |
| | 0 | 652 | | if (!montoEsAutomatico && monto <= 0) |
| | | 653 | | { |
| | 0 | 654 | | resultado.Fallidos++; |
| | 0 | 655 | | resultado.Resultados.Add(new() { Linea = linea, Cedula = cedula, Exito = false, Error = "El monto debe s |
| | 0 | 656 | | linea++; |
| | 0 | 657 | | continue; |
| | | 658 | | } |
| | | 659 | | |
| | 0 | 660 | | decimal unidadCantidad = 1; |
| | 0 | 661 | | if (idxUnidad >= 0 && idxUnidad < cols.Length && !string.IsNullOrWhiteSpace(cols[idxUnidad])) |
| | 0 | 662 | | decimal.TryParse(cols[idxUnidad].Trim(), System.Globalization.NumberStyles.Any, System.Globalization.Cul |
| | | 663 | | |
| | 0 | 664 | | var funcion = idxFuncion < 0 || idxFuncion >= cols.Length ? null : NullIfEmpty(cols[idxFuncion].Trim()) |
| | 0 | 665 | | var incidencia = idxIncidencia < 0 || idxIncidencia >= cols.Length ? null : NullIfEmpty(cols[idxIncidencia |
| | 0 | 666 | | var observaciones = idxObservaciones < 0 || idxObservaciones >= cols.Length ? null : NullIfEmpty(cols[idxObs |
| | | 667 | | |
| | 0 | 668 | | var request = new CreateItemLoteRequest |
| | 0 | 669 | | { |
| | 0 | 670 | | CedulaPersona = cedula, |
| | 0 | 671 | | Monto = monto > 0 ? monto : null, |
| | 0 | 672 | | UnidadCantidad = unidadCantidad, |
| | 0 | 673 | | Funcion = funcion, |
| | 0 | 674 | | Ala = ala, |
| | 0 | 675 | | CategoriaCompensacion = categoria, |
| | 0 | 676 | | Incidencia = incidencia, |
| | 0 | 677 | | Observaciones = observaciones |
| | 0 | 678 | | }; |
| | | 679 | | |
| | 0 | 680 | | var (success, item, error) = dryRun |
| | 0 | 681 | | ? await ValidarItemAsync(loteId, lote, request) |
| | 0 | 682 | | : await CreateItemAsync(loteId, request); |
| | 0 | 683 | | resultado.Resultados.Add(new() { Linea = linea, Cedula = cedula, Exito = success, Error = error, ItemId = it |
| | 0 | 684 | | if (success) resultado.Exitosos++; |
| | 0 | 685 | | else resultado.Fallidos++; |
| | | 686 | | |
| | 0 | 687 | | linea++; |
| | 0 | 688 | | } |
| | | 689 | | |
| | 0 | 690 | | return resultado; |
| | 0 | 691 | | } |
| | | 692 | | |
| | | 693 | | /// Valida un ítem sin persistir (dry run). Replica las mismas validaciones de CreateItemAsync. |
| | | 694 | | private async Task<(bool Success, ItemLoteCompensacion? Item, string? Error)> ValidarItemAsync( |
| | | 695 | | long loteId, LoteCompensacion lote, CreateItemLoteRequest request) |
| | | 696 | | { |
| | 0 | 697 | | if (!EstadosEditablesLote.Contains(lote.Estado)) |
| | 0 | 698 | | return (false, null, $"Lote en estado '{lote.Estado}' no es editable"); |
| | | 699 | | |
| | 0 | 700 | | var relacion = await _personalRepo.GetByCedulaAsync(request.CedulaPersona); |
| | 0 | 701 | | if (relacion == null) |
| | 0 | 702 | | return (false, null, $"No se encontró personal activo con cédula {request.CedulaPersona}"); |
| | | 703 | | |
| | 0 | 704 | | if (await _repo.ExistePersonaEnLoteAsync(loteId, relacion.PersonaId)) |
| | 0 | 705 | | return (false, null, "Ya existe un ítem para esa persona en este lote"); |
| | | 706 | | |
| | 0 | 707 | | var config = await _repo.GetConfigVigenteAsync(lote.TipoCompensacionId, lote.Periodo); |
| | 0 | 708 | | if (config?.TopeUnidades.HasValue == true && request.UnidadCantidad > config.TopeUnidades.Value) |
| | 0 | 709 | | return (false, null, $"unidad_cantidad excede el tope máximo de {config.TopeUnidades} unidades"); |
| | | 710 | | |
| | 0 | 711 | | if (config != null) |
| | | 712 | | { |
| | 0 | 713 | | var (formulaOk, _, formulaError) = await AplicarFormulaAsync( |
| | 0 | 714 | | loteId, config, request.UnidadCantidad, request.Monto, |
| | 0 | 715 | | request.Ala, request.CategoriaCompensacion, relacion.GradoId, lote.Periodo); |
| | 0 | 716 | | if (!formulaOk) return (false, null, formulaError); |
| | | 717 | | } |
| | | 718 | | |
| | | 719 | | // Validación aprobada — no se persiste |
| | 0 | 720 | | return (true, null, null); |
| | 0 | 721 | | } |
| | | 722 | | |
| | | 723 | | // ── Helpers ────────────────────────────────────────────────────────────── |
| | | 724 | | |
| | | 725 | | // ── Lógica de fórmulas ─────────────────────────────────────────────────── |
| | | 726 | | |
| | | 727 | | /// Aplica la fórmula de la configuración para calcular o validar el monto del ítem. |
| | | 728 | | /// Devuelve el monto final que debe persistirse. |
| | | 729 | | private async Task<(bool Success, decimal? MontoCalculado, string? Error)> AplicarFormulaAsync( |
| | | 730 | | long loteId, |
| | | 731 | | ConfigCompensacion config, |
| | | 732 | | decimal unidadCantidad, |
| | | 733 | | decimal? montoEntrada, |
| | | 734 | | string? ala = null, |
| | | 735 | | string? categoria = null, |
| | | 736 | | long? snapshotGradoId = null, |
| | | 737 | | DateTime? periodo = null) |
| | | 738 | | { |
| | 21 | 739 | | switch (config.Formula) |
| | | 740 | | { |
| | | 741 | | case "fijo": |
| | 5 | 742 | | return (true, config.Monto, null); |
| | | 743 | | |
| | | 744 | | case "prorrateo": |
| | 3 | 745 | | if (!config.ValorPorUnidad.HasValue) |
| | 1 | 746 | | return (false, null, "La configuración de prorrateo no tiene valor_por_unidad definido"); |
| | 2 | 747 | | return (true, unidadCantidad * config.ValorPorUnidad.Value, null); |
| | | 748 | | |
| | | 749 | | case "rango": |
| | 5 | 750 | | if (!montoEntrada.HasValue) |
| | 1 | 751 | | return (false, null, "Se debe proveer monto para fórmula rango"); |
| | 4 | 752 | | if (config.ValorMinimo.HasValue && montoEntrada.Value < config.ValorMinimo.Value) |
| | 1 | 753 | | return (false, null, $"El monto {montoEntrada.Value:F2} es menor al mínimo permitido de {config.Valo |
| | 3 | 754 | | if (config.ValorMaximo.HasValue && montoEntrada.Value > config.ValorMaximo.Value) |
| | 2 | 755 | | return (false, null, $"El monto {montoEntrada.Value:F2} supera el máximo permitido de {config.ValorM |
| | 1 | 756 | | return (true, montoEntrada, null); |
| | | 757 | | |
| | | 758 | | case "presupuesto": |
| | 3 | 759 | | if (!montoEntrada.HasValue) |
| | 1 | 760 | | return (false, null, "Se debe proveer monto para fórmula presupuesto"); |
| | 2 | 761 | | if (config.Tope.HasValue) |
| | | 762 | | { |
| | 2 | 763 | | var totalActual = await _repo.GetMontoTotalItemsAsync(loteId); |
| | 2 | 764 | | if (totalActual + montoEntrada.Value > config.Tope.Value) |
| | 1 | 765 | | return (false, null, |
| | 1 | 766 | | $"El monto supera el tope presupuestario. Disponible: {config.Tope.Value - totalActual:F2}, |
| | | 767 | | } |
| | 1 | 768 | | return (true, montoEntrada, null); |
| | | 769 | | |
| | | 770 | | case "tabla": |
| | | 771 | | // Subcaso 1: VUELO — tarifa por categoría (ala A/N/S) |
| | 5 | 772 | | if (!string.IsNullOrEmpty(ala) && config.CatalogoItemId.HasValue) |
| | | 773 | | { |
| | 2 | 774 | | var fechaRef = periodo ?? DateTime.UtcNow; |
| | 2 | 775 | | var tarifa = await _repo.GetTarifaCategoriaAsync(config.CatalogoItemId.Value, ala, fechaRef); |
| | 2 | 776 | | if (tarifa == null) |
| | 1 | 777 | | return (false, null, $"No se encontró tarifa para categoría de vuelo '{ala}'. Verifique que la c |
| | 1 | 778 | | return (true, tarifa.Monto, null); |
| | | 779 | | } |
| | | 780 | | |
| | | 781 | | // Subcaso 2: SAR — tarifa por categoría (función) |
| | 3 | 782 | | if (!string.IsNullOrEmpty(categoria) && config.CatalogoItemId.HasValue) |
| | | 783 | | { |
| | 1 | 784 | | var fechaRef = periodo ?? DateTime.UtcNow; |
| | 1 | 785 | | var tarifa = await _repo.GetTarifaCategoriaAsync(config.CatalogoItemId.Value, categoria, fechaRef); |
| | 1 | 786 | | if (tarifa == null) |
| | 0 | 787 | | return (false, null, $"No se encontró tarifa para categoría '{categoria}'. Verifique que la conf |
| | 1 | 788 | | return (true, tarifa.Monto, null); |
| | | 789 | | } |
| | | 790 | | |
| | | 791 | | // Subcaso 3: CARCEL — tarifa diaria por grado |
| | 2 | 792 | | if (snapshotGradoId.HasValue && config.CatalogoItemId.HasValue) |
| | | 793 | | { |
| | 1 | 794 | | var fechaRef = periodo ?? DateTime.UtcNow; |
| | 1 | 795 | | var tarifaGrado = await _repo.GetTarifaGradoAsync(config.CatalogoItemId.Value, snapshotGradoId.Value |
| | 1 | 796 | | if (tarifaGrado != null) |
| | 1 | 797 | | return (true, unidadCantidad * tarifaGrado.Monto, null); |
| | | 798 | | // Si no hay tarifa por grado, cae al monto del CSV |
| | | 799 | | } |
| | | 800 | | |
| | | 801 | | // Default: monto viene precalculado del origen externo (COMP_PERS, etc.) |
| | 1 | 802 | | return (true, montoEntrada, null); |
| | | 803 | | |
| | | 804 | | default: |
| | 0 | 805 | | return (false, null, $"Fórmula '{config.Formula}' no reconocida"); |
| | | 806 | | } |
| | 21 | 807 | | } |
| | | 808 | | |
| | | 809 | | private static string? ValidarFormula(string formula, decimal? monto, decimal? valorPorUnidad, decimal? valorMinimo, |
| | | 810 | | { |
| | 8 | 811 | | if (!FormulasValidas.Contains(formula)) |
| | 0 | 812 | | return $"formula inválida. Valores aceptados: {string.Join(", ", FormulasValidas)}"; |
| | | 813 | | |
| | 8 | 814 | | if (formula == "fijo" && !monto.HasValue) |
| | 1 | 815 | | return "monto es obligatorio para fórmula fijo"; |
| | | 816 | | |
| | 7 | 817 | | if (formula == "prorrateo" && !valorPorUnidad.HasValue) |
| | 1 | 818 | | return "valor_por_unidad es obligatorio para fórmula prorrateo"; |
| | | 819 | | |
| | 6 | 820 | | if (formula == "rango") |
| | | 821 | | { |
| | 1 | 822 | | if (!valorMinimo.HasValue || !valorMaximo.HasValue) |
| | 0 | 823 | | return "valor_minimo y valor_maximo son obligatorios para fórmula rango"; |
| | 1 | 824 | | if (valorMinimo.Value >= valorMaximo.Value) |
| | 1 | 825 | | return "valor_minimo debe ser menor que valor_maximo"; |
| | | 826 | | } |
| | | 827 | | |
| | 5 | 828 | | if (topeUnidades.HasValue && topeUnidades.Value < 0) |
| | 0 | 829 | | return "tope_unidades debe ser mayor o igual a 0"; |
| | | 830 | | |
| | 5 | 831 | | return null; |
| | | 832 | | } |
| | | 833 | | |
| | 4 | 834 | | private static TipoCompensacionDto MapTipoToDto(TipoCompensacion t) => new() |
| | 4 | 835 | | { |
| | 4 | 836 | | Id = t.Id, |
| | 4 | 837 | | Codigo = t.Codigo, |
| | 4 | 838 | | Nombre = t.Nombre, |
| | 4 | 839 | | UnidadMedida = t.UnidadMedida, |
| | 4 | 840 | | RequiereFuente = t.RequiereFuente, |
| | 4 | 841 | | Vigente = t.Vigente |
| | 4 | 842 | | }; |
| | | 843 | | |
| | 4 | 844 | | private static ConfigCompensacionDto MapConfigToDto(ConfigCompensacion c) => new() |
| | 4 | 845 | | { |
| | 4 | 846 | | Id = c.Id, |
| | 4 | 847 | | TipoCompensacionId = c.TipoCompensacionId, |
| | 4 | 848 | | NombreTipo = c.TipoCompensacion?.Nombre ?? string.Empty, |
| | 4 | 849 | | RegimenId = c.RegimenId, |
| | 4 | 850 | | NombreRegimen = c.Regimen?.Denominacion, |
| | 4 | 851 | | GradoId = c.GradoId, |
| | 4 | 852 | | NombreGrado = c.Grado?.Denominacion, |
| | 4 | 853 | | EscalafonId = c.EscalafonId, |
| | 4 | 854 | | NombreEscalafon = c.Escalafon?.Denominacion, |
| | 4 | 855 | | Funcion = c.Funcion, |
| | 4 | 856 | | UnidadMedida = c.UnidadMedida, |
| | 4 | 857 | | Formula = c.Formula, |
| | 4 | 858 | | ValorPorUnidad = c.ValorPorUnidad, |
| | 4 | 859 | | Monto = c.Monto, |
| | 4 | 860 | | Tope = c.Tope, |
| | 4 | 861 | | TopeUnidades = c.TopeUnidades, |
| | 4 | 862 | | ValorMinimo = c.ValorMinimo, |
| | 4 | 863 | | ValorMaximo = c.ValorMaximo, |
| | 4 | 864 | | VigenteDesde = c.VigenteDesde, |
| | 4 | 865 | | VigenteHasta = c.VigenteHasta, |
| | 4 | 866 | | Activo = c.Activo, |
| | 4 | 867 | | SujetoDescLegales = c.SujetoDescLegales, |
| | 4 | 868 | | CatalogoItemId = c.CatalogoItemId, |
| | 4 | 869 | | NombreCatalogoItem = c.CatalogoItem?.Nombre |
| | 4 | 870 | | }; |
| | | 871 | | |
| | 0 | 872 | | private static LoteCompensacionDto MapLoteToDto(LoteCompensacion l) => new() |
| | 0 | 873 | | { |
| | 0 | 874 | | Id = l.Id, |
| | 0 | 875 | | TipoCompensacionId = l.TipoCompensacionId, |
| | 0 | 876 | | NombreTipo = l.TipoCompensacion?.Nombre ?? string.Empty, |
| | 0 | 877 | | UnidadMedida = l.TipoCompensacion?.UnidadMedida ?? string.Empty, |
| | 0 | 878 | | Periodo = l.Periodo, |
| | 0 | 879 | | Estado = l.Estado, |
| | 0 | 880 | | Fuente = l.Fuente, |
| | 0 | 881 | | NombreArchivo = l.NombreArchivo, |
| | 0 | 882 | | UsuarioId = l.UsuarioId, |
| | 0 | 883 | | AprobadoPor = l.AprobadoPor, |
| | 0 | 884 | | NombreAprobador = l.AprobadorUsuario?.Username, |
| | 0 | 885 | | AprobadoEn = l.AprobadoEn, |
| | 0 | 886 | | CreadoEn = l.CreadoEn, |
| | 0 | 887 | | ItemCount = l.ItemCount > 0 ? l.ItemCount : l.Items.Count(), |
| | 0 | 888 | | Items = l.Items.Select(i => MapItemToDto(i, l.TipoCompensacion?.UnidadMedida ?? string.Empty)) |
| | 0 | 889 | | }; |
| | | 890 | | |
| | | 891 | | private static string? NullIfEmpty(string? s) => |
| | 0 | 892 | | string.IsNullOrWhiteSpace(s) ? null : s; |
| | | 893 | | |
| | 2 | 894 | | private static ItemLoteCompensacionDto MapItemToDto(ItemLoteCompensacion i, string unidadMedida = "") => new() |
| | 2 | 895 | | { |
| | 2 | 896 | | Id = i.Id, |
| | 2 | 897 | | LoteCompensacionId = i.LoteCompensacionId, |
| | 2 | 898 | | CedulaPersona = i.Persona?.Cedula ?? string.Empty, |
| | 2 | 899 | | NombrePersona = i.Persona?.NombreCompleto ?? string.Empty, |
| | 2 | 900 | | UnidadCantidad = i.UnidadCantidad, |
| | 2 | 901 | | UnidadMedida = unidadMedida, |
| | 2 | 902 | | Monto = i.Monto, |
| | 2 | 903 | | Estado = i.Estado, |
| | 2 | 904 | | Incidencia = i.Incidencia, |
| | 2 | 905 | | Observaciones = i.Observaciones, |
| | 2 | 906 | | Funcion = i.Funcion, |
| | 2 | 907 | | SujetoDescLegales = i.SujetoDescLegales, |
| | 2 | 908 | | Ala = i.Ala, |
| | 2 | 909 | | CategoriaCompensacion = i.CategoriaCompensacion, |
| | 2 | 910 | | SnapshotGrado = i.SnapshotGrado?.Denominacion, |
| | 2 | 911 | | SnapshotSituacion = i.SnapshotSituacion?.Denominacion, |
| | 2 | 912 | | SnapshotUnidad = i.SnapshotUnidad?.Denominacion, |
| | 2 | 913 | | SnapshotPrograma = i.SnapshotPrograma?.Codigo |
| | 2 | 914 | | }; |
| | | 915 | | } |