优化:通道同步任务 增加：根据用户统计未读总数

liusuyi

2024-07-23 811b14aa5cd2bd6d4313b43dc38ce87cd938f3b0

 ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysConfigServiceImpl.java

@@ -4,8 +4,10 @@
import java.util.List;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import javax.management.Query;

import org.springframework.beans.factory.annotation.Autowired;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ruoyi.common.utils.MessageUtils;
import org.springframework.stereotype.Service;
import com.ruoyi.common.annotation.DataSource;
import com.ruoyi.common.constant.CacheConstants;
@@ -15,13 +17,13 @@
import com.ruoyi.common.enums.DataSourceType;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.system.domain.SysConfig;
import com.ruoyi.common.core.domain.entity.SysConfig;
import com.ruoyi.system.mapper.SysConfigMapper;
import com.ruoyi.system.service.ISysConfigService;

/**
 * 参数配置 服务层实现
 * 
 *
 * @author ruoyi
 */
@Service
@@ -44,7 +46,7 @@

    /**
     * 查询参数配置信息
     * 
     *
     * @param configId 参数配置ID
     * @return 参数配置信息
     */
@@ -54,12 +56,19 @@
    {
        SysConfig config = new SysConfig();
        config.setConfigId(configId);
        return configMapper.selectConfig(config);
        SysConfig sysConfig = configMapper.selectConfig(config);
        //国际化
        String message = MessageUtils.message("config." + sysConfig.getConfigNameI18n());
        if(StringUtils.isNotEmpty(message))
        {
            sysConfig.setConfigName(message);
        }
        return sysConfig;
    }

    /**
     * 根据键名查询参数配置信息
     * 
     *
     * @param configKey 参数key
     * @return 参数键值
     */
@@ -84,7 +93,7 @@

    /**
     * 获取验证码开关
     * 
     *
     * @return true开启，false关闭
     */
    @Override
@@ -99,19 +108,27 @@
    }
    /**
     * 查询参数配置列表
     * 
     *
     * @param config 参数配置信息
     * @return 参数配置集合
     */
    @Override
    public List<SysConfig> selectConfigList(SysConfig config)
    {
        return configMapper.selectConfigList(config);
        List<SysConfig> sysConfigs = configMapper.selectConfigList(config);
        //国际化
        sysConfigs.stream().forEach(sysConfig -> {
            String message = MessageUtils.message("config." + sysConfig.getConfigNameI18n());
            if (StringUtils.isNotEmpty(message)) {
                sysConfig.setConfigName(message);
            }
        });
        return sysConfigs;
    }

    /**
     * 新增参数配置
     * 
     *
     * @param config 参数配置信息
     * @return 结果
     */
@@ -128,7 +145,7 @@

    /**
     * 修改参数配置
     * 
     *
     * @param config 参数配置信息
     * @return 结果
     */
@@ -151,7 +168,7 @@

    /**
     * 批量删除参数信息
     * 
     *
     * @param configIds 需要删除的参数ID
     */
    @Override
@@ -204,7 +221,7 @@

    /**
     * 校验参数键名是否唯一
     * 
     *
     * @param config 参数配置信息
     * @return 结果
     */
@@ -222,7 +239,7 @@

    /**
     * 设置cache key
     * 
     *
     * @param configKey 参数键
     * @return 缓存键key
     */
@@ -230,4 +247,41 @@
    {
        return CacheConstants.SYS_CONFIG_KEY + configKey;
    }

    @Override
    public String getSYURL() {
        List<SysConfig> result = configMapper.selectByType("syCarPT");
        if(result.size() > 0){
            String SYURL = result.get(0).getConfigValue();
            return SYURL;
        }else{
            return "";
        }
    }

    @Override
    public String getSYVideo() {
        List<SysConfig> result = configMapper.selectByType("threeOneVideo");
        if(result.size() > 0){
            String SYURL = result.get(0).getConfigValue();
            return SYURL;
        }else{
            return "";
        }
    }

    @Override
    public String getHealth() {
        List<SysConfig> result = configMapper.selectByType("health");
        if(result.size() > 0){
            return result.get(0).getConfigValue();
        }else{
            return "";
        }
    }

    @Override
    public List<SysConfig> getAccPwd() {
        return configMapper.selectList(new QueryWrapper<SysConfig>().in("config_key","eqHealthUrl","eqHealthAccount","eqHealthPassword"));
    }
}