package com.zbkj.service.service.impl;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.zbkj.common.config.CarManagerConfig;
|
import com.zbkj.common.constants.Constants;
|
import com.zbkj.common.exception.CarException;
|
import com.zbkj.common.request.SystemConfigAdminRequest;
|
import com.zbkj.common.request.SystemFormCheckRequest;
|
import com.zbkj.common.request.SystemFormItemCheckRequest;
|
import com.zbkj.common.utils.RedisUtil;
|
import com.zbkj.common.model.system.SystemConfig;
|
import com.zbkj.service.dao.SystemConfigDao;
|
import com.zbkj.service.service.SystemAttachmentService;
|
import com.zbkj.service.service.SystemConfigService;
|
import com.zbkj.service.service.SystemFormTempService;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* SystemConfigServiceImpl 接口实现
|
|
*/
|
@Service
|
public class SystemConfigServiceImpl extends ServiceImpl<SystemConfigDao, SystemConfig> implements SystemConfigService {
|
|
@Resource
|
private SystemConfigDao dao;
|
|
@Autowired
|
private SystemFormTempService systemFormTempService;
|
|
@Autowired
|
private SystemAttachmentService systemAttachmentService;
|
|
@Autowired
|
private RedisUtil redisUtil;
|
|
@Autowired
|
CarManagerConfig carManagerConfig;
|
|
private static final String redisKey = Constants.CONFIG_LIST;
|
|
/**
|
* 根据menu name 获取 value
|
* @param name menu name
|
* @return String
|
*/
|
@Override
|
public String getValueByKey(String name) {
|
return get(name);
|
}
|
|
|
/**
|
* 同时获取多个配置
|
* @param keys 多个配置key
|
* @return List<String>
|
*/
|
@Override
|
public List<String> getValuesByKes(List<String> keys) {
|
List<String> result = new ArrayList<>();
|
for (String key : keys) {
|
result.add(getValueByKey(key));
|
}
|
return result;
|
}
|
|
/**
|
* 根据 name 获取 value 找不到抛异常
|
* @param name menu name
|
* @return String
|
*/
|
@Override
|
public String getValueByKeyException(String name) {
|
String value = get(name);
|
if (null == value) {
|
throw new CarException("没有找到"+ name +"数据");
|
}
|
|
return value;
|
}
|
|
/**
|
* 整体保存表单数据
|
* @param systemFormCheckRequest SystemFormCheckRequest 数据保存
|
* @return boolean
|
*/
|
@Override
|
public Boolean saveForm(SystemFormCheckRequest systemFormCheckRequest) {
|
//检测form表单，并且返回需要添加的数据
|
systemFormTempService.checkForm(systemFormCheckRequest);
|
|
List<SystemConfig> systemConfigList = new ArrayList<>();
|
|
//批量添加
|
for (SystemFormItemCheckRequest systemFormItemCheckRequest : systemFormCheckRequest.getFields()) {
|
SystemConfig systemConfig = new SystemConfig();
|
systemConfig.setName(systemFormItemCheckRequest.getName());
|
String value = systemAttachmentService.clearPrefix(systemFormItemCheckRequest.getValue());
|
if (StrUtil.isBlank(value)) {
|
//去掉图片域名之后没有数据则说明当前数据就是图片域名
|
value = systemFormItemCheckRequest.getValue();
|
}
|
systemConfig.setValue(value);
|
systemConfig.setFormId(systemFormCheckRequest.getId());
|
systemConfig.setTitle(systemFormItemCheckRequest.getTitle());
|
systemConfigList.add(systemConfig);
|
}
|
|
//修改之前的数据
|
updateStatusByFormId(systemFormCheckRequest.getId());
|
|
saveBatch(systemConfigList);
|
|
//删除之前隐藏的数据
|
deleteStatusByFormId(systemFormCheckRequest.getId());
|
|
List<SystemConfig> forAsyncPram = systemConfigList.stream().map(e -> {
|
e.setStatus(true);
|
return e;
|
}).collect(Collectors.toList());
|
async(forAsyncPram);
|
|
return true;
|
}
|
|
|
|
/**
|
* updateStatusByGroupId
|
* @param formId Integer formId
|
*/
|
private void updateStatusByFormId(Integer formId) {
|
LambdaQueryWrapper<SystemConfig> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
lambdaQueryWrapper.eq(SystemConfig::getFormId, formId).eq(SystemConfig::getStatus, false);
|
|
SystemConfig systemConfig = new SystemConfig();
|
systemConfig.setStatus(true);
|
update(systemConfig, lambdaQueryWrapper);
|
|
}
|
|
/**
|
* deleteStatusByGroupId
|
* @param formId Integer formId
|
* @author Mr.Zhang
|
* @since 2020-04-16
|
*/
|
private void deleteStatusByFormId(Integer formId) {
|
LambdaQueryWrapper<SystemConfig> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
//删除已经隐藏的数据
|
lambdaQueryWrapper.eq(SystemConfig::getFormId, formId).eq(SystemConfig::getStatus, true);
|
List<SystemConfig> systemConfigList = dao.selectList(lambdaQueryWrapper);
|
dao.delete(lambdaQueryWrapper);
|
async(systemConfigList);
|
}
|
|
|
/**
|
* 保存或更新配置数据
|
* @param name 菜单名称
|
* @param value 菜单值
|
* @return boolean
|
*/
|
@Override
|
public Boolean updateOrSaveValueByName(String name, String value) {
|
value = systemAttachmentService.clearPrefix(value);
|
|
LambdaQueryWrapper<SystemConfig> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
lambdaQueryWrapper.eq(SystemConfig::getName, name);
|
List<SystemConfig> systemConfigs = dao.selectList(lambdaQueryWrapper);
|
if (systemConfigs.size() >= 2) {
|
throw new CarException("配置名称存在多个请检查配置 eb_system_config 重复数据："+name+"条数："+systemConfigs.size());
|
} else if (systemConfigs.size() == 1) {
|
systemConfigs.get(0).setValue(value);
|
updateById(systemConfigs.get(0));
|
asyncRedis(name);
|
return true;
|
} else {
|
save(new SystemConfig().setName(name).setValue(value));
|
asyncRedis(name);
|
return true;
|
}
|
}
|
|
|
/**
|
* 根据formId查询数据
|
* @param formId Integer id
|
* @return HashMap<String, String>
|
*/
|
@Override
|
public HashMap<String, String> info(Integer formId) {
|
LambdaQueryWrapper<SystemConfig> lambdaQueryWrapper1 = new LambdaQueryWrapper<>();
|
lambdaQueryWrapper1.eq(SystemConfig::getFormId, formId);
|
List<SystemConfig> systemConfigList = dao.selectList(lambdaQueryWrapper1);
|
if (ObjectUtil.isNull(systemConfigList)) {
|
return CollUtil.newHashMap();
|
}
|
HashMap<String, String> map = new HashMap<>();
|
for (SystemConfig systemConfig : systemConfigList) {
|
map.put(systemConfig.getName(), systemConfig.getValue());
|
}
|
map.put("id", formId.toString());
|
return map;
|
}
|
|
/**
|
* 根据name查询数据
|
* @param name name
|
* @return boolean
|
*/
|
@Override
|
public Boolean checkName(String name) {
|
String value = get(name);
|
return StrUtil.isBlank(value);
|
}
|
|
/**
|
* 根据key获取配置
|
* @param key key
|
* @return List
|
*/
|
@Override
|
public List<SystemConfig> getListByKey(String key) {
|
LambdaQueryWrapper<SystemConfig> lqw = Wrappers.lambdaQuery();
|
lqw.eq(SystemConfig::getName, key);
|
return dao.selectList(lqw);
|
}
|
/**
|
* 更新配置信息
|
* @param requestList 请求数组
|
* @return Boolean
|
*/
|
@Override
|
public Boolean updateByList(List<SystemConfigAdminRequest> requestList) {
|
List<SystemConfig> configList = requestList.stream().map(e -> {
|
SystemConfig systemConfig = new SystemConfig();
|
BeanUtils.copyProperties(e, systemConfig);
|
return systemConfig;
|
}).collect(Collectors.toList());
|
return updateBatchById(configList);
|
}
|
|
/**
|
* 获取颜色配置
|
* @return SystemConfig
|
*/
|
@Override
|
public SystemConfig getColorConfig() {
|
LambdaQueryWrapper<SystemConfig> lqw = Wrappers.lambdaQuery();
|
lqw.eq(SystemConfig::getName, "change_color_config");
|
lqw.eq(SystemConfig::getStatus, 0);
|
return dao.selectOne(lqw);
|
}
|
|
|
/**
|
* 把数据同步到redis
|
* @param name name
|
* @author Mr.Zhang
|
* @since 2020-04-16
|
*/
|
private void asyncRedis(String name) {
|
LambdaQueryWrapper<SystemConfig> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
lambdaQueryWrapper.eq(SystemConfig::getName, name);
|
List<SystemConfig> systemConfigList = dao.selectList(lambdaQueryWrapper);
|
if (systemConfigList.size() == 0) {
|
//说明数据已经被删除了
|
deleteRedis(name);
|
return;
|
}
|
|
async(systemConfigList);
|
}
|
|
/**
|
* 把数据同步到redis
|
* @param systemConfigList List<SystemConfig> 需要同步的数据
|
*/
|
private void async(List<SystemConfig> systemConfigList) {
|
if (!carManagerConfig.isAsyncConfig()) {
|
//如果配置没有开启
|
return;
|
}
|
for (SystemConfig systemConfig : systemConfigList) {
|
redisUtil.hmSet(redisKey, systemConfig.getName(), systemConfig.getValue());
|
}
|
}
|
|
/**
|
* 把数据同步到redis
|
* @param name String
|
* @author Mr.Zhang
|
* @since 2020-04-16
|
*/
|
private void deleteRedis(String name) {
|
if (!carManagerConfig.isAsyncConfig()) {
|
//如果配置没有开启
|
return;
|
}
|
redisUtil.hmDelete(redisKey, name);
|
}
|
|
/**
|
* 把数据同步到redis
|
* @param name String
|
* @return String
|
*/
|
private String get(String name) {
|
if (!carManagerConfig.isAsyncConfig()) {
|
//如果配置没有开启
|
LambdaQueryWrapper<SystemConfig> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
lambdaQueryWrapper.eq(SystemConfig::getStatus, false).eq(SystemConfig::getName, name);
|
SystemConfig systemConfig = dao.selectOne(lambdaQueryWrapper);
|
if (ObjectUtil.isNull(systemConfig) || StrUtil.isBlank(systemConfig.getValue())) {
|
return "";
|
}
|
return systemConfig.getValue();
|
}
|
setRedisByVoList();
|
Object data = redisUtil.hmGet(redisKey, name);
|
if (ObjectUtil.isNull(data) || StrUtil.isBlank(data.toString())) {
|
//没有找到数据
|
return "";
|
}
|
//去数据库查找，然后写入redis
|
return data.toString();
|
}
|
|
/**
|
* 把数据同步到redis, 此方法适用于redis为空的时候进行一次批量输入
|
*/
|
private void setRedisByVoList() {
|
//检测redis是否为空
|
Long size = redisUtil.getHashSize(redisKey);
|
if (size > 0 || !carManagerConfig.isAsyncConfig()) {
|
return;
|
}
|
|
LambdaQueryWrapper<SystemConfig> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
lambdaQueryWrapper.eq(SystemConfig::getStatus, false);
|
List<SystemConfig> systemConfigList = dao.selectList(lambdaQueryWrapper);
|
async(systemConfigList);
|
}
|
}
|
