activiti动态创建路径

admin

/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/
package cn.gdyes.wf.workflow.manager.impl;

import cn.gdyes.wf.workflow.manager.IGeneralRejectManager;
import java.util.ArrayList;
import java.util.List;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.TaskService;
import org.activiti.engine.impl.RepositoryServiceImpl;
import org.activiti.engine.impl.persistence.entity.ExecutionEntity;
import org.activiti.engine.impl.persistence.entity.ProcessDefinitionEntity;
import org.activiti.engine.impl.persistence.entity.TaskEntity;
import org.activiti.engine.impl.pvm.PvmTransition;
import org.activiti.engine.impl.pvm.process.ActivityImpl;
import org.activiti.engine.impl.pvm.process.TransitionImpl;
import org.springframework.beans.factory.annotation.Autowired;

/**
*
* @author Administrator
*/
public class GeneralRejectManagerImpl implements IGeneralRejectManager {

    @Autowired   
    private TaskService taskService;
    @Autowired   
    private RuntimeService runtimeService;
    @Autowired   
    private RepositoryService repositoryService;

    private List<ActivityImpl> activitiList = new ArrayList();
   
    //根据ActivitiId获取Acitiviti
    public ActivityImpl findActivityImpl(List<ActivityImpl> activitiList, String activitiId) {

        for (ActivityImpl activityImpl : activitiList) {
            String id = activityImpl.getId();
            if (id.equals(activitiId)) {
                return activityImpl;
            }
        }
        return null;
    }

    public List<ActivityImpl> findEndActivityImpls(List<ActivityImpl> activitiList) {
        List<ActivityImpl> activityImpls = new ArrayList<ActivityImpl>();
        for (ActivityImpl activityImpl : activitiList) {
            List<PvmTransition> pvmTransitionList = activityImpl.getOutgoingTransitions();
            if (pvmTransitionList.isEmpty()) {
                activityImpls.add(activityImpl);
            }
        }
        return activityImpls;
    }
   
    //通用流程否决接口
    public void rejectAndEnd(String taskId) {
        
        TaskEntity taskEntity = (TaskEntity) taskService.createTaskQuery().taskId(taskId).singleResult();
        
        ProcessDefinitionEntity def = (ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService).getDeployedProcessDefinition(taskEntity.getProcessDefinitionId());
        
        
        ExecutionEntity executionEntity = (ExecutionEntity) runtimeService.createExecutionQuery().executionId(taskEntity.getExecutionId()).singleResult();//执行实例

        String activitiId = executionEntity.getActivityId();//当前实例的执行到哪个节点
        activitiList = def.getActivities();//获得当前任务的所有节点
        
        ActivityImpl activeActivity = findActivityImpl(activitiList, activitiId);
        ActivityImpl endActivity = findEndActivityImpls(activitiList).get(0);

        List<PvmTransition> pvmTransitionList = activeActivity.getOutgoingTransitions();//获取当前节点的所以出口（这个方法做的不好，应该返回List<TransitionImpl>才对的，这样就不用下面的强转换了，我想以后版本会改了这点）
        for (PvmTransition pvmTransition : pvmTransitionList) {
            TransitionImpl transitionImpl = (TransitionImpl) pvmTransition;//强转为TransitionImpl
            transitionImpl.setDestination(endActivity);
        }
        
        taskService.complete(taskId);
    }

}