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