diff --git a/com.awspaas.user.apps.app20221008163300/src/com/awspaas/user/apps/app/event/ProcessEndAfterEvent.java b/com.awspaas.user.apps.app20221008163300/src/com/awspaas/user/apps/app/event/ProcessEndAfterEvent.java index f9d792d8..6895915c 100644 --- a/com.awspaas.user.apps.app20221008163300/src/com/awspaas/user/apps/app/event/ProcessEndAfterEvent.java +++ b/com.awspaas.user.apps.app20221008163300/src/com/awspaas/user/apps/app/event/ProcessEndAfterEvent.java @@ -88,9 +88,9 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList String publshId = byProcess.getString("PUBLISHUSPROSSINSID"); // 发布流程发布节点任务Id String sql = "SELECT ID FROM WFH_TASK WHERE PROCESSINSTID = '" + publshId - + "' AND ACTIVITYDEFID = 'obj_c9e5a3144b200001b68cffa01ed0153e' "; - String taskInd = DBSql.getString(sql); - TaskInstance taskInst = SDK.getTaskAPI().getInstanceById(taskInd); + + "' AND ACTIVITYDEFID = 'obj_c9e5a3144b200001b68cffa01ed0153e' order by ENDTIME desc"; + List taskInd = DBSql.getMaps(sql); + TaskInstance taskInst = SDK.getTaskAPI().getInstanceById(taskInd.get(0).getString("ID")); BO publishBo = SDK.getBOAPI().getByProcess("BO_ACT_COE_PUBLISH", publshId); // 发送岗位 @@ -248,69 +248,6 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList } } - /* // 按人员推送 - String fsUserIds = byProcess.getString("PUBLISHTOUSER"); - if (UtilString.isNotEmpty(fsUserIds)) { - String[] split = fsUserIds.split(","); - for (String uid : split) { - arr.add(uid); - UserModel user = SDK.getORGAPI().getUser(uid); - if (user != null) { - String positionNo = user.getPositionNo(); - postSb.append(positionNo).append(","); - } - } - - if (UtilString.isNotEmpty(post)) { - newPost = post + "," + postSb.toString(); - } else { - newPost = postSb.toString(); - } - System.err.println("补充推送岗位权限========》" + newPost); - } else { - // 按部门补充推送 - String depIds = byProcess.getString("PUBLISHTODEPT"); - if (UtilString.isNotEmpty(depIds)) { - if (UtilString.isNotEmpty(org)) { - newOrg = org + "," + depIds; - } else { - newOrg = depIds; - } - System.err.println("补充推送部门权限==========》" + newOrg); - if (UtilString.isNotEmpty(depIds)) { - String[] split = depIds.split(","); - for (String depId : split) { - getUserList(arr, depId); - } - } - } - // 按岗位推送 - String s_post = byProcess.getString("POSTPERM"); - if (UtilString.isNotEmpty(s_post)) { - if (UtilString.isNotEmpty(post)) { - newPost = post + "," + s_post; - } else { - newPost = s_post; - } - System.err.println("补充推送岗位权限==========》" + newOrg); - ArrayList sendPost = sendPost(s_post, arr, publshId); - arr = sendPost; - } - - // 按职级补充推送 - String s_level = byProcess.getString("LEVELPERM"); - if (UtilString.isNotEmpty(s_level)) { - if (UtilString.isNotEmpty(level)) { - newLevel = level + "," + s_level; - } else { - newLevel = s_level; - } - System.err.println("补充推送部门权限==========》" + newOrg); - ArrayList sendLevel = sendLevel(s_level, arr, publshId); - arr = sendLevel; - } - - }*/ /* // 重新添加权限 if (UtilString.isNotEmpty(newOrg) || UtilString.isNotEmpty(newPost) || UtilString.isNotEmpty(newLevel)) { @@ -610,9 +547,10 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList Element result = rootElement.element("Body").element("serviceResponse").element("out"); String resultString = result.getData().toString(); JSONObject jsonObject1 = JSON.parseObject(resultString); + System.out.println("Data>>>>>>>>>>>>>"+jsonObject1); String datas = jsonObject1.getString("data"); String status = jsonObject1.getString("status"); - // System.out.println("推送》》》》》》》》》》》" + status); + System.out.println("推送》》》》》》》》》》》" + status); if ("false".equals(status)) { System.out.println(processInstance.getTitle() + "待阅推送失败:" + userId); try {