246 lines
9.4 KiB
C#
246 lines
9.4 KiB
C#
using Aop.Api.Domain;
|
|
using JNPF.Common.Const;
|
|
using JNPF.Common.Core.Handlers;
|
|
using JNPF.Common.Core.Manager;
|
|
using JNPF.Common.Enums;
|
|
using JNPF.Common.Extension;
|
|
using JNPF.Common.Filter;
|
|
using JNPF.Common.Manager;
|
|
using JNPF.Common.Models.User;
|
|
using JNPF.Common.Security;
|
|
using JNPF.DependencyInjection;
|
|
using JNPF.DynamicApiController;
|
|
using JNPF.FriendlyException;
|
|
using JNPF.LinqBuilder;
|
|
using JNPF.Systems.Entitys.Dto.System.System;
|
|
using JNPF.Systems.Entitys.Permission;
|
|
using JNPF.Systems.Entitys.System;
|
|
using Mapster;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using SqlSugar;
|
|
|
|
namespace JNPF.Systems.System;
|
|
|
|
/// <summary>
|
|
/// 系统功能.
|
|
/// </summary>
|
|
[ApiDescriptionSettings(Tag = "System", Name = "System", Order = 200)]
|
|
[Route("api/system/[controller]")]
|
|
public class SystemService : IDynamicApiController, ITransient
|
|
{
|
|
/// <summary>
|
|
/// 系统功能表仓储.
|
|
/// </summary>
|
|
private readonly ISqlSugarRepository<SystemEntity> _repository;
|
|
|
|
/// <summary>
|
|
/// 缓存管理器.
|
|
/// </summary>
|
|
private readonly ICacheManager _cacheManager;
|
|
|
|
/// <summary>
|
|
/// IM中心处理程序.
|
|
/// </summary>
|
|
private IMHandler _imHandler;
|
|
|
|
/// <summary>
|
|
/// 用户管理.
|
|
/// </summary>
|
|
private readonly IUserManager _userManager;
|
|
|
|
/// <summary>
|
|
/// 初始化一个<see cref="ModuleService"/>类型的新实例.
|
|
/// </summary>
|
|
public SystemService(
|
|
ISqlSugarRepository<SystemEntity> repository,
|
|
ICacheManager cacheManager,
|
|
IMHandler imHandler,
|
|
IUserManager userManager)
|
|
{
|
|
_repository = repository;
|
|
_cacheManager = cacheManager;
|
|
_imHandler = imHandler;
|
|
_userManager = userManager;
|
|
}
|
|
|
|
#region Get
|
|
|
|
/// <summary>
|
|
/// 列表.
|
|
/// </summary>
|
|
/// <param name="input">参数.</param>
|
|
/// <returns></returns>
|
|
[HttpGet("")]
|
|
public async Task<dynamic> GetList([FromQuery] SystemQuery input)
|
|
{
|
|
var authorIds = await _repository.AsSugarClient().Queryable<AuthorizeEntity>()
|
|
.Where(x => x.ItemType.Equals("system") && x.ObjectType.Equals("Role") && _userManager.Roles.Contains(x.ObjectId)).Select(x => x.ItemId).ToListAsync();
|
|
|
|
var whereLambda = LinqExpression.And<SystemEntity>();
|
|
whereLambda = whereLambda.And(x => x.DeleteMark == null);
|
|
if (!_userManager.IsAdministrator)
|
|
whereLambda = whereLambda.And(x => authorIds.Contains(x.Id));
|
|
if (input.keyword.IsNotEmptyOrNull())
|
|
whereLambda = whereLambda.And(x => x.FullName.Contains(input.keyword) || x.EnCode.Contains(input.keyword));
|
|
if (input.enableMark.IsNotEmptyOrNull())
|
|
whereLambda = whereLambda.And(x => x.EnabledMark == SqlFunc.ToInt32(input.enableMark));
|
|
var output = (await _repository.AsQueryable().Where(whereLambda).OrderBy(a => a.SortCode).OrderByDescending(a => a.CreatorTime).ToListAsync()).Adapt<List<SystemListOutput>>();
|
|
return new { list = output };
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取信息.
|
|
/// </summary>
|
|
/// <param name="id">主键id.</param>
|
|
/// <returns></returns>
|
|
[HttpGet("{id}")]
|
|
public async Task<dynamic> GetInfo(string id)
|
|
{
|
|
var data = await _repository.GetFirstAsync(x => x.Id == id && x.DeleteMark == null);
|
|
return data.Adapt<SystemCrInput>();
|
|
}
|
|
#endregion
|
|
|
|
#region Post
|
|
|
|
/// <summary>
|
|
/// 新建.
|
|
/// </summary>
|
|
/// <param name="input">实体对象.</param>
|
|
/// <returns></returns>
|
|
[HttpPost("")]
|
|
public async Task Create([FromBody] SystemCrInput input)
|
|
{
|
|
if (await _repository.IsAnyAsync(x => (x.EnCode == input.enCode || x.FullName == input.fullName) && x.DeleteMark == null))
|
|
throw Oops.Oh(ErrorCode.COM1004);
|
|
var entity = input.Adapt<SystemEntity>();
|
|
var isOk = await _repository.AsInsertable(entity).IgnoreColumns(ignoreNullColumn: true).CallEntityMethod(m => m.Creator()).ExecuteCommandAsync();
|
|
if (isOk < 1)
|
|
throw Oops.Oh(ErrorCode.COM1000);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 修改.
|
|
/// </summary>
|
|
/// <param name="id">主键值.</param>
|
|
/// <param name="input">实体对象.</param>
|
|
/// <returns></returns>
|
|
[HttpPut("{id}")]
|
|
public async Task Update(string id, [FromBody] SystemCrInput input)
|
|
{
|
|
if (await _repository.IsAnyAsync(x => x.Id != id && (x.EnCode == input.enCode || x.FullName == input.fullName) && x.DeleteMark == null))
|
|
throw Oops.Oh(ErrorCode.COM1004);
|
|
|
|
var mainSystem = await _repository.GetFirstAsync(it => it.IsMain.Equals(1) && it.EnabledMark.Equals(1) && it.DeleteMark == null);
|
|
|
|
// 判断主系统是否被禁用.
|
|
if (input.id.Equals(mainSystem.Id) && input.enabledMark.Equals(0))
|
|
throw Oops.Oh(ErrorCode.D1036);
|
|
|
|
// 判断主系统是否有修改系统编码.
|
|
if (input.id.Equals(mainSystem.Id) && !input.enCode.Equals(mainSystem.EnCode))
|
|
throw Oops.Oh(ErrorCode.D1037);
|
|
|
|
var isOk = await _repository.AsUpdateable().SetColumns(it => new SystemEntity()
|
|
{
|
|
FullName = input.fullName,
|
|
EnCode = input.enCode,
|
|
Icon = input.icon,
|
|
SortCode = input.sortCode,
|
|
Description = input.description,
|
|
EnabledMark = input.enabledMark,
|
|
LastModifyUserId = _userManager.UserId,
|
|
LastModifyTime = SqlFunc.GetDate(),
|
|
}).Where(it => it.Id.Equals(id)).ExecuteCommandAsync();
|
|
if (!(isOk > 0))
|
|
throw Oops.Oh(ErrorCode.COM1001);
|
|
|
|
// 当用户的子系统被禁用时，更换成其他未被禁用的系统.
|
|
if (!input.id.Equals(mainSystem.Id) && input.enabledMark.Equals(0))
|
|
{
|
|
var systemUser = await _repository.AsSugarClient().Queryable<UserEntity>()
|
|
.Where(it => it.DeleteMark == null && input.id.Equals(it.SystemId))
|
|
.Select(x => new UserEntity()
|
|
{
|
|
Id = x.Id,
|
|
SystemId = x.SystemId
|
|
}).ToListAsync();
|
|
|
|
// 获取用户所有角色id.
|
|
var userRoleIdList = await _repository.AsSugarClient().Queryable<UserRelationEntity>()
|
|
.Where(it => systemUser.Select(s => s.Id).ToList().Contains(it.UserId) && it.ObjectType.Equals("Role"))
|
|
.Select(x => x.ObjectId)
|
|
.ToListAsync();
|
|
var authorizeList = await _repository.AsSugarClient().Queryable<AuthorizeEntity>()
|
|
.Where(it => it.ItemType.Equals("module") && it.ObjectType.Equals("Role"))
|
|
.ToListAsync();
|
|
var moduleList = await _repository.AsSugarClient().Queryable<ModuleEntity>()
|
|
.Where(it => !it.SystemId.Equals(mainSystem.Id) && !it.SystemId.Equals(input.id) && it.DeleteMark == null)
|
|
.ToListAsync();
|
|
|
|
systemUser.ForEach(async item =>
|
|
{
|
|
// 获取用户所有角色的菜单.
|
|
var moduleIdList = authorizeList
|
|
.Where(x => userRoleIdList.Contains(x.ObjectId))
|
|
.Select(s => s.ItemId);
|
|
|
|
// 获取用户所有有权限的系统id.
|
|
var systemId = moduleList
|
|
.Where(x => moduleIdList.Contains(x.Id))
|
|
.Select(s => s.SystemId).FirstOrDefault();
|
|
|
|
if (systemId == null)
|
|
systemId = mainSystem.Id;
|
|
|
|
// 更新用户的系统id.
|
|
var res = await _repository.AsSugarClient().Updateable<UserEntity>()
|
|
.Where(x => item.Id.Equals(x.Id))
|
|
.SetColumns(x => new UserEntity()
|
|
{
|
|
SystemId = systemId
|
|
}).ExecuteCommandAsync();
|
|
|
|
if (!(res > 0))
|
|
throw Oops.Oh(ErrorCode.COM1001);
|
|
});
|
|
|
|
var tenantId = _userManager.TenantId;
|
|
var cacheKey = string.Format("{0}{1}", CommonConst.CACHEKEYONLINEUSER, tenantId);
|
|
var allUserOnlineList = await _cacheManager.GetAsync<List<UserOnlineModel>>(cacheKey);
|
|
|
|
var userOnlineList = allUserOnlineList.FindAll(it => systemUser.Select(s => s.Id).ToList().Contains(it.userId));
|
|
userOnlineList.ForEach(async item =>
|
|
{
|
|
await _imHandler.SendMessageAsync(item.connectionId, new { method = "logout", msg = "此系统已被禁用" }.ToJsonString());
|
|
|
|
// 删除在线用户ID.
|
|
allUserOnlineList.RemoveAll((x) => x.connectionId == item.connectionId);
|
|
|
|
// 删除用户登录信息缓存.
|
|
var mCacheKey = string.Format("{0}:{1}:{2}", tenantId, CommonConst.CACHEKEYUSER, item.userId);
|
|
await _cacheManager.DelAsync(mCacheKey);
|
|
});
|
|
await _cacheManager.SetAsync(cacheKey, allUserOnlineList);
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 删除.
|
|
/// </summary>
|
|
/// <param name="id">主键.</param>
|
|
/// <returns></returns>
|
|
[HttpDelete("{id}")]
|
|
public async Task Delete(string id)
|
|
{
|
|
var entity = await _repository.GetFirstAsync(x => x.Id == id && x.DeleteMark == null);
|
|
if (entity == null)
|
|
throw Oops.Oh(ErrorCode.COM1005);
|
|
var isOk = await _repository.AsUpdateable(entity).CallEntityMethod(m => m.Delete()).UpdateColumns(it => new { it.DeleteMark, it.DeleteTime, it.DeleteUserId }).ExecuteCommandHasChangeAsync();
|
|
if (!isOk)
|
|
throw Oops.Oh(ErrorCode.COM1002);
|
|
}
|
|
|
|
#endregion
|
|
}
|