// Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。 // // 本项目主要遵循 MIT 许可证和 Apache 许可证(版本 2.0)进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。 // // 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动!任何基于本项目二次开发而产生的一切法律纠纷和责任,我们不承担任何责任! namespace Admin.NET.Core.Service; /// /// 系统用户配置参数服务 🧩 /// [ApiDescriptionSettings(Order = 440)] public class SysUserConfigService : IDynamicApiController, ITransient { private readonly SysCacheService _sysCacheService; private readonly SqlSugarRepository _sysConfigRep; private readonly SqlSugarRepository _sysConfigDataRep; public readonly ISugarQueryable VSysConfig; private readonly UserManager _userManager; public SysUserConfigService(SysCacheService sysCacheService, SqlSugarRepository sysConfigRep, SqlSugarRepository sysConfigDataRep, UserManager userManager) { _userManager = userManager; _sysCacheService = sysCacheService; _sysConfigRep = sysConfigRep; _sysConfigDataRep = sysConfigDataRep; VSysConfig = _sysConfigRep.AsQueryable().LeftJoin(_sysConfigDataRep.AsQueryable().WhereIF(_userManager.SuperAdmin, cv => cv.UserId == _userManager.UserId), (c, cv) => c.Id == cv.ConfigId).Select().MergeTable(); } /// /// 获取配置参数分页列表 🔖 /// /// /// [DisplayName("获取配置参数分页列表")] public async Task> Page(PageConfigInput input) { return await VSysConfig .WhereIF(!string.IsNullOrWhiteSpace(input.Name?.Trim()), u => u.Name.Contains(input.Name)) .WhereIF(!string.IsNullOrWhiteSpace(input.Code?.Trim()), u => u.Code.Contains(input.Code)) .WhereIF(!string.IsNullOrWhiteSpace(input.GroupCode?.Trim()), u => u.GroupCode.Equals(input.GroupCode)) .OrderBuilder(input) .ToPagedListAsync(input.Page, input.PageSize); } /// /// 获取配置参数列表 🔖 /// /// [DisplayName("获取配置参数列表")] public async Task> List(PageConfigInput input) { return await VSysConfig .WhereIF(!string.IsNullOrWhiteSpace(input.GroupCode?.Trim()), u => u.GroupCode.Equals(input.GroupCode)) .ToListAsync(); } /// /// 增加配置参数 🔖 /// /// /// [ApiDescriptionSettings(Name = "Add"), HttpPost] [DisplayName("增加配置参数")] public async Task AddConfig(AddConfigInput input) { var isExist = await _sysConfigRep.IsAnyAsync(u => u.Name == input.Name || u.Code == input.Code); if (isExist) throw Oops.Oh(ErrorCodeEnum.D9000); var configId = _sysConfigRep.InsertReturnSnowflakeId(input.Adapt()); await _sysConfigDataRep.InsertAsync(new SysUserConfigData() { UserId = _userManager.UserId, ConfigId = configId, Value = input.Value }); } /// /// 更新配置参数 🔖 /// /// /// [ApiDescriptionSettings(Name = "Update"), HttpPost] [DisplayName("更新配置参数")] [UnitOfWork] public async Task UpdateConfig(UpdateConfigInput input) { var isExist = await _sysConfigRep.IsAnyAsync(u => (u.Name == input.Name || u.Code == input.Code) && u.Id != input.Id); if (isExist) throw Oops.Oh(ErrorCodeEnum.D9000); var config = input.Adapt(); await _sysConfigRep.AsUpdateable(config).IgnoreColumns(true).ExecuteCommandAsync(); var configData = await _sysConfigDataRep.GetFirstAsync(cv => cv.ConfigId == input.Id); if (configData == null) await _sysConfigDataRep.AsInsertable(new SysUserConfigData() { UserId = _userManager.UserId, ConfigId = input.Id, Value = input.Value }).ExecuteCommandAsync(); else { configData.Value = input.Value; await _sysConfigDataRep.AsUpdateable(configData).IgnoreColumns(true).ExecuteCommandAsync(); } RemoveConfigCache(config); } /// /// 删除配置参数 🔖 /// /// /// [ApiDescriptionSettings(Name = "Delete"), HttpPost] [DisplayName("删除配置参数")] public async Task DeleteConfig(DeleteConfigInput input) { var config = await _sysConfigRep.GetByIdAsync(input.Id); // 禁止删除系统参数 if (config.SysFlag == YesNoEnum.Y) throw Oops.Oh(ErrorCodeEnum.D9001); await _sysConfigRep.DeleteAsync(config); await _sysConfigDataRep.DeleteAsync(it => it.UserId == _userManager.UserId && it.ConfigId == config.Id); RemoveConfigCache(config); } /// /// 批量删除配置参数 🔖 /// /// /// [ApiDescriptionSettings(Name = "BatchDelete"), HttpPost] [DisplayName("批量删除配置参数")] public async Task BatchDeleteConfig(List ids) { foreach (var id in ids) { var config = await _sysConfigRep.GetByIdAsync(id); // 禁止删除系统参数 if (config.SysFlag == YesNoEnum.Y) continue; await _sysConfigRep.DeleteAsync(config); await _sysConfigDataRep.DeleteAsync(it => it.UserId == _userManager.UserId && it.ConfigId == config.Id); RemoveConfigCache(config); } } /// /// 获取配置参数详情 🔖 /// /// /// [DisplayName("获取配置参数详情")] public async Task GetDetail([FromQuery] ConfigInput input) { return await VSysConfig.FirstAsync(u => u.Id == input.Id); } /// /// 根据Code获取配置参数 🔖 /// /// /// [NonAction] public async Task GetConfig(string code) { return await VSysConfig.FirstAsync(u => u.Code == code); } /// /// 根据Code获取配置参数值 🔖 /// /// 编码 /// [DisplayName("根据Code获取配置参数值")] public async Task GetConfigValueByCode(string code) { return await GetConfigValueByCode(code); } /// /// 获取配置参数值 /// /// 编码 /// 默认值 /// [NonAction] public async Task GetConfigValueByCode(string code, string defaultValue = default) { return await GetConfigValueByCode(code, defaultValue); } /// /// 获取配置参数值 /// /// 类型 /// 编码 /// 默认值 /// [NonAction] public async Task GetConfigValueByCode(string code, T defaultValue = default) { return await GetConfigValueByCode(code, _userManager.UserId, defaultValue); } /// /// 获取配置参数值 /// /// 类型 /// 编码 /// 用户Id /// 默认值 /// [NonAction] public async Task GetConfigValueByCode(string code, long userId, T defaultValue = default) { if (string.IsNullOrWhiteSpace(code)) return defaultValue; var value = _sysCacheService.Get($"{CacheConst.KeyUserConfig}{userId}{code}"); if (string.IsNullOrEmpty(value)) { value = (await VSysConfig.FirstAsync(u => u.Code == code))?.Value; _sysCacheService.Set($"{CacheConst.KeyUserConfig}{userId}{code}", value); } if (string.IsNullOrWhiteSpace(value)) return defaultValue; return (T)Convert.ChangeType(value, typeof(T)); } /// /// 更新配置参数值 /// /// /// /// [NonAction] public async Task UpdateConfigValue(string code, string value) { var config = await _sysConfigRep.GetFirstAsync(u => u.Code == code); if (config == null) return; await _sysConfigDataRep.AsUpdateable().SetColumns(it => it.Value == value).Where(it => it.UserId == _userManager.UserId && it.ConfigId == config.Id).ExecuteCommandAsync(); RemoveConfigCache(config); } /// /// 获取分组列表 🔖 /// /// [DisplayName("获取分组列表")] public async Task> GetGroupList() { return await _sysConfigRep.AsQueryable() .GroupBy(u => u.GroupCode) .Select(u => u.GroupCode).ToListAsync(); } /// /// 批量更新配置参数值 🔖 /// /// /// [ApiDescriptionSettings(Name = "BatchUpdate"), HttpPost] [DisplayName("批量更新配置参数值")] public async Task BatchUpdateConfig(List input) { foreach (var config in input) { await UpdateConfigValue(config.Code, config.Value); } } /// /// 清除配置缓存 /// /// private void RemoveConfigCache(SysUserConfig config) { _sysCacheService.Remove($"{CacheConst.KeyUserConfig}{_userManager.UserId}{config.Code}"); } }