master
admin 2 years ago
parent 19fff9038b
commit 33777da1ca

@ -274,6 +274,8 @@ public class IdcServiceImpl implements IdcService {
JSONObject json = JSONObject.parseObject(result); JSONObject json = JSONObject.parseObject(result);
if(isLastLevel()) { if(isLastLevel()) {
success = analyToDB(json,files); success = analyToDB(json,files);
if(!success)
logger.info("fetchData-->解析失败");
} else { } else {
syncAddTaskStatus(json,false,success); syncAddTaskStatus(json,false,success);
} }
@ -602,17 +604,19 @@ public class IdcServiceImpl implements IdcService {
/*解析到数据库*/ /*解析到数据库*/
private boolean analyToDB(JSONObject jsonObject,MultipartFile[] files) { private boolean analyToDB(JSONObject jsonObject,MultipartFile[] files) {
if(!StringUtils.isEmpty(jsonObject.getString("tableName"))) { if(jsonObject.getJSONObject("data")!=null) {
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);
} else { } else {
object = jsonObject;
if(object.get("data")!=null) if(object.get("data")!=null)
list = object.getObject("data", List.class); list = object.getObject("data", List.class);
} }
return analyData(jsonObject.getString("tableName"),jsonObject.getString("uniqueColumn"),list); if(!StringUtils.isEmpty(object.getString("tableName")))
return analyData(object.getString("tableName"),jsonObject.getString("uniqueColumn"),list);
//图片处理 //图片处理
} }
return false; return false;

Loading…
Cancel
Save