camunda駁回到第一個任務節點示例

@Test
public void reject() {
 String processInstanceId="";
 String message="項目的金額款項結算不正確";
 Task task = taskService.createTaskQuery()
 .taskAssignee("admin") //當前登錄用戶的id
 .processInstanceId(processInstanceId)
 .singleResult();
 ActivityInstance tree = runtimeService.getActivityInstance(processInstanceId);
 List<HistoricActivityInstance> resultList = historyService
 .createHistoricActivityInstanceQuery()
 .processInstanceId(processInstanceId)
 .activityType("userTask")
 .finished()
 .orderByHistoricActivityInstanceEndTime()
 .asc()
 .list();
 //得到第一個任務節點的id
 HistoricActivityInstance historicActivityInstance = resultList.get(0);
 String toActId = historicActivityInstance.getActivityId();
 String assignee = historicActivityInstance.getAssignee();
 //設置流程中的可變參數
 Map<String, Object> taskVariable = new HashMap<>(2);
 taskVariable.put("user", assignee);
 taskVariable.put("formName", "項目建設");
 taskService.createComment(task.getId(), processInstanceId, "駁回原因:" + message);
 runtimeService.createProcessInstanceModification(processInstanceId)
 .cancelActivityInstance(getInstanceIdForActivity(tree, task.getTaskDefinitionKey()))//關閉相關任務
 .setAnnotation("進行了駁回到第一個任務節點操作")
 .startBeforeActivity(toActId)//啟動目標活動節點
 .setVariables(taskVariable)//流程的可變參數賦值
 .execute();
}
private String getInstanceIdForActivity(ActivityInstance activityInstance, String activityId) {
 ActivityInstance instance = getChildInstanceForActivity(activityInstance, activityId);
 if (instance != null) {
 return instance.getId();
 }
 return null;
}

private ActivityInstance getChildInstanceForActivity(ActivityInstance activityInstance, String activityId) {
 if (activityId.equals(activityInstance.getActivityId())) {
 return activityInstance;
 }
 for (ActivityInstance childInstance : activityInstance.getChildActivityInstances()) {
 ActivityInstance instance = getChildInstanceForActivity(childInstance, activityId);
 if (instance != null) {
 return instance;
 }
 }
 return null;
}