Apigateway/Microservicios/MsUsuarios/Controllers/PermisosController.cs

165 lines
6.8 KiB
C#

using MSAdminUsuarios.Context;
using Microsoft.AspNetCore.Mvc;
using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;
using System.Transactions;
namespace MSAdminUsuarios.Controllers
{
[ApiController]
[Route("[controller]")]
public class PermisosController : ControllerBase
{
private readonly ModelContext _context;
public PermisosController(ModelContext context)
{
_context = context;
}
[HttpGet]
public async Task<IActionResult> GetPermisos()
{
try
{
var consulta = from dm in _context.PERMISOSMs
select dm;
return Ok(consulta);
}
catch (Exception ex)
{
return BadRequest(ex);
}
}
[HttpPost]
public async Task<IActionResult> GuardarPermisos(PERMISO[] guardar)
{
using (var dbContextTransaction = _context.Database.BeginTransaction())
{
List<string> error = new List<string>(); //Inicializamos variable para guardar errores
var count = 0;
try
{
// Se cambia a estado 0 todos los perfiles por usuario existentes
var existe_pms_c = _context.PERMISOSMs.Where(x => x.BL_ESTADO_PMS == 1 && x.NU_FK_PFL == guardar[0].NU_FK_PFL).ToList();
foreach (var cu in existe_pms_c)
{
cu.BL_ESTADO_PMS = 0;
_context.PERMISOSMs.Update(cu);
await _context.SaveChangesAsync();
}
foreach (var pms in guardar)
{
count++;
//Se comprueba existencia de cada permiso en base de datos
/*var existe_pms = (from dm in _context.PERMISOSMs
where dm.NU_FK_PFL == pms.NU_FK_PFL
&& dm.NU_FK_MS == pms.NU_FK_MS
select dm).ToList();*/
PERMISO? existe = _context.PERMISOSMs.FirstOrDefault(prm => prm.NU_FK_PFL == pms.NU_FK_PFL && prm.NU_FK_MS == pms.NU_FK_MS);
//if (existe_pms.Count() > 0)
if (existe != null)
{
//Si existe activamos estado 1 del perfil
existe.BL_ESTADO_PMS = 1;
//_context.Update(existe_pms[0]);
_context.Update(existe);
await _context.SaveChangesAsync();
continue;
}
else
{
if (pms == null)
{
error.Add($"Perfil por usuario #{count} sin valores");
continue;
}
//Se valida si el permiso a guardar tiene asignado microservicio padre o hijo
/*var validar_ms_hijo = (from dm in _context.MICROSERVICIOs
where dm.NU_PK_MS == pms.NU_FK_MS
&& dm.NU_PADRE_MS != null
select dm).ToList();*/
MICROSERVICIO? validar_ms_hijo = _context.MICROSERVICIOs.FirstOrDefault(m => m.NU_PK_MS == pms.NU_FK_MS && m.NU_PADRE_MS != null);
//if (validar_ms_hijo.Count() > 0)
if (validar_ms_hijo != null)
{
/*var existe_permiso_padre = (from dm in _context.PERMISOSMs
where dm.NU_FK_MS == validar_ms_hijo[0].NU_PADRE_MS
&& dm.NU_FK_PFL == pms.NU_FK_PFL
select dm).ToList();*/
PERMISO? existe_permiso_padre = _context.PERMISOSMs.FirstOrDefault(m => m.NU_FK_MS == validar_ms_hijo.NU_PADRE_MS && m.NU_FK_PFL == pms.NU_FK_PFL);
//if (existe_permiso_padre.Count() > 0)
if (existe_permiso_padre != null)
{
existe_permiso_padre.BL_ESTADO_PMS = 1;
_context.Update(existe_permiso_padre);
await _context.SaveChangesAsync();
}
else
{
PERMISO padre = new PERMISO
{
NU_PK_PMS = count * (-1),
NU_FK_PFL = pms.NU_FK_PFL,
//NU_FK_MS = validar_ms_hijo[0].NU_PADRE_MS,
NU_FK_MS = validar_ms_hijo.NU_PADRE_MS,
BL_ESTADO_PMS = 1,
};
_context.Add(padre);
await _context.SaveChangesAsync();
}
}
pms.BL_ESTADO_PMS = 1;
_context.PERMISOSMs.Add(pms);
await _context.SaveChangesAsync();
}
}
dbContextTransaction.Commit();
List<string> all = new List<string>();
all.Add($"Total registros: {guardar.Count().ToString()}");
all.Add($"Exitosos: {(guardar.Count() - error.Count()).ToString()}");
all.Add($"Erroneos: {error.Count().ToString()}");
var flag_r = 0;
foreach (var r in error)
{
flag_r++;
all.Add($"Error #{flag_r}: {r}");
}
if (error.Count() > 0)
{
return Conflict(all.ToList());
}
return Ok();
}
catch (Exception ex)
{
//hacemos rollback si hay excepción
dbContextTransaction.Rollback();
return BadRequest(ex.Message);
}
}
}
}
}