You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
188 lines
5.1 KiB
188 lines
5.1 KiB
package com.ruoyi.system.service.impl; |
|
|
|
import java.util.Collection; |
|
import java.util.List; |
|
import javax.annotation.PostConstruct; |
|
import org.springframework.beans.factory.annotation.Autowired; |
|
import org.springframework.stereotype.Service; |
|
import com.ruoyi.common.annotation.DataSource; |
|
import com.ruoyi.common.constant.Constants; |
|
import com.ruoyi.common.constant.UserConstants; |
|
import com.ruoyi.common.core.redis.RedisCache; |
|
import com.ruoyi.common.core.text.Convert; |
|
import com.ruoyi.common.enums.DataSourceType; |
|
import com.ruoyi.common.utils.StringUtils; |
|
import com.ruoyi.system.domain.SysConfig; |
|
import com.ruoyi.system.mapper.SysConfigMapper; |
|
import com.ruoyi.system.service.ISysConfigService; |
|
|
|
/** |
|
* 参数配置 服务层实现 |
|
* |
|
* @author ruoyi |
|
*/ |
|
@Service |
|
public class SysConfigServiceImpl implements ISysConfigService |
|
{ |
|
@Autowired |
|
private SysConfigMapper configMapper; |
|
|
|
@Autowired |
|
private RedisCache redisCache; |
|
|
|
/** |
|
* 项目启动时,初始化参数到缓存 |
|
*/ |
|
@PostConstruct |
|
public void init() |
|
{ |
|
List<SysConfig> configsList = configMapper.selectConfigList(new SysConfig()); |
|
for (SysConfig config : configsList) |
|
{ |
|
redisCache.setCacheObject(getCacheKey(config.getConfigKey()), config.getConfigValue()); |
|
} |
|
} |
|
|
|
/** |
|
* 查询参数配置信息 |
|
* |
|
* @param configId 参数配置ID |
|
* @return 参数配置信息 |
|
*/ |
|
@Override |
|
@DataSource(DataSourceType.MASTER) |
|
public SysConfig selectConfigById(Long configId) |
|
{ |
|
SysConfig config = new SysConfig(); |
|
config.setConfigId(configId); |
|
return configMapper.selectConfig(config); |
|
} |
|
|
|
/** |
|
* 根据键名查询参数配置信息 |
|
* |
|
* @param configKey 参数key |
|
* @return 参数键值 |
|
*/ |
|
@Override |
|
public String selectConfigByKey(String configKey) |
|
{ |
|
String configValue = Convert.toStr(redisCache.getCacheObject(getCacheKey(configKey))); |
|
if (StringUtils.isNotEmpty(configValue)) |
|
{ |
|
return configValue; |
|
} |
|
SysConfig config = new SysConfig(); |
|
config.setConfigKey(configKey); |
|
SysConfig retConfig = configMapper.selectConfig(config); |
|
if (StringUtils.isNotNull(retConfig)) |
|
{ |
|
redisCache.setCacheObject(getCacheKey(configKey), retConfig.getConfigValue()); |
|
return retConfig.getConfigValue(); |
|
} |
|
return StringUtils.EMPTY; |
|
} |
|
|
|
/** |
|
* 查询参数配置列表 |
|
* |
|
* @param config 参数配置信息 |
|
* @return 参数配置集合 |
|
*/ |
|
@Override |
|
public List<SysConfig> selectConfigList(SysConfig config) |
|
{ |
|
return configMapper.selectConfigList(config); |
|
} |
|
|
|
/** |
|
* 新增参数配置 |
|
* |
|
* @param config 参数配置信息 |
|
* @return 结果 |
|
*/ |
|
@Override |
|
public int insertConfig(SysConfig config) |
|
{ |
|
int row = configMapper.insertConfig(config); |
|
if (row > 0) |
|
{ |
|
redisCache.setCacheObject(getCacheKey(config.getConfigKey()), config.getConfigValue()); |
|
} |
|
return row; |
|
} |
|
|
|
/** |
|
* 修改参数配置 |
|
* |
|
* @param config 参数配置信息 |
|
* @return 结果 |
|
*/ |
|
@Override |
|
public int updateConfig(SysConfig config) |
|
{ |
|
int row = configMapper.updateConfig(config); |
|
if (row > 0) |
|
{ |
|
redisCache.setCacheObject(getCacheKey(config.getConfigKey()), config.getConfigValue()); |
|
} |
|
return row; |
|
} |
|
|
|
/** |
|
* 批量删除参数信息 |
|
* |
|
* @param configIds 需要删除的参数ID |
|
* @return 结果 |
|
*/ |
|
@Override |
|
public int deleteConfigByIds(Long[] configIds) |
|
{ |
|
int count = configMapper.deleteConfigByIds(configIds); |
|
if (count > 0) |
|
{ |
|
Collection<String> keys = redisCache.keys(Constants.SYS_CONFIG_KEY + "*"); |
|
redisCache.deleteObject(keys); |
|
} |
|
return count; |
|
} |
|
|
|
/** |
|
* 清空缓存数据 |
|
*/ |
|
@Override |
|
public void clearCache() |
|
{ |
|
Collection<String> keys = redisCache.keys(Constants.SYS_CONFIG_KEY + "*"); |
|
redisCache.deleteObject(keys); |
|
} |
|
|
|
/** |
|
* 校验参数键名是否唯一 |
|
* |
|
* @param config 参数配置信息 |
|
* @return 结果 |
|
*/ |
|
@Override |
|
public String checkConfigKeyUnique(SysConfig config) |
|
{ |
|
Long configId = StringUtils.isNull(config.getConfigId()) ? -1L : config.getConfigId(); |
|
SysConfig info = configMapper.checkConfigKeyUnique(config.getConfigKey()); |
|
if (StringUtils.isNotNull(info) && info.getConfigId().longValue() != configId.longValue()) |
|
{ |
|
return UserConstants.NOT_UNIQUE; |
|
} |
|
return UserConstants.UNIQUE; |
|
} |
|
|
|
/** |
|
* 设置cache key |
|
* |
|
* @param configKey 参数键 |
|
* @return 缓存键key |
|
*/ |
|
private String getCacheKey(String configKey) |
|
{ |
|
return Constants.SYS_CONFIG_KEY + configKey; |
|
} |
|
}
|
|
|