diff --git a/src/main/java/com/ydw/bat/wkflow/listener/StandardCommentProcess/SelectResponsibleUserAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/StandardCommentProcess/SelectResponsibleUserAfter.java index 5b4b8925..6314ef74 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/StandardCommentProcess/SelectResponsibleUserAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/StandardCommentProcess/SelectResponsibleUserAfter.java @@ -91,7 +91,6 @@ public class SelectResponsibleUserAfter implements TaskListener { queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ -// one1.setOverTime(OVERTIME); one1.setPrcType("3"); one1.setPrcName(prcName); one1.setCreatUser(user); @@ -115,37 +114,45 @@ public class SelectResponsibleUserAfter implements TaskListener { updataWapper.eq("P_ID",delegateTask.getProcessInstanceId()); busBean.update(busProcessNew,updataWapper); + if (null==delegateTask.getVariable("zs")) { + delegateTask.setVariable("zs", strings); + }else { + delegateTask.getVariable("zs",List.class).addAll(strings); + delegateTask.setVariable("zs",delegateTask.getVariable("zs") ); + } if(selectResponCompletedCount>=dockUserList.size()){ -// Collection values = userListJson; -// Collection> respon=new ArrayList<>(); -// for (Object value : values) { -// respon.add(((JSONObject)value).getInnerMap()); -// } - delegateTask.setVariable("zqazqazqaUserList",strings); + delegateTask.setVariable("zqazqazqaUserList", delegateTask.getVariable("zs",List.class)); delegateTask.setVariable("datas",map); if(nextUserList != null && !nextUserList.isEmpty()){ List busProcessNews=new ArrayList<>(); - for(String zqa : strings){ - BusProcessNew busProcessNewNext = new BusProcessNew(); - busProcessNewNext.setMsgType("clause"); - busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); -// object.put("dockUser",(String)zqa.get("dockUser")); - object.put("dockUser",map.get(zqa).getString("dockUser")); - busProcessNewNext.setMesg(object.toJSONString()); - busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); - busProcessNewNext.setFinishFlag("0"); - busProcessNewNext.setTaskInfo(delegateTask.getName()); - busProcessNewNext.setUserId(map.get(zqa).getString("id")); - busProcessNewNext.setPrcName(prcName); - busProcessNews.add(busProcessNewNext); - } + saveBusPress(delegateTask, object, strings, map, prcName, busProcessNews); busBean.saveBatch(busProcessNews); } + }else { + List busProcessNews=new ArrayList<>(); + saveBusPress(delegateTask, object, strings, map, prcName, busProcessNews); + busBean.saveBatch(busProcessNews); + } + } + + private void saveBusPress(DelegateTask delegateTask, JSONObject object, List strings, Map map, String prcName, List busProcessNews) { + for (String zqa : strings) { + BusProcessNew busProcessNewNext = new BusProcessNew(); + busProcessNewNext.setMsgType("clause"); + busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); + object.put("dockUser", map.get(zqa).getString("dockUser")); + busProcessNewNext.setMesg(object.toJSONString()); + busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); + busProcessNewNext.setFinishFlag("0"); + busProcessNewNext.setTaskInfo(delegateTask.getName()); + busProcessNewNext.setUserId(map.get(zqa).getString("id")); + busProcessNewNext.setPrcName(prcName); + busProcessNews.add(busProcessNewNext); } } }