392 lines
14 KiB
C#
392 lines
14 KiB
C#
/*******************************************************************************
|
||
* Copyright © 2020 HT.Cloud.Framework 版权所有
|
||
* Author: HT.Cloud
|
||
* Description: WaterCloud快速开发平台
|
||
* Website：
|
||
*********************************************************************************/
|
||
|
||
using SqlSugar;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Threading.Tasks;
|
||
using HT.Cloud.Code;
|
||
using HT.Cloud.Domain.SystemManage;
|
||
using HT.Cloud.Domain.SystemOrganize;
|
||
using HT.Cloud.Domain.ViewModel;
|
||
using HT.Cloud.Service.SystemManage;
|
||
|
||
namespace HT.Cloud.Service.SystemOrganize
|
||
{
|
||
public class RoleAuthorizeService : BaseService<RoleAuthorizeEntity>, IDenpendency
|
||
{
|
||
public ModuleService moduleApp { get; set; }
|
||
public ModuleButtonService moduleButtonApp { get; set; }
|
||
public ModuleFieldsService moduleFieldsApp { get; set; }
|
||
public UserService userApp { get; set; }
|
||
public RoleService roleApp { get; set; }
|
||
|
||
/// <summary>
|
||
/// 缓存操作类
|
||
/// </summary>
|
||
private string cacheKey = GlobalContext.SystemConfig.ProjectPrefix + "_authorizeurldata_";// +权限
|
||
|
||
public RoleAuthorizeService(ISqlSugarClient context) : base(context)
|
||
{
|
||
}
|
||
|
||
public async Task<List<RoleAuthorizeEntity>> GetList(string ObjectId)
|
||
{
|
||
var query = repository.IQueryable();
|
||
query = query.Where(a => a.F_ObjectId == ObjectId);
|
||
return await query.ToListAsync();
|
||
}
|
||
|
||
public async Task<List<ModuleEntity>> GetMenuList(string roleId)
|
||
{
|
||
var data = new List<ModuleEntity>();
|
||
if (currentuser.IsAdmin)
|
||
{
|
||
data = await moduleApp.GetList();
|
||
data = data.Where(a => a.F_IsMenu == true && a.F_EnabledMark == true).ToList();
|
||
}
|
||
else
|
||
{
|
||
var rolelist = roleId.Split(',');
|
||
var moduledata = await moduleApp.GetList();
|
||
moduledata = moduledata.Where(a => a.F_IsMenu == true && a.F_EnabledMark == true).ToList();
|
||
var role = repository.Db.Queryable<RoleEntity>().Where(a => rolelist.Contains(a.F_Id) && a.F_EnabledMark == true).ToList();
|
||
if (role.Count == 0)
|
||
{
|
||
return data;
|
||
}
|
||
var authorizedata = repository.IQueryable().Where(a => rolelist.Contains(a.F_ObjectId) && a.F_ItemType == 1).Distinct().ToList();
|
||
foreach (var item in authorizedata)
|
||
{
|
||
ModuleEntity moduleEntity = moduledata.Find(a => a.F_Id == item.F_ItemId && a.F_IsPublic == false);
|
||
if (moduleEntity != null && data.Find(a => a.F_Id == moduleEntity.F_Id) == null)
|
||
{
|
||
data.Add(moduleEntity);
|
||
}
|
||
}
|
||
data.AddRange(moduledata.Where(a => a.F_IsPublic == true));
|
||
}
|
||
return data.OrderBy(a => a.F_SortCode).ToList();
|
||
}
|
||
|
||
public async Task<List<ModuleButtonEntity>> GetButtonList(string roleId)
|
||
{
|
||
var data = new List<ModuleButtonEntity>();
|
||
if (currentuser.IsAdmin)
|
||
{
|
||
data = await moduleButtonApp.GetListNew();
|
||
}
|
||
else
|
||
{
|
||
var buttondata = await moduleButtonApp.GetListNew();
|
||
var role = await roleApp.GetForm(roleId);
|
||
if (role == null || role.F_EnabledMark == false)
|
||
{
|
||
return data;
|
||
}
|
||
var authorizedata = repository.IQueryable().Where(a => a.F_ObjectId == roleId && a.F_ItemType == 2).ToList();
|
||
foreach (var item in authorizedata)
|
||
{
|
||
ModuleButtonEntity moduleButtonEntity = buttondata.Find(a => a.F_Id == item.F_ItemId && a.F_IsPublic == false);
|
||
if (moduleButtonEntity != null)
|
||
{
|
||
data.Add(moduleButtonEntity);
|
||
}
|
||
}
|
||
data.AddRange(buttondata.Where(a => a.F_IsPublic == true));
|
||
}
|
||
return data.OrderBy(a => a.F_SortCode).ToList();
|
||
}
|
||
|
||
public async Task<List<ModuleFieldsEntity>> GetFieldsList(string roleId)
|
||
{
|
||
var data = new List<ModuleFieldsEntity>();
|
||
if (currentuser.IsAdmin)
|
||
{
|
||
data = await moduleFieldsApp.GetListNew();
|
||
}
|
||
else
|
||
{
|
||
var fieldsdata = await moduleFieldsApp.GetListNew();
|
||
var role = await roleApp.GetForm(roleId);
|
||
if (role == null || role.F_EnabledMark == false)
|
||
{
|
||
return data;
|
||
}
|
||
var authorizedata = repository.IQueryable().Where(a => a.F_ObjectId == roleId && a.F_ItemType == 3).ToList();
|
||
foreach (var item in authorizedata)
|
||
{
|
||
ModuleFieldsEntity moduleFieldsEntity = fieldsdata.Where(a => a.F_Id == item.F_ItemId && a.F_IsPublic == false).FirstOrDefault();
|
||
if (moduleFieldsEntity != null)
|
||
{
|
||
data.Add(moduleFieldsEntity);
|
||
}
|
||
}
|
||
data.AddRange(fieldsdata.Where(a => a.F_IsPublic == true));
|
||
}
|
||
return data.OrderByDescending(a => a.F_CreatorTime).ToList();
|
||
}
|
||
|
||
public async Task<bool> ActionValidate(string action, bool isAuthorize = false)
|
||
{
|
||
var user = await userApp.GetForm(currentuser.UserId);
|
||
var temps = isAuthorize ? action.Split(',') : new string[0];
|
||
if (user == null || user.F_EnabledMark == false)
|
||
{
|
||
return false;
|
||
}
|
||
var authorizeurldata = new List<AuthorizeActionModel>();
|
||
var cachedata = await CacheHelper.GetAsync<Dictionary<string, List<AuthorizeActionModel>>>(cacheKey + repository.Db.CurrentConnectionConfig.ConfigId + "_list");
|
||
if (cachedata == null)
|
||
{
|
||
cachedata = new Dictionary<string, List<AuthorizeActionModel>>();
|
||
}
|
||
if (user.F_IsAdmin == true)
|
||
{
|
||
if (await repository.Db.Queryable<ModuleEntity>().Where(a => a.F_UrlAddress == action || temps.Contains(a.F_Authorize)).AnyAsync()
|
||
|| await repository.Db.Queryable<ModuleButtonEntity>().Where(a => a.F_UrlAddress == action || temps.Contains(a.F_Authorize)).AnyAsync())
|
||
{
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
else
|
||
{
|
||
var rolelist = user.F_RoleId.Split(',');
|
||
foreach (var roles in rolelist)
|
||
{
|
||
if (!cachedata.ContainsKey(roles))
|
||
{
|
||
var moduledata = await moduleApp.GetList();
|
||
moduledata = moduledata.Where(a => a.F_EnabledMark == true).ToList();
|
||
var buttondata = await moduleButtonApp.GetList();
|
||
buttondata = buttondata.Where(a => a.F_EnabledMark == true).ToList();
|
||
var role = await roleApp.GetForm(roles);
|
||
if (role != null && role.F_EnabledMark == true)
|
||
{
|
||
var authdata = new List<AuthorizeActionModel>();
|
||
var authorizedata = await GetList(roles);
|
||
foreach (var item in authorizedata)
|
||
{
|
||
try
|
||
{
|
||
if (item.F_ItemType == 1)
|
||
{
|
||
ModuleEntity moduleEntity = moduledata.Where(a => a.F_Id == item.F_ItemId && a.F_IsPublic == false).FirstOrDefault();
|
||
if (moduleEntity != null)
|
||
{
|
||
authdata.Add(new AuthorizeActionModel { F_Id = moduleEntity.F_Id, F_UrlAddress = moduleEntity.F_UrlAddress, F_Authorize = moduleEntity.F_Authorize });
|
||
}
|
||
}
|
||
else if (item.F_ItemType == 2)
|
||
{
|
||
ModuleButtonEntity moduleButtonEntity = buttondata.Where(a => a.F_Id == item.F_ItemId && a.F_IsPublic == false).FirstOrDefault();
|
||
if (moduleButtonEntity != null)
|
||
{
|
||
authdata.Add(new AuthorizeActionModel { F_Id = moduleButtonEntity.F_ModuleId, F_UrlAddress = moduleButtonEntity.F_UrlAddress, F_Authorize = moduleButtonEntity.F_Authorize });
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
string e = ex.Message;
|
||
continue;
|
||
}
|
||
}
|
||
authdata.AddRange(moduledata.Where(a => a.F_IsPublic == true).Select(a => new AuthorizeActionModel { F_Id = a.F_Id, F_UrlAddress = a.F_UrlAddress, F_Authorize = a.F_Authorize }).ToList());
|
||
authdata.AddRange(buttondata.Where(a => a.F_IsPublic == true).Select(a => new AuthorizeActionModel { F_Id = a.F_ModuleId, F_UrlAddress = a.F_UrlAddress, F_Authorize = a.F_Authorize }).ToList());
|
||
cachedata.Add(roles, authdata);
|
||
authorizeurldata.AddRange(authdata);
|
||
await CacheHelper.RemoveAsync(cacheKey + repository.Db.CurrentConnectionConfig.ConfigId + "_list");
|
||
await CacheHelper.SetAsync(cacheKey + repository.Db.CurrentConnectionConfig.ConfigId + "_list", cachedata);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
authorizeurldata.AddRange(cachedata[roles]);
|
||
}
|
||
}
|
||
}
|
||
var module = authorizeurldata.Find(a => a.F_UrlAddress == action || temps.Contains(a.F_Authorize));
|
||
if (module != null)
|
||
{
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
public async Task<bool> CheckReturnUrl(string userId, string url, bool isAll = false)
|
||
{
|
||
var user = await userApp.GetForm(userId);
|
||
if (isAll == false && (user == null || user.F_EnabledMark == false))
|
||
{
|
||
return false;
|
||
}
|
||
if (isAll == true || user.F_IsAdmin == true)
|
||
{
|
||
if (repository.Db.Queryable<ModuleEntity>().Where(a => a.F_UrlAddress == url).Any() || repository.Db.Queryable<ModuleButtonEntity>().Where(a => a.F_UrlAddress == url).Any())
|
||
{
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
else
|
||
{
|
||
var authorizeurldata = new List<AuthorizeActionModel>();
|
||
var rolelist = user.F_RoleId.Split(',');
|
||
var cachedata = await CacheHelper.GetAsync<Dictionary<string, List<AuthorizeActionModel>>>(cacheKey + repository.Db.CurrentConnectionConfig.ConfigId + "_list");
|
||
if (cachedata == null)
|
||
{
|
||
cachedata = new Dictionary<string, List<AuthorizeActionModel>>();
|
||
}
|
||
foreach (var roles in rolelist)
|
||
{
|
||
if (!cachedata.ContainsKey(roles))
|
||
{
|
||
var moduledata = await moduleApp.GetList();
|
||
moduledata = moduledata.Where(a => a.F_EnabledMark == true).ToList();
|
||
var buttondata = await moduleButtonApp.GetList();
|
||
buttondata = buttondata.Where(a => a.F_EnabledMark == true).ToList();
|
||
var role = await roleApp.GetForm(roles);
|
||
if (role != null && role.F_EnabledMark == true)
|
||
{
|
||
var authdata = new List<AuthorizeActionModel>();
|
||
var authorizedata = await GetList(roles);
|
||
foreach (var item in authorizedata)
|
||
{
|
||
try
|
||
{
|
||
if (item.F_ItemType == 1)
|
||
{
|
||
ModuleEntity moduleEntity = moduledata.Where(a => a.F_Id == item.F_ItemId && a.F_IsPublic == false).FirstOrDefault();
|
||
if (moduleEntity != null)
|
||
{
|
||
authdata.Add(new AuthorizeActionModel { F_Id = moduleEntity.F_Id, F_UrlAddress = moduleEntity.F_UrlAddress, F_Authorize = moduleEntity.F_Authorize });
|
||
}
|
||
}
|
||
else if (item.F_ItemType == 2)
|
||
{
|
||
ModuleButtonEntity moduleButtonEntity = buttondata.Where(a => a.F_Id == item.F_ItemId && a.F_IsPublic == false).FirstOrDefault();
|
||
if (moduleButtonEntity != null)
|
||
{
|
||
authdata.Add(new AuthorizeActionModel { F_Id = moduleButtonEntity.F_ModuleId, F_UrlAddress = moduleButtonEntity.F_UrlAddress, F_Authorize = moduleButtonEntity.F_Authorize });
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
string e = ex.Message;
|
||
continue;
|
||
}
|
||
}
|
||
authdata.AddRange(moduledata.Where(a => a.F_IsPublic == true).Select(a => new AuthorizeActionModel { F_Id = a.F_Id, F_UrlAddress = a.F_UrlAddress, F_Authorize = a.F_Authorize }).ToList());
|
||
authdata.AddRange(buttondata.Where(a => a.F_IsPublic == true).Select(a => new AuthorizeActionModel { F_Id = a.F_ModuleId, F_UrlAddress = a.F_UrlAddress, F_Authorize = a.F_Authorize }).ToList());
|
||
cachedata.Add(roles, authdata);
|
||
authorizeurldata.AddRange(authdata);
|
||
await CacheHelper.RemoveAsync(cacheKey + repository.Db.CurrentConnectionConfig.ConfigId + "_list");
|
||
await CacheHelper.SetAsync(cacheKey + repository.Db.CurrentConnectionConfig.ConfigId + "_list", cachedata);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
authorizeurldata.AddRange(cachedata[roles]);
|
||
}
|
||
}
|
||
var module = authorizeurldata.Find(a => a.F_UrlAddress == url);
|
||
if (module != null)
|
||
{
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
}
|
||
|
||
public async Task<bool> RoleValidate()
|
||
{
|
||
var current = OperatorProvider.Provider.GetCurrent();
|
||
if (current == null || string.IsNullOrEmpty(current.UserId))
|
||
{
|
||
return false;
|
||
}
|
||
var user = await userApp.GetForm(current.UserId);
|
||
if (user == null || user.F_EnabledMark == false)
|
||
{
|
||
return false;
|
||
}
|
||
if (user.F_IsAdmin == true)
|
||
{
|
||
return true;
|
||
}
|
||
var authorizeurldata = new List<AuthorizeActionModel>();
|
||
var rolelist = user.F_RoleId.Split(',');
|
||
var cachedata = await CacheHelper.GetAsync<Dictionary<string, List<AuthorizeActionModel>>>(cacheKey + repository.Db.CurrentConnectionConfig.ConfigId + "_list");
|
||
if (cachedata == null)
|
||
{
|
||
cachedata = new Dictionary<string, List<AuthorizeActionModel>>();
|
||
}
|
||
foreach (var roles in rolelist)
|
||
{
|
||
if (!cachedata.ContainsKey(roles))
|
||
{
|
||
var moduledata = await moduleApp.GetList();
|
||
moduledata = moduledata.Where(a => a.F_EnabledMark == true).ToList();
|
||
var buttondata = await moduleButtonApp.GetList();
|
||
buttondata = buttondata.Where(a => a.F_EnabledMark == true).ToList();
|
||
var role = await roleApp.GetForm(roles);
|
||
if (role != null && role.F_EnabledMark == true)
|
||
{
|
||
var authdata = new List<AuthorizeActionModel>();
|
||
var authorizedata = await GetList(roles);
|
||
foreach (var item in authorizedata)
|
||
{
|
||
try
|
||
{
|
||
if (item.F_ItemType == 1)
|
||
{
|
||
ModuleEntity moduleEntity = moduledata.Where(a => a.F_Id == item.F_ItemId && a.F_IsPublic == false).FirstOrDefault();
|
||
if (moduleEntity != null)
|
||
{
|
||
authdata.Add(new AuthorizeActionModel { F_Id = moduleEntity.F_Id, F_UrlAddress = moduleEntity.F_UrlAddress, F_Authorize = moduleEntity.F_Authorize });
|
||
}
|
||
}
|
||
else if (item.F_ItemType == 2)
|
||
{
|
||
ModuleButtonEntity moduleButtonEntity = buttondata.Where(a => a.F_Id == item.F_ItemId && a.F_IsPublic == false).FirstOrDefault();
|
||
if (moduleButtonEntity != null)
|
||
{
|
||
authdata.Add(new AuthorizeActionModel { F_Id = moduleButtonEntity.F_ModuleId, F_UrlAddress = moduleButtonEntity.F_UrlAddress, F_Authorize = moduleButtonEntity.F_Authorize });
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
string e = ex.Message;
|
||
continue;
|
||
}
|
||
}
|
||
authdata.AddRange(moduledata.Where(a => a.F_IsPublic == true).Select(a => new AuthorizeActionModel { F_Id = a.F_Id, F_UrlAddress = a.F_UrlAddress, F_Authorize = a.F_Authorize }).ToList());
|
||
authdata.AddRange(buttondata.Where(a => a.F_IsPublic == true).Select(a => new AuthorizeActionModel { F_Id = a.F_ModuleId, F_UrlAddress = a.F_UrlAddress, F_Authorize = a.F_Authorize }).ToList());
|
||
cachedata.Add(roles, authdata);
|
||
authorizeurldata.AddRange(authdata);
|
||
await CacheHelper.RemoveAsync(cacheKey + repository.Db.CurrentConnectionConfig.ConfigId + "_list");
|
||
await CacheHelper.SetAsync(cacheKey + repository.Db.CurrentConnectionConfig.ConfigId + "_list", cachedata);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
authorizeurldata.AddRange(cachedata[roles]);
|
||
}
|
||
}
|
||
if (authorizeurldata.Count > 0)
|
||
{
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
}
|
||
} |