From 9ac1fe17ad57a95fc04e796812af03ea7d6e1b6c Mon Sep 17 00:00:00 2001 From: yuezhihang Date: Wed, 15 Sep 2021 11:26:36 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BE=81=E6=B1=82=E6=84=8F=E8=A7=81=E6=B5=81?= =?UTF-8?q?=E7=A8=8B=20=E5=88=86=E5=8F=91=E6=95=B0=E6=8D=AE=E4=B8=A2?= =?UTF-8?q?=E5=A4=B1=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../SelectResponsibleUserAfter.java | 49 +++++++++++-------- 1 file changed, 28 insertions(+), 21 deletions(-) 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); } } }