pinganxiaoyuan/SafeCampus.API/SafeCampus.System/Services/Ops/Config/ConfigService.cs

// 








namespace SafeCampus.System;

/// <inheritdoc cref="IConfigService"/>
public class ConfigService : DbRepository<SysConfig>, IConfigService
{
    private readonly ISimpleCacheService _simpleCacheService;

    public ConfigService(ISimpleCacheService simpleCacheService)
    {
        _simpleCacheService = simpleCacheService;
    }

    #region 查询

    /// <inheritdoc/>
    public async Task<List<SysConfig>> GetConfigsByCategory(string category)
    {
        var key = SystemConst.CACHE_DEV_CONFIG + category;//系统配置key
        //先从redis拿配置
        var configList = _simpleCacheService.HashGetAll<SysConfig>(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();
    }

    /// <inheritdoc/>
    public async Task<List<SysConfig>> GetSysConfigList()
    {
        //这里不返回系统配置
        return await GetListAsync(it => it.Category != CateGoryConst.CONFIG_BIZ_DEFINE);
    }

    /// <inheritdoc/>
    public async Task<SysConfig> GetByConfigKey(string category, string configKey)
    {
        var key = SystemConst.CACHE_DEV_CONFIG + category;//系统配置key
        //先从redis拿配置
        var config = _simpleCacheService.HashGetOne<SysConfig>(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;
    }

    /// <inheritdoc/>
    public async Task<SqlSugarPagedList<SysConfig>> Page(ConfigPageInput input)
    {
        var query = Context.Queryable<SysConfig>().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;
    }

    /// <inheritdoc/>
    public async Task<FileStreamResult> 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");
    }

    /// <inheritdoc/>
    public async Task<bool> 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 添加

    /// <inheritdoc/>
    public async Task Add(ConfigAddInput input)
    {
        await CheckInput(input,true);
        var devConfig = input.Adapt<SysConfig>();//实体转换
        if (await InsertAsync(devConfig))//插入数据)
            await RefreshCache(CateGoryConst.CONFIG_BIZ_DEFINE);//刷新缓存
    }

    #endregion

    #region 编辑

    /// <inheritdoc/>
    public async Task Edit(ConfigEditInput input)
    {
        await CheckInput(input,false);
        //var devConfig = input.Adapt<SysConfig>();//实体转换
        var model = await GetByConfigKey(input.Category, input.ConfigKey);
        model.ConfigValue=input.ConfigValue;
        if (await UpdateAsync(model))//更新数据
            await RefreshCache(CateGoryConst.CONFIG_BIZ_DEFINE);//刷新缓存
    }

    /// <inheritdoc/>
    public async Task EditBatch(List<SysConfig> 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 删除

    /// <inheritdoc/>
    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 方法

    /// <summary>
    /// 刷新缓存
    /// </summary>
    /// <param name="category">分类</param>
    /// <returns></returns>
    private async Task RefreshCache(string category)
    {
        _simpleCacheService.Remove(SystemConst.CACHE_DEV_CONFIG + category);//redis删除
        await GetConfigsByCategory(category);//重新获取
    }

    /// <summary>
    /// 检查输入参数
    /// </summary>
    /// <param name="sysConfig"></param>
    private async Task CheckInput(SysConfig sysConfig,bool isAdd)
    {
        var configs = await GetConfigsByCategory(CateGoryConst.CONFIG_BIZ_DEFINE);//获取全部字典
        //判断是否从存在重复字典名
        var hasSameKey = configs.Any(it => it.ConfigKey == sysConfig.ConfigKey && it.Id != sysConfig.Id);
        if (hasSameKey== isAdd)
        {
            throw Oops.Bah($"存在重复的配置键:{sysConfig.ConfigKey}");
        }
        //设置分类为业务
        sysConfig.Category = CateGoryConst.CONFIG_BIZ_DEFINE;
    }

    #endregion 方法
}