当前使用的BPM引擎为Activiti6.0，客户需求是流程发起人能将整个流程撤销，对于某个流程节点，办理人可以撤回已经办理的任务，同时前提是该任务节点的下个节点未被办理。

1、流程撤销

首先说下发起人对整个流程的撤销，直接删除流程，传入流程实例ID，结束一个流程。执行此方法后，流程实例的当前任务act_ru_task会被删除，流程历史act_hi_taskinst不会被删除，并且流程历史的状态置为finished完成。

runtimeService.deleteProcessInstance(instanceId, deleteReason);

2、任务撤回

已执行任务的撤回操作相对来说复杂些，这里先分步骤说下总体思路：

1）选择一条已办理任务，根据该任务查询出任务ID =myTaskId和流程实例ID=processInstanceId；

2）根据processInstanceId判断当前流程是否已结束或已挂起，流程结束或挂起则无法执行撤回操作；

3）根据myTaskId查询选择任务的历史任务实例historicTaskInstance，进而查询出对应历史活动实例historicActivityInstance，最终得到活动标识myActivityId；

4）根据活动标识myActivityId获取该任务对应的FlowNode对象myFlowNode；

5）查询出该任务节点的所有下一任务节点flowElementList，此处是任务节点Task，排查其它类型活动节点；

6）判断flowElementList中是否有代办事项，如果有则可以执行撤回操作，否则表示该任务的所有下一任务都执行完毕，此时不允许再执行撤回操作；

7）对下一节点代办任务，同样查询出对应的FlowNode对象flowNode；

8）借助FlowNode对象myFlowNode和flowNode，反方向执行一次任务，即从代办任务节点反方向流转到当前任务节点，从而完成了任务撤回操作。

完整代码如下：

public Result cancelTask(ActivitiTask doneTask) { 	try { 		// doneTask为封装的Task对象     String processInstanceId = doneTask.getInstanceId(); 		String myTaskId = doneTask.getTaskId(); 		// 校验流程是否结束 		ProcessInstance processInstance = runtimeService.createProcessInstanceQuery() 				.processInstanceId(processInstanceId).active().singleResult(); 		if(processInstance == null) { 			return Result.error("流程已结束或已挂起，无法执行撤回操作"); 		} 		// 当前任务 		HistoricTaskInstance historicTaskInstance = historyService.createHistoricTaskInstanceQuery() 				.taskId(myTaskId).processInstanceId(processInstanceId).singleResult(); 		if(historicTaskInstance==null) { 		    return Result.error("当前任务不存在，无法撤回"); 		} 		String myActivityId = null; 		List<HistoricActivityInstance> actInstList = 			historyService.createHistoricActivityInstanceQuery() 				.executionId(historicTaskInstance.getExecutionId()) 				.finished().list(); 		for(HistoricActivityInstance hai : actInstList) { 		    if(myTaskId.equals(hai.getTaskId())) { 			      myActivityId = hai.getActivityId(); 			      break; 		    } 		} 		 		BpmnModel bpmnModel = repositoryService.getBpmnModel(processInstance.getProcessDefinitionId()); 		FlowNode myFlowNode = (FlowNode) bpmnModel.getMainProcess().getFlowElement(myActivityId); 		// 获取所有下一任务节点的标识ID 		Map<String, String> taskKeyMap = Maps.newHashMap(); 		// 获取所有下一任务节点对应的FlowElement 		List<FlowElement> flowElementList = getOutgoingTask(bpmnModel, myActivityId); 		for(FlowElement flowElement : flowElementList) { 			String eleId = flowElement.getId(); 			taskKeyMap.put(eleId, eleId); 		} 		// 获取当前流程代办事项，没有代办事项表明流程结束或已挂起 		List<Task> alltaskList = taskService.createTaskQuery().processInstanceId(processInstanceId).list(); 		if(alltaskList.size() <= 0) { 			return Result.error("流程已结束或已挂起，无法执行撤回操作"); 		} 		// 判断所有下一任务节点中是否有代办任务，没有则表示任务已办理或已撤回，此时无法再执行撤回操作 		List<Task> nextTaskList = Lists.newArrayList(); 		for(Task task : alltaskList) { 			if(taskKeyMap.containsKey(task.getTaskDefinitionKey())) { 				nextTaskList.add(task); 			} 		} 		if(nextTaskList.size() <= 0) { 			return Result.error("任务已办理或已撤回，无法执行撤回操作"); 		} 		 		// 执行撤回操作 		for(Task task : nextTaskList) { 			Execution execution = runtimeService.createExecutionQuery() 			    .executionId(task.getExecutionId()).singleResult(); 		    String activityId = execution.getActivityId(); 		    FlowNode flowNode = (FlowNode) bpmnModel.getMainProcess() 			    .getFlowElement(activityId); 		    // 记录原活动方向 		    List<SequenceFlow> oriSequenceFlows = new ArrayList<SequenceFlow>(); 		    oriSequenceFlows.addAll(flowNode.getOutgoingFlows()); 		    flowNode.getOutgoingFlows().clear(); 		    // 建立新方向 		    List<SequenceFlow> newSequenceFlowList = new ArrayList<SequenceFlow>(); 		    SequenceFlow newSequenceFlow = new SequenceFlow(); 		    newSequenceFlow.setId("sid-"+UUID.randomUUID().toString()); 		    newSequenceFlow.setSourceFlowElement(flowNode); 		    newSequenceFlow.setTargetFlowElement(myFlowNode); 		    newSequenceFlowList.add(newSequenceFlow); 		    flowNode.setOutgoingFlows(newSequenceFlowList); 		    // 反方向执行任务 		    taskService.addComment(task.getId(), task.getProcessInstanceId(), "主动撤回"); 		    taskService.resolveTask(task.getId()); 		    taskService.claim(task.getId(),doneTask.getTodoUserId()); 		    taskService.complete(task.getId()); 		    flowNode.setOutgoingFlows(oriSequenceFlows); 		} 		 		return Result.success(); 	} catch (Exception e) { 		return Result.error("任务撤回失败500"); 	} }