version1
admin 2 years ago
parent 7ff5fb9056
commit 40379fb4ad

@ -552,7 +552,7 @@ public class IdcServiceImpl implements IdcService {
} }
} else { } else {
success = false; success = false;
saveIdcLog(messageType,"",tableName +">fail:上传地址未连通",i *limit,total); saveIdcLog(messageType,"",syncIp+":"+tableName +">fail:上传地址未连通",i *limit,total);
} }
} else { } else {
if(!StringUtils.isEmpty(recordSql)) { if(!StringUtils.isEmpty(recordSql)) {
@ -602,16 +602,22 @@ public class IdcServiceImpl implements IdcService {
/*解析到数据库*/ /*解析到数据库*/
private boolean analyToDB(JSONObject jsonObject,MultipartFile[] files) { private boolean analyToDB(JSONObject jsonObject,MultipartFile[] files) {
if(jsonObject.getJSONObject("data")!=null) { if(jsonObject.getJSONObject("data")!=null) {
String tableName = "";
String uniqueColumn = "";
JSONObject object = jsonObject.getJSONObject("data"); JSONObject object = jsonObject.getJSONObject("data");
List<Map<String,Object>> list = new ArrayList<>(); List<Map<String,Object>> list = new ArrayList<>();
if(object instanceof List<?>) { if(object instanceof List<?>) {
list = jsonObject.getObject("data", List.class); list = jsonObject.getObject("data", List.class);
tableName = jsonObject.getString("tableName");
uniqueColumn = jsonObject.getString("uniqueColumn");
} else { } else {
list = object.getObject("data", List.class); list = object.getObject("data", List.class);
tableName = object.getString("tableName");
uniqueColumn = object.getString("uniqueColumn");
} }
if(!StringUtils.isEmpty(object.getString("tableName"))) {
return analyData(object.getString("tableName"),object.getString("uniqueColumn"),list); if(!StringUtils.isEmpty(tableName)) {
return analyData(tableName,uniqueColumn,list);
} else { } else {
logger.error("数据格式错误:无数据标记"); logger.error("数据格式错误:无数据标记");
} }
@ -620,6 +626,7 @@ public class IdcServiceImpl implements IdcService {
return false; return false;
} }
/*按表名解析数据到数据库,子表暂未处理*/ /*按表名解析数据到数据库,子表暂未处理*/
private boolean analyData(String tableName,String uniqueColumn,List<Map<String,Object>> list) { private boolean analyData(String tableName,String uniqueColumn,List<Map<String,Object>> list) {

Loading…
Cancel
Save