修改单独添加域配置的方法支持为app协议ip业务添加userregion字段
This commit is contained in:
@@ -1445,7 +1445,7 @@ public class ConfigJedisServiceimpl implements ConfigRedisService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private void addTmpReion(List<Map<String, String>> regionMapList, MaatXmlConfig maatXmlConfig,
|
private void addTmpReion(List<Map<String, String>> regionMapList, MaatXmlConfig maatXmlConfig,
|
||||||
Transaction transaction, int type, int tmpStorageReuseRegionDB, int idRelaRedisDBIndex) {
|
Transaction transaction, int type, int tmpStorageReuseRegionDB, int idRelaRedisDBIndex, int service) {
|
||||||
if (regionMapList != null && regionMapList.size() > 0) {
|
if (regionMapList != null && regionMapList.size() > 0) {
|
||||||
for (Map<String, String> map : regionMapList) {
|
for (Map<String, String> map : regionMapList) {
|
||||||
List<MaatXmlExpr> expressionList = maatXmlConfig.getExpressionList();
|
List<MaatXmlExpr> expressionList = maatXmlConfig.getExpressionList();
|
||||||
@@ -1488,6 +1488,10 @@ public class ConfigJedisServiceimpl implements ConfigRedisService {
|
|||||||
for (String valStr : valSplit) {
|
for (String valStr : valSplit) {
|
||||||
if (!StringUtils.isEmpty(valStr) && valStr.trim().startsWith("[")) {
|
if (!StringUtils.isEmpty(valStr) && valStr.trim().startsWith("[")) {
|
||||||
valStr = valStr.trim().replace("[", "").replace("]", "");
|
valStr = valStr.trim().replace("[", "").replace("]", "");
|
||||||
|
if (valStr.toLowerCase().equals("op_time") && type == 12) {
|
||||||
|
String user_region = map.get("user_region");
|
||||||
|
valBF.append(user_region + "\t");
|
||||||
|
}
|
||||||
String val = map.get(valStr);
|
String val = map.get(valStr);
|
||||||
if (val != null) {
|
if (val != null) {
|
||||||
valBF.append(val);
|
valBF.append(val);
|
||||||
@@ -1500,6 +1504,7 @@ public class ConfigJedisServiceimpl implements ConfigRedisService {
|
|||||||
"未从map中获取到" + valStr + "的值,无法拼接redisValue,请检查数据或配置文件是否正确",
|
"未从map中获取到" + valStr + "的值,无法拼接redisValue,请检查数据或配置文件是否正确",
|
||||||
RestBusinessCode.NotFoundValueByKey.getValue());
|
RestBusinessCode.NotFoundValueByKey.getValue());
|
||||||
}
|
}
|
||||||
|
|
||||||
} else if (valStr.equals(" ")) {
|
} else if (valStr.equals(" ")) {
|
||||||
valBF.append(" ");
|
valBF.append(" ");
|
||||||
} else if (valStr.equals("\\t")) {// xml中是字符串的\t这里判断的时候需要转义为\\t,但是添加的时候需要添加\t不是\\t
|
} else if (valStr.equals("\\t")) {// xml中是字符串的\t这里判断的时候需要转义为\\t,但是添加的时候需要添加\t不是\\t
|
||||||
@@ -1580,11 +1585,11 @@ public class ConfigJedisServiceimpl implements ConfigRedisService {
|
|||||||
for (MaatConfig maatConfig : configList) {
|
for (MaatConfig maatConfig : configList) {
|
||||||
MaatXmlConfig maatXmlConfig = ReadMaatXmlUtil.getMaatConfigByService(37);// maat类配置的表达式都一样,这里因为没有service所以就随便取了一个
|
MaatXmlConfig maatXmlConfig = ReadMaatXmlUtil.getMaatConfigByService(37);// maat类配置的表达式都一样,这里因为没有service所以就随便取了一个
|
||||||
addTmpReion(maatConfig.getIpRegionMapList(), maatXmlConfig, transaction, 12,
|
addTmpReion(maatConfig.getIpRegionMapList(), maatXmlConfig, transaction, 12,
|
||||||
tmpStorageReuseRegionDB, idRelaRedisDBIndex);
|
tmpStorageReuseRegionDB, idRelaRedisDBIndex, maatConfig.getService());
|
||||||
addTmpReion(maatConfig.getNumRegionMapList(), maatXmlConfig, transaction, 13,
|
addTmpReion(maatConfig.getNumRegionMapList(), maatXmlConfig, transaction, 13,
|
||||||
tmpStorageReuseRegionDB, idRelaRedisDBIndex);
|
tmpStorageReuseRegionDB, idRelaRedisDBIndex, maatConfig.getService());
|
||||||
addTmpReion(maatConfig.getStrRegionMapList(), maatXmlConfig, transaction, 14,
|
addTmpReion(maatConfig.getStrRegionMapList(), maatXmlConfig, transaction, 14,
|
||||||
tmpStorageReuseRegionDB, idRelaRedisDBIndex);
|
tmpStorageReuseRegionDB, idRelaRedisDBIndex, maatConfig.getService());
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
throw new ServiceRuntimeException("添加分组复用域配置时,未发现对应的配置信息,请检查配置参数是否正确",
|
throw new ServiceRuntimeException("添加分组复用域配置时,未发现对应的配置信息,请检查配置参数是否正确",
|
||||||
|
|||||||
@@ -862,8 +862,10 @@ public class ConfigSourcesService extends BaseService {
|
|||||||
} else {
|
} else {
|
||||||
maatConfig.getIpRegionMapList().addAll(dstMapList);
|
maatConfig.getIpRegionMapList().addAll(dstMapList);
|
||||||
}
|
}
|
||||||
|
maatConfig.setService(groupReuse.getService());
|
||||||
list.add(maatConfig);
|
list.add(maatConfig);
|
||||||
}
|
}
|
||||||
|
|
||||||
// 调用接口入redis
|
// 调用接口入redis
|
||||||
logger.info("---------------调用Redis 分组复用配置新增接口---------------------");
|
logger.info("---------------调用Redis 分组复用配置新增接口---------------------");
|
||||||
configRedisService.saveGroupReuseConfig(list);
|
configRedisService.saveGroupReuseConfig(list);
|
||||||
|
|||||||
Reference in New Issue
Block a user