diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessTaskServiceImpl.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessTaskServiceImpl.java index f2a7c828d..20de3a14a 100644 --- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessTaskServiceImpl.java +++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessTaskServiceImpl.java @@ -459,10 +459,13 @@ public class BpmnProcessTaskServiceImpl implements BpmnProcessTaskService { task.setPriority(parentTask.getPriority()); task.setCreateTime(new Date()); - Execution subExecution = runtimeService.createExecutionQuery() - .parentId(parentTask.getExecutionId()) // 将新执行实例设置为当前执行实例的子实例 - .activityId(parentTask.getTaskDefinitionKey()) // 指定活动ID - .singleResult(); + Execution subExecution = runtimeService.addMultiInstanceExecution(parentTask.getTaskDefinitionKey(), parentTask.getProcessInstanceId(), null); +// ExecutionEntity concurrentExecution = CommandContextUtil.getExecutionEntityManager() +// .createChildExecution((ExecutionEntity) multiInstanceRootExecution); +// Execution subExecution = runtimeService.createExecutionQuery() +// .parentId(parentTask.getExecutionId()) // 将新执行实例设置为当前执行实例的子实例 +// .activityId(parentTask.getTaskDefinitionKey()) // 指定活动ID +// .singleResult(); task.setExecutionId(subExecution.getId()); log.info("流程加签父任务:{},正在创建加签子任务:{},", parentTaskId, JSONUtil.toJsonStr(Lists.newArrayList(task))); taskService.saveTask(task);