diff --git a/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BussUtils.java b/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BussUtils.java index 41207189..cbe13f17 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BussUtils.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BussUtils.java @@ -54,6 +54,12 @@ public class BussUtils { queryWrapper1.eq("TASK_ID", delegateTask.getId()); BusProcessNew one1 = busBean.getOne(queryWrapper1); if (one1 != null) { + one1.setMsgType("clause"); + one1.setPId(delegateTask.getProcessInstanceId()); + one1.setMesg(object.toJSONString()); + one1.setTaskInfo(delegateTask.getTaskDefinitionKey()); + one1.setFinishFlag("0"); + one1.setTaskInfo(delegateTask.getName()); one1.setPrcName(prcName); one1.setCommitFlag(commitFlag); one1.setCommitText(object.getString("commentText")); @@ -78,6 +84,12 @@ public class BussUtils { queryWrapper1.eq("TASK_ID", delegateTask.getId()); BusProcessNew one1 = busBean.getOne(queryWrapper1); if (one1 != null) { + one1.setMsgType("clause"); + one1.setPId(delegateTask.getProcessInstanceId()); + one1.setMesg(object.toJSONString()); + one1.setTaskInfo(delegateTask.getTaskDefinitionKey()); + one1.setFinishFlag("0"); + one1.setTaskInfo(delegateTask.getName()); one1.setPrcName(prcName); one1.setCommitFlag(commitFlag); one1.setCommitText(object.getString("commentText"));