//
namespace SafeCampus.System;
///
public class ConfigService : DbRepository, IConfigService
{
private readonly ISimpleCacheService _simpleCacheService;
public ConfigService(ISimpleCacheService simpleCacheService)
{
_simpleCacheService = simpleCacheService;
}
#region 查询
///
public async Task> GetConfigsByCategory(string category)
{
var key = SystemConst.CACHE_DEV_CONFIG + category;//系统配置key
//先从redis拿配置
var configList = _simpleCacheService.HashGetAll(key).Values.ToList();
if (configList.Count == 0)
{
//redis没有再去数据可拿
var configs = await GetListAsync(it => it.Category == category);//获取系统配置列表
if (configs.Count > 0)
{
configList = configs;
_simpleCacheService.HashSet(key, configList.ToDictionary(it => it.ConfigKey));//如果不为空,插入redis
}
}
return configList.ToList();
}
///
public async Task> GetSysConfigList()
{
//这里不返回系统配置
return await GetListAsync(it => it.Category != CateGoryConst.CONFIG_BIZ_DEFINE);
}
///
public async Task GetByConfigKey(string category, string configKey)
{
var key = SystemConst.CACHE_DEV_CONFIG + category;//系统配置key
//先从redis拿配置
var config = _simpleCacheService.HashGetOne(key, configKey);
if (config == null)
{
//redis没有再去数据可拿
config = await GetFirstAsync(it => it.Category == category && it.ConfigKey == configKey);//获取系统配置
if (config != null)
{
await GetConfigsByCategory(category);//获取全部字典,并插入redis
}
}
return config;
}
///
public async Task> Page(ConfigPageInput input)
{
var query = Context.Queryable().Where(it => it.Category == CateGoryConst.CONFIG_BIZ_DEFINE)//自定义配置
.WhereIF(!string.IsNullOrEmpty(input.SearchKey),
it => it.ConfigKey.Contains(input.SearchKey) || it.ConfigValue.Contains(input.SearchKey))//根据关键字查询
.OrderByIF(!string.IsNullOrEmpty(input.SortField), $"{input.SortField} {input.SortOrder}")//排序
.OrderBy(it => it.SortCode)
.OrderBy(it => it.CreateTime);//排序
var pageInfo = await query.ToPagedListAsync(input.PageNum, input.PageSize);//分页
return pageInfo;
}
///
public async Task GetIco()
{
var config = await GetByConfigKey(CateGoryConst.CONFIG_SYS_BASE, SysConfigConst.SYS_ICO);//获取系统配置 ico
var icoBase64 = config.ConfigValue.Split(",")[1];//获取ico的base64
//转为byte数组
var bytes = Convert.FromBase64String(icoBase64);
//将byte数组转为流
var stream = new MemoryStream(bytes);
return new FileStreamResult(stream, "image/x-icon");
}
///
public async Task IsTenant()
{
var tenantOption = await GetByConfigKey(CateGoryConst.CONFIG_SYS_BASE, SysConfigConst.SYS_TENANT_OPTIONS);
var isTenant = tenantOption.ConfigValue != SysDictConst.TENANT_OPTIONS_CLOSE;//是否开启多租户
return isTenant;
}
#endregion
#region 添加
///
public async Task Add(ConfigAddInput input)
{
await CheckInput(input);
var devConfig = input.Adapt();//实体转换
if (await InsertAsync(devConfig))//插入数据)
await RefreshCache(CateGoryConst.CONFIG_BIZ_DEFINE);//刷新缓存
}
#endregion
#region 编辑
///
public async Task Edit(ConfigEditInput input)
{
await CheckInput(input);
var devConfig = input.Adapt();//实体转换
if (await UpdateAsync(devConfig))//更新数据
await RefreshCache(CateGoryConst.CONFIG_BIZ_DEFINE);//刷新缓存
}
///
public async Task EditBatch(List devConfigs)
{
if (devConfigs.Count > 0)
{
//根据分类分组
var configGroups = devConfigs.GroupBy(it => it.Category).ToList();
//遍历分组
foreach (var item in configGroups)
{
var configList = await GetConfigsByCategory(item.Key);//获取系统配置
var configs = item.ToList();//获取分组完的配置列表
var keys = configs.Select(it => it.ConfigKey).ToList();//获取key列表
configList = configList.Where(it => keys.Contains(it.ConfigKey)).ToList();//获取要修改的列表
//遍历配置列表
configList.ForEach(it =>
{
//赋值ConfigValue
it.ConfigValue = configs.Where(c => c.ConfigKey == it.ConfigKey).First().ConfigValue;
});
//更新数据
if (await UpdateRangeAsync(configList))
await RefreshCache(item.Key);//刷新缓存
}
}
}
#endregion
#region 删除
///
public async Task Delete(ConfigDeleteInput input)
{
//获取所有业务配置
var configs = await GetConfigsByCategory(CateGoryConst.CONFIG_BIZ_DEFINE);
if (configs.Any(it => it.Id == input.Id))//如果有当前配置
{
if (await DeleteByIdAsync(input.Id))//删除配置
await RefreshCache(CateGoryConst.CONFIG_BIZ_DEFINE);//刷新缓存
}
}
#endregion
#region 方法
///
/// 刷新缓存
///
/// 分类
///
private async Task RefreshCache(string category)
{
_simpleCacheService.Remove(SystemConst.CACHE_DEV_CONFIG + category);//redis删除
await GetConfigsByCategory(category);//重新获取
}
///
/// 检查输入参数
///
///
private async Task CheckInput(SysConfig sysConfig)
{
var configs = await GetConfigsByCategory(CateGoryConst.CONFIG_BIZ_DEFINE);//获取全部字典
//判断是否从存在重复字典名
var hasSameKey = configs.Any(it => it.ConfigKey == sysConfig.ConfigKey && it.Id != sysConfig.Id);
if (hasSameKey)
{
throw Oops.Bah($"存在重复的配置键:{sysConfig.ConfigKey}");
}
//设置分类为业务
sysConfig.Category = CateGoryConst.CONFIG_BIZ_DEFINE;
}
#endregion 方法
}