FT/foton-wkflow-rest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

征求意见流程 分发数据丢失问题

Browse Source
This commit is contained in:
yuezhihang
2021-09-15 11:26:36 +08:00
parent 518fa5bc61
commit 9ac1fe17ad
1 changed files with 28 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/ydw/bat/wkflow/listener/StandardCommentProcess/SelectResponsibleUserAfter.java
+28 -21
View File
@@ -91,7 +91,6 @@ public class SelectResponsibleUserAfter implements TaskListener {
queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId());
BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2);
if(one1!=null){ if(one1!=null){
// one1.setOverTime(OVERTIME);
one1.setPrcType("3"); one1.setPrcType("3");
one1.setPrcName(prcName); one1.setPrcName(prcName);
one1.setCreatUser(user); one1.setCreatUser(user);
@@ -115,37 +114,45 @@ public class SelectResponsibleUserAfter implements TaskListener {
updataWapper.eq("P_ID",delegateTask.getProcessInstanceId()); updataWapper.eq("P_ID",delegateTask.getProcessInstanceId());
busBean.update(busProcessNew,updataWapper); 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()){ if(selectResponCompletedCount>=dockUserList.size()){
// Collection<Object> values = userListJson; delegateTask.setVariable("zqazqazqaUserList", delegateTask.getVariable("zs",List.class));
// Collection<Map<String,Object>> respon=new ArrayList<>();
// for (Object value : values) {
// respon.add(((JSONObject)value).getInnerMap());
// }
delegateTask.setVariable("zqazqazqaUserList",strings);
delegateTask.setVariable("datas",map); delegateTask.setVariable("datas",map);
if(nextUserList != null && !nextUserList.isEmpty()){ if(nextUserList != null && !nextUserList.isEmpty()){
List<BusProcessNew> busProcessNews=new ArrayList<>(); List<BusProcessNew> busProcessNews=new ArrayList<>();
for(String zqa : strings){ saveBusPress(delegateTask, object, strings, map, prcName, busProcessNews);
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);
}
busBean.saveBatch(busProcessNews); busBean.saveBatch(busProcessNews);
} }
}else {
List<BusProcessNew> busProcessNews=new ArrayList<>();
saveBusPress(delegateTask, object, strings, map, prcName, busProcessNews);
busBean.saveBatch(busProcessNews);
}
}
private void saveBusPress(DelegateTask delegateTask, JSONObject object, List<String> strings, Map<String, JSONObject> map, String prcName, List<BusProcessNew> 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);
} }
} }
} }