package com.product.admin.service;
|
|
import com.product.admin.config.CmnCode;
|
import com.product.admin.config.CmnConst;
|
import com.product.admin.service.idel.ISystemParamSettingService;
|
import com.product.common.io.FileUtils;
|
import com.product.common.lang.StringUtils;
|
import com.product.core.dao.BaseDao;
|
import com.product.core.entity.DataTableEntity;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.exception.BaseException;
|
import com.product.core.service.support.AbstractBaseService;
|
import com.product.core.spring.context.SpringMVCContextHolder;
|
import com.product.core.transfer.Transactional;
|
import com.product.file.config.FileCode;
|
import com.product.module.sys.entity.SystemUser;
|
import com.product.util.BaseUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.io.*;
|
import java.text.SimpleDateFormat;
|
import java.util.Properties;
|
|
/**
|
* Copyright © 6c
|
*
|
* @Date: 2021-08-06 09:34
|
* @Author: 6c
|
* @Description:
|
*/
|
@Service
|
public class SystemParamSettingService extends AbstractBaseService implements ISystemParamSettingService {
|
|
@Autowired
|
public BaseDao baseDao;
|
|
/**
|
* 保存
|
* @param fse
|
*/
|
@Transactional
|
@Override
|
public String saveSetting(FieldSetEntity fse) {
|
SystemUser curUser = SpringMVCContextHolder.getCurrentUser();
|
// 保存数据
|
if (!StringUtils.isEmpty(fse.getString("operate_type"))) {
|
String uuid = fse.getUUID();
|
if (StringUtils.isEmpty(uuid)) {
|
BaseUtil.createCreatorAndCreationTime(curUser, fse);
|
} else {
|
BaseUtil.updatedRegeneratorAndUpdateTime(curUser, fse);
|
}
|
}
|
|
if(null!=fse.getString("uuid")){
|
FieldSetEntity fs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_PARAMS_SETTING, fse.getString("uuid"), false);
|
if (!fs.getString(CmnConst.PARAM_TYPE).equals(fse.getString(CmnConst.PARAM_TYPE))){
|
String type = fs.getString(CmnConst.PARAM_TYPE);
|
String key = fs.getString(CmnConst.PARAM_KEY);
|
syncProperties(type, key, null);
|
}
|
}
|
baseDao.saveFieldSetEntity(fse);
|
String type = fse.getString(CmnConst.PARAM_TYPE);
|
String key = fse.getString(CmnConst.PARAM_KEY);
|
String value = fse.getString(CmnConst.PARAM_KEY_VALUE);
|
syncProperties(type, key, value);
|
|
return fse.getUUID();
|
}
|
|
/**
|
* 删除
|
* @param fse
|
*/
|
@Transactional
|
@Override
|
public void deleteSetting(FieldSetEntity fse) {
|
FieldSetEntity recordFse = baseDao.getFieldSetEntity(fse.getTableName(), fse.getUUID(), false);
|
if (recordFse == null) {
|
return;
|
}
|
|
String type = recordFse.getString(CmnConst.PARAM_TYPE);
|
String key = recordFse.getString(CmnConst.PARAM_KEY);
|
|
syncProperties(type, key, null);
|
|
baseDao.delete(fse.getTableName(), new Object[]{fse.getUUID()});
|
}
|
|
/**
|
* 同步到properties
|
* @param type
|
* @param key
|
* @param value
|
*/
|
private void syncProperties(String type, String key, String value) {
|
String filePath = System.getProperty("user.dir") + "/src/main/resources/application.properties";
|
String sysType = getProperties(filePath).getProperty("spring.profiles.active");
|
String fileName = "";
|
if ("0".equals(type)) {
|
fileName = "application-" + sysType + ".properties";
|
} else if ("1".equals(type)) {
|
fileName = "file.properties";
|
} else if ("2".equals(type)) {
|
fileName = "cache-" + sysType + ".properties";
|
}
|
|
filePath = System.getProperty("user.dir") + "/src/main/resources/" + fileName;
|
String newContent = replaceAimKeyValue(filePath, key, value);
|
|
try {
|
File file = new File(filePath);
|
FileUtils.write(file, newContent, "utf-8");
|
} catch (IOException e) {
|
throw new BaseException(CmnCode.WRITE_FILE_FAIL.getValue(), CmnCode.WRITE_FILE_FAIL.getText(), e);
|
}
|
}
|
|
/**
|
* 替换指定key的value
|
* @param filePath
|
* @param key
|
* @param value
|
* @return 文件内容
|
*/
|
private String replaceAimKeyValue(String filePath, String key, String value) {
|
StringBuffer sb = new StringBuffer();
|
//日常指定读取的文件
|
File file = new File(filePath);
|
if (!file.exists()) {
|
System.out.println("文件不存在");
|
} else {
|
//初始化读取操作的br对象
|
BufferedReader br = null;
|
try {
|
//调用字节流,设置读取文件的编码格式
|
InputStreamReader ir = new InputStreamReader(new FileInputStream(filePath), "utf-8");
|
br = new BufferedReader(ir);
|
|
String rowContent = null;
|
boolean existFlag = false;
|
while ((rowContent = br.readLine()) != null) {
|
rowContent = rowContent.trim();
|
if (!StringUtils.isEmpty(rowContent) && !rowContent.startsWith("#") && rowContent.startsWith(key + "=")) {
|
if (value == null) {
|
// 删除
|
rowContent = null;
|
} else {
|
// 修改
|
rowContent = key + "=" + value;
|
}
|
existFlag = true;
|
}
|
if (rowContent == null) {
|
continue;
|
}
|
sb.append(rowContent).append("\n");
|
}
|
if (!existFlag) {
|
// 新增
|
sb.append(key).append("=").append(value).append("\n");
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
} finally {
|
try {
|
br.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
return sb.toString();
|
}
|
|
/**
|
* 获取指定配置文件中的信息
|
* @return
|
*/
|
private Properties getProperties(String path) {
|
Properties properties = new Properties();
|
try (FileReader reader = new FileReader(path);) {
|
properties.load(reader);
|
return properties;
|
} catch (IOException e) {
|
throw new BaseException(FileCode.LOAD_FTP_PROPERTIES_FAIL.getValue(), FileCode.LOAD_FTP_PROPERTIES_FAIL.getText(), e);
|
}
|
}
|
|
/**
|
* 初始化properties文件内容到数据库
|
*/
|
public void initSetting() {
|
String filePath = System.getProperty("user.dir") + "/src/main/resources/application.properties";
|
String sysType = getProperties(filePath).getProperty("spring.profiles.active");
|
// 基础设置
|
String fileName = "application-" + sysType + ".properties";
|
filePath = System.getProperty("user.dir") + "/src/main/resources/" + fileName;
|
initSinglePropertiesFile(filePath, "0");
|
|
// 文件设置
|
fileName = "file.properties";
|
filePath = System.getProperty("user.dir") + "/src/main/resources/" + fileName;
|
initSinglePropertiesFile(filePath, "1");
|
|
// 缓存设置
|
fileName = "cache-" + sysType + ".properties";
|
filePath = System.getProperty("user.dir") + "/src/main/resources/" + fileName;
|
initSinglePropertiesFile(filePath, "2");
|
}
|
/**
|
* 获取类型列表
|
*/
|
public DataTableEntity getTypeList(){
|
return baseDao.listTable(CmnConst.PRODUCT_SYS_DICT,"is_used=1 and dict_name='product_SYS_param_type'");
|
}
|
/**
|
* 根据类型获取数据
|
*/
|
public DataTableEntity getTypeData(FieldSetEntity fse){
|
return baseDao.listTable(CmnConst.PRODUCT_SYS_PARAMS_SETTING,"param_type=?",new String[]{fse.getString("type")});
|
}
|
/**
|
* 初始化单个文件到数据库
|
* @param path
|
* @param type
|
*/
|
private void initSinglePropertiesFile(String path, String type) {
|
Properties properties = getProperties(path);
|
properties.forEach((k, v) -> {
|
FieldSetEntity fse = new FieldSetEntity();
|
fse.setTableName(CmnConst.PRODUCT_SYS_PARAMS_SETTING);
|
fse.setValue("param_type", type);
|
fse.setValue("param_key", k);
|
fse.setValue("param_key_value", v);
|
fse.setValue("param_name", k);
|
baseDao.saveFieldSetEntity(fse);
|
});
|
}
|
}
|
