bug 46474 修复

This commit is contained in:
yuezhihang
2021-08-12 10:27:28 +08:00
parent 86de1b2d4d
commit 6fee276ad3
@@ -36,7 +36,7 @@ public class MinisterAndDockerSignAfter implements TaskListener {
if(delegateTask.getVariable("actionFlag",Integer.class)==0){ if(delegateTask.getVariable("actionFlag",Integer.class)==0){
if("1".equals(object.getString("actionFlag"))){ if("1".equals(object.getString("actionFlag"))){
delegateTask.setVariable("actionFlag",1); delegateTask.setVariable("actionFlag",1);
nextUserList.add(delegateTask.getVariable("startUser",String.class)); // nextUserList.add(delegateTask.getVariable("startUser",String.class));
} }
} }
@@ -82,6 +82,10 @@ public class MinisterAndDockerSignAfter implements TaskListener {
busBean.update(busProcessNew,updataWapper); busBean.update(busProcessNew,updataWapper);
Integer count=delegateTask.getVariable("task3OKCount",Integer.class); Integer count=delegateTask.getVariable("task3OKCount",Integer.class);
Integer gose=0;
if (null!=delegateTask.getVariable("task3Count",Integer.class)){
gose=delegateTask.getVariable("task3Count",Integer.class);
}
List<String> userList=delegateTask.getVariable("userList",List.class); List<String> userList=delegateTask.getVariable("userList",List.class);
if(delegateTask.getVariable("actionFlag",Integer.class)==0){ if(delegateTask.getVariable("actionFlag",Integer.class)==0){
@@ -89,6 +93,8 @@ public class MinisterAndDockerSignAfter implements TaskListener {
count++; count++;
delegateTask.setVariable("task3OKCount",count); delegateTask.setVariable("task3OKCount",count);
} }
delegateTask.setVariable("task3Count",gose+1);
if (gose+1==userList.size()) {
if (count >= userList.size()) { if (count >= userList.size()) {
if (delegateTask.getVariable("actionFlag", Integer.class) == 0) { if (delegateTask.getVariable("actionFlag", Integer.class) == 0) {
if (nextUserList != null && !nextUserList.isEmpty()) { if (nextUserList != null && !nextUserList.isEmpty()) {
@@ -123,6 +129,18 @@ public class MinisterAndDockerSignAfter implements TaskListener {
busProcessNewNext.setUserId(delegateTask.getVariable("startUser", String.class)); busProcessNewNext.setUserId(delegateTask.getVariable("startUser", String.class));
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
} }
}else {
BusProcessNew busProcessNewNext = new BusProcessNew();
busProcessNewNext.setMsgType("clause");
busProcessNewNext.setPId(delegateTask.getProcessInstanceId());
busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName());
busProcessNewNext.setUserId(delegateTask.getVariable("startUser",String.class));
busBean.save(busProcessNewNext);
}
delegateTask.setVariable("task3Count",0);
} }
} }