1.TaskFlowControlService 方法類

package com.epf.activiti.service;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import org.activiti.engine.HistoryService;
import org.activiti.engine.ManagementService;
import org.activiti.engine.RepositoryService;
import org.activiti.engine
 
.RuntimeService;
import org.activiti.engine.TaskService;
import org.activiti.engine.history.HistoricTaskInstance;
import org.activiti.engine.impl.RepositoryServiceImpl;
import org.activiti.engine.impl.persistence.entity.ProcessDefinitionEntity;
import org.activiti.engine.impl.pvm.PvmActivity;
import org.activiti
 
.engine.impl.pvm.PvmTransition;
import org.activiti.engine.impl.pvm.process.ActivityImpl;
import org.activiti.engine.impl.pvm.process.ProcessDefinitionImpl;
import org.activiti.engine.impl.pvm.process.TransitionImpl;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task
 
.Task;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 
 * <code>TaskFlowControlService</code>  (節點自由跳轉)
 * @author   zhouxib
 * @version  V1.0
 * @date     2018 2018年8月18日 下午1:51:12
 */
@Component
public class TaskFlowControlService {
    @Autowired
    private  TaskService  taskService  ;


    @Autowired
    private ManagementService managementService;

    @Autowired
    private HistoryService historyService;

    @Autowired
    private RuntimeService runtimeService;

    @Autowired
    private RepositoryService repositoryService;

     public String rollBackWorkFlow(String taskId) {  
         try {  
             Map<String, Object> variables;  
             // 取得當前任務.當前任務節點  
             HistoricTaskInstance currTask = historyService  
                     .createHistoricTaskInstanceQuery().taskId(taskId)  
                     .singleResult();  
             // 取得流程例項，流程例項  
             ProcessInstance instance = runtimeService  
                     .createProcessInstanceQuery()  
                     .processInstanceId(currTask.getProcessInstanceId())  
                     .singleResult();  
             if (instance == null) {  
//              logger.info("流程結束");  
//              logger.error("出錯啦！流程已經結束");  
                 return "ERROR";  
             }  
             variables = instance.getProcessVariables();  
             // 取得流程定義  
             ProcessDefinitionEntity definition = (ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService)  
                     .getDeployedProcessDefinition(currTask  
                             .getProcessDefinitionId());  
             if (definition == null) {  
//                 logger.info("流程定義未找到");  
//                 logger.error("出錯啦！流程定義未找到");  
                 return "ERROR";  
             }  
             // 取得上一步活動  
             ActivityImpl currActivity = ((ProcessDefinitionImpl) definition)  
                     .findActivity(currTask.getTaskDefinitionKey());  

             //也就是節點間的連線  
             List<PvmTransition> nextTransitionList = currActivity  
                     .getIncomingTransitions();  
             // 清除當前活動的出口  
             List<PvmTransition> oriPvmTransitionList = new ArrayList<PvmTransition>();  
             //新建一個節點連線關係集合  

             List<PvmTransition> pvmTransitionList = currActivity  
                     .getOutgoingTransitions();  
             //  
             for (PvmTransition pvmTransition : pvmTransitionList) {  
                 oriPvmTransitionList.add(pvmTransition);  
             }  
             pvmTransitionList.clear();  

             // 建立新出口  
             List<TransitionImpl> newTransitions = new ArrayList<TransitionImpl>();  
             for (PvmTransition nextTransition : nextTransitionList) {  
                 PvmActivity nextActivity = nextTransition.getSource();  
                 ActivityImpl nextActivityImpl = ((ProcessDefinitionImpl) definition)  
                         .findActivity(nextActivity.getId());  
                 TransitionImpl newTransition = currActivity  
                         .createOutgoingTransition();  
                 newTransition.setDestination(nextActivityImpl);  
                 newTransitions.add(newTransition);  
             }  
             // 完成任務  
             List<Task> tasks = taskService.createTaskQuery()  
                     .processInstanceId(instance.getId())  
                     .taskDefinitionKey(currTask.getTaskDefinitionKey()).list();  
             for (Task task : tasks) {  
                 taskService.claim(task.getId(), task.getAssignee());  
                 taskService.complete(task.getId(), variables);  
                 historyService.deleteHistoricTaskInstance(task.getId());  
             }  
             // 恢復方向  
             for (TransitionImpl transitionImpl : newTransitions) {  
                 currActivity.getOutgoingTransitions().remove(transitionImpl);  
             }  
             for (PvmTransition pvmTransition : oriPvmTransitionList) {  
                 pvmTransitionList.add(pvmTransition);  
             }  
//             logger.info("OK");  
//             logger.info("流程結束");  
             return "SUCCESS";  
         } catch (Exception e) {  
//             logger.error("失敗",e);  
             return "ERROR";  
         }  
     }  


     /** 
      * 工作流自由跳轉 
      * @param taskId 要跳轉到的節點名稱 
      * @return 
      */  
     public String taskRollback(String taskId){  
         //根據要跳轉的任務ID獲取其任務  
         HistoricTaskInstance hisTask = historyService.createHistoricTaskInstanceQuery().taskId(taskId).singleResult();  
        // String taskAssignee = hisTask.getAssignee();  
         //進而獲取流程例項  
         ProcessInstance instance = runtimeService.createProcessInstanceQuery().processInstanceId(hisTask.getProcessInstanceId()).singleResult();  
         //取得流程定義  
         ProcessDefinitionEntity definition = (ProcessDefinitionEntity) repositoryService.getProcessDefinition(hisTask.getProcessDefinitionId());  
         //獲取歷史任務的Activity  
         ActivityImpl hisActivity = definition.findActivity(hisTask.getTaskDefinitionKey());  
         //實現跳轉  
         managementService.executeCommand(new JumpCmd(instance.getId(), hisActivity.getId()));  
         return hisTask.getProcessInstanceId();  
     } 

}

2.重寫的Command介面

/**
 * com.epf.activiti.service
 *
 *   ver     date           author
 * ──────────────────────────────────
 *           2018年8月18日         GZEPF
 *
 * Copyright (c) 2018, gomai.
*/

package com.epf.activiti.service;

import org.activiti.engine.impl.interceptor.Command;
import org.activiti.engine.impl.interceptor.CommandContext;
import org.activiti.engine.impl.persistence.entity.ExecutionEntity;
import org.activiti.engine.impl.pvm.process.ActivityImpl;
import org.activiti.engine.impl.pvm.process.ProcessDefinitionImpl;

/**
 *
 * @author   GZEPF
 * @version  
 * @date     2018年8月18日 下午2:48:21
 */
 public class JumpCmd implements Command<ExecutionEntity>{  

     private String processInstanceId;  
     private String activityId;  
     public static final String REASION_DELETE = "deleted";  

     public JumpCmd(String processInstanceId, String activityId) {  
         this.processInstanceId = processInstanceId;  
         this.activityId = activityId;  
     }  

     public ExecutionEntity execute(CommandContext commandContext) {  
         ExecutionEntity executionEntity = commandContext.getExecutionEntityManager().findExecutionById(processInstanceId);  
         executionEntity.destroyScope(REASION_DELETE);  
         ProcessDefinitionImpl processDefinition = executionEntity.getProcessDefinition();  
         ActivityImpl activity = processDefinition.findActivity(activityId);  
         executionEntity.executeActivity(activity);  
         return executionEntity;  
     }  

 }  

3.案例：駁回至第一個環節

@RequestMapping("runbackStater")
public R runbackStater(String processInstanceId){
    //1.獲取需要跳轉的流程環節processid
    List<HistoricTaskInstance> historicTaskInstance= historyService.createHistoricTaskInstanceQuery().processInstanceId(processInstanceId).orderByTaskCreateTime().asc().list();
    if(historicTaskInstance!=null && historicTaskInstance.size()>0){
        //2.跳轉到指定節點
        taskFlowControlService.taskRollback(historicTaskInstance.get(0).getId());
        return R.ok("操作成功！");
    }else{
        return R.error("操作失敗！");
    }


}