diff --git a/main/java/shkd/bamp/base/task/DobeDWpersonUpdateTask.java b/main/java/shkd/bamp/base/task/DobeDWpersonUpdateTask.java index 88f4d57..0af1bc8 100644 --- a/main/java/shkd/bamp/base/task/DobeDWpersonUpdateTask.java +++ b/main/java/shkd/bamp/base/task/DobeDWpersonUpdateTask.java @@ -59,10 +59,14 @@ public class DobeDWpersonUpdateTask extends AbstractTask implements Plugin { log.info(String.format("人员接口异常:%s", e.getMessage())); throw new RuntimeException(e); } + boolean personoabid = false; + if(map != null && "yes".equals(map.get("personoabid"))){ + personoabid = true; + } JSONObject json_body = JSON.parseObject(resultData); //接口返回的数据进行了分页 int totalNum = json_body.getIntValue("totalNum");//分页-SQL查询总数据量 - handleUser(json_body); + handleUser(json_body,personoabid); int queryCount = DobeDWUtils.getQueryCount(totalNum); if(queryCount > 1){ //查询次数不止一次,需要分页查询 @@ -81,13 +85,13 @@ public class DobeDWpersonUpdateTask extends AbstractTask implements Plugin { throw new RuntimeException(e); } json_body = JSON.parseObject(resultData); - handleUser(json_body); + handleUser(json_body,personoabid); } } } - private void handleUser(JSONObject json_body) { + private void handleUser(JSONObject json_body,boolean personoabid) { //解析接口返回值,与系统数据比较 JSONArray detailsJson = json_body.getJSONArray("data"); // String userID = null;