package com.newfiber.system.service.impl; import com.newfiber.common.core.constant.UserConstants; import com.newfiber.common.core.exception.ServiceException; import com.newfiber.common.core.text.Convert; import com.newfiber.common.core.utils.StringUtils; import com.newfiber.common.redis.service.RedisService; import com.newfiber.system.api.enums.ESystemRedisKey; import com.newfiber.system.domain.SysConfig; import com.newfiber.system.mapper.SysConfigMapper; import com.newfiber.system.service.ISysConfigService; import java.util.Collection; import java.util.List; import javax.annotation.PostConstruct; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; /** * 参数配置 服务层实现 * * @author newfiber */ @Service public class SysConfigServiceImpl implements ISysConfigService{ @Autowired private SysConfigMapper configMapper; @Autowired private RedisService redisService; /** * 项目启动时,初始化参数到缓存 */ @PostConstruct public void init(){ loadingConfigCache(); } /** * 查询参数配置信息 * * @param configId 参数配置ID * @return 参数配置信息 */ @Override 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(redisService.getCacheObject(ESystemRedisKey.Config, configKey)); if (StringUtils.isNotEmpty(configValue)){ return configValue; } SysConfig config = new SysConfig(); config.setConfigKey(configKey); SysConfig retConfig = configMapper.selectConfig(config); if (StringUtils.isNotNull(retConfig)){ redisService.setCacheObject(ESystemRedisKey.Config, 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){ redisService.setCacheObject(ESystemRedisKey.Config, config.getConfigKey(), config.getConfigValue()); } return row; } /** * 修改参数配置 * * @param config 参数配置信息 * @return 结果 */ @Override public int updateConfig(SysConfig config){ SysConfig temp = configMapper.selectConfigById(config.getConfigId()); if (!StringUtils.equals(temp.getConfigKey(), config.getConfigKey())){ redisService.deleteObject(ESystemRedisKey.Config, temp.getConfigKey()); } int row = configMapper.updateConfig(config); if (row > 0){ redisService.setCacheObject(ESystemRedisKey.Config, config.getConfigKey(), config.getConfigValue()); } return row; } /** * 批量删除参数信息 * * @param configIds 需要删除的参数ID */ @Override public void deleteConfigByIds(Long[] configIds){ for (Long configId : configIds){ SysConfig config = selectConfigById(configId); if (StringUtils.equals(UserConstants.YES, config.getConfigType())){ throw new ServiceException(String.format("内置参数【%1$s】不能删除 ", config.getConfigKey())); } configMapper.deleteConfigById(configId); redisService.deleteObject(ESystemRedisKey.Config, config.getConfigKey()); } } /** * 加载参数缓存数据 */ @Override public void loadingConfigCache(){ List<SysConfig> configsList = configMapper.selectConfigList(new SysConfig()); for (SysConfig config : configsList){ redisService.setCacheObject(ESystemRedisKey.Config, config.getConfigKey(), config.getConfigValue()); } } /** * 清空参数缓存数据 */ @Override public void clearConfigCache(){ Collection<String> keys = redisService.keys(ESystemRedisKey.Config); redisService.deleteObject(keys); } /** * 重置参数缓存数据 */ @Override public void resetConfigCache(){ clearConfigCache(); loadingConfigCache(); } /** * 校验参数键名是否唯一 * * @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; } }