diff --git a/src/main/java/com/glxp/api/service/sync/HeartService.java b/src/main/java/com/glxp/api/service/sync/HeartService.java index 69ddaf48d..b00230ce1 100644 --- a/src/main/java/com/glxp/api/service/sync/HeartService.java +++ b/src/main/java/com/glxp/api/service/sync/HeartService.java @@ -515,6 +515,11 @@ public class HeartService { public void pullBasicData() { String data = spGetHttp.pullBasicData(); cn.hutool.json.JSONObject obj = JSONUtil.parseObj(data); + Integer code = obj.getInt("code"); + if (!code.equals(ResultVOUtils.success().getCode())) { + log.error("从UDI自助平台拉取基础数据错误,报文-----{}", data); + return; + } SpsSyncBasicDataResponse bean = obj.get("data", SpsSyncBasicDataResponse.class); this.insertBasicData(bean); String taskId = bean.getTaskId(); @@ -543,6 +548,11 @@ public class HeartService { public void pullOtherData() { String data = spGetHttp.pullOtherData(); cn.hutool.json.JSONObject obj = JSONUtil.parseObj(data); + Integer code = obj.getInt("code"); + if (!code.equals(ResultVOUtils.success().getCode())) { + log.error("从UDI自助平台拉取其他数据,报文-----{}", data); + return; + } SpsSyncOtherDataResponse bean = obj.get("data", SpsSyncOtherDataResponse.class); this.insertOtherData(bean); String taskId = bean.getTaskId();