update 优化 任务创建监听器 使用下一个节点的任务数据

master
疯狂的狮子Li 5 months ago
parent 74e3d232f5
commit c41add355f

@ -55,6 +55,7 @@ public class FlowProcessEventHandler {
* @param flowCode * @param flowCode
* @param instance * @param instance
* @param taskId id * @param taskId id
* @param params
*/ */
public void processTaskHandler(String flowCode, Instance instance, Long taskId, Map<String, Object> params) { public void processTaskHandler(String flowCode, Instance instance, Long taskId, Map<String, Object> params) {
String tenantId = TenantHelper.getTenantId(); String tenantId = TenantHelper.getTenantId();

@ -105,6 +105,7 @@ public class WorkflowGlobalListener implements GlobalListener {
Instance instance = listenerVariable.getInstance(); Instance instance = listenerVariable.getInstance();
Definition definition = listenerVariable.getDefinition(); Definition definition = listenerVariable.getDefinition();
Task task = listenerVariable.getTask(); Task task = listenerVariable.getTask();
List<Task> nextTasks = listenerVariable.getNextTasks();
Map<String, Object> params = new HashMap<>(); Map<String, Object> params = new HashMap<>();
FlowParams flowParams = listenerVariable.getFlowParams(); FlowParams flowParams = listenerVariable.getFlowParams();
Map<String, Object> variable = new HashMap<>(); Map<String, Object> variable = new HashMap<>();
@ -129,8 +130,10 @@ public class WorkflowGlobalListener implements GlobalListener {
} }
} }
//发布任务事件 //发布任务事件
if (task != null) { if (CollUtil.isNotEmpty(nextTasks)) {
flowProcessEventHandler.processTaskHandler(definition.getFlowCode(), instance, task.getId(), params); for (Task nextTask : nextTasks) {
flowProcessEventHandler.processTaskHandler(definition.getFlowCode(), instance, nextTask.getId(), params);
}
} }
if (ObjectUtil.isNull(flowParams)) { if (ObjectUtil.isNull(flowParams)) {
return; return;

Loading…
Cancel
Save