diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/cmd/CustomResetTaskApproversCmd.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/cmd/CustomResetTaskApproversCmd.java index 227ce477d..28ce6a4d2 100644 --- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/cmd/CustomResetTaskApproversCmd.java +++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/cmd/CustomResetTaskApproversCmd.java @@ -101,7 +101,10 @@ public class CustomResetTaskApproversCmd extends AbstractCommand implement // 将提级审批人加签 taskDelegateAssigners.forEach(assigner -> CustomTaskHelper.addMultiTask(commandContext, taskEntity, assigner)); // 移除该节点原审批人 - List tasks = taskService.createTaskQuery().taskDefinitionKey(taskEntity.getTaskDefinitionKey()).active().list(); + List tasks = taskService.createTaskQuery() + .processInstanceId(taskEntity.getProcessInstanceId()) + .taskDefinitionKey(taskEntity.getTaskDefinitionKey()) + .active().list(); CustomTaskHelper.deleteMultiTasks(commandContext, tasks); }