workitem.java

来自「Fire-Workflow-Engine-All-In-One-20090208」· Java 代码 · 共 379 行 · 第 1/2 页

    }

    /**
     * 签收
     * @throws org.fireflow.engine.EngineException
     * @throws org.fireflow.kenel.KenelException
     */
    public void sign() throws EngineException, KenelException {

        if (this.getState().intValue() != IWorkItem.INITIALIZED) {
            throw new EngineException("WorkItem的当前状态为" + this.getState() + "，不可以执行accept操作。");
        }
        if (this.getTaskInstance().getState().intValue() != ITaskInstance.INITIALIZED && this.getTaskInstance().getState().intValue() != ITaskInstance.STARTED) {
            throw new EngineException("TaskInstance的当前状态为" + this.getTaskInstance().getState() + "，对应的WorkItem不可以执行accept操作。");
        }
      
        IPersistenceService persistenceService = rtCtx.getPersistenceService();

        //0、首先修改workitem的状态
        this.setState(IWorkItem.STARTED);
        this.setSignedTime(rtCtx.getCalendarService().getSysDate());
        persistenceService.saveOrUpdateWorkItem(this);

        //1、如果不是会签，则删除其他的workitem
        if (Task.ANY.equals(this.getTaskInstance().getAssignmentStrategy())){
            persistenceService.deleteWorkItemsInInitializedState(this.getTaskInstance().getId());
        }
        
        //2、start taskInstance,修改相关联的workItem的状态。
        ((TaskInstance) this.getTaskInstance()).start();

    }

    public void junpToNextActivity(List<String> nextActorIds) throws EngineException, KenelException {
        junpToNextActivity(nextActorIds,false);
    }

    public void jumpTo(String activityId) throws EngineException, KenelException {
        jumpTo(activityId,null,true);
    }

    public void jumpTo(String activityId, List<String> nextActorIds) throws EngineException, KenelException {
        jumpTo(activityId,nextActorIds,false);
    }

    public void loopTo(String activityId) throws EngineException, KenelException {
        //首先找到上次的执行者，如果上次操作是汇签，怎么办？？？？？
        
        IPersistenceService persistenceService = rtCtx.getPersistenceService();
        List taskInstanceList = persistenceService.findTaskInstancesForProcessInstance(this.getTaskInstance().getProcessInstanceId(), activityId);
        if (taskInstanceList==null && taskInstanceList.size()==0){
            throw new EngineException("The activity has NOT been fired yet.");
        }
        TaskInstance tmpTaskInstance = (TaskInstance)taskInstanceList.get(0);
        if (tmpTaskInstance.getState()!=ITaskInstance.COMPLETED && tmpTaskInstance.getState()!=ITaskInstance.CANCELED){
            throw new EngineException("The activity instance is in running state.");
        }
        for (int i=1;i<taskInstanceList.size();i++){
            
            TaskInstance tmpTaskInst2 = (TaskInstance)taskInstanceList.get(i);
            if (tmpTaskInst2.getState()!=ITaskInstance.COMPLETED && tmpTaskInst2.getState()!=ITaskInstance.CANCELED){
                throw new EngineException("The activity instance is in running state.");
            }            
            if (tmpTaskInst2.getCreatedTime().after(tmpTaskInstance.getCreatedTime())){
                tmpTaskInstance = tmpTaskInst2;
            }
        }
        
        List workItems = persistenceService.findWorkItemsForTaskInstance(tmpTaskInstance.getId());
        if (workItems==null || workItems.size()==0) throw new EngineException("LoopTo action refused, have-done workitems for activity[id="+activityId+"] NOT found");
        
        List nextActorIds = new ArrayList();
        for (int i=0;i<workItems.size();i++){
            nextActorIds.add(((IWorkItem)workItems.get(i)).getActorId());
        }
        this.jumpTo(activityId,nextActorIds,false);
        /*
        List workItems = persistenceService.findHaveDoneWorkItems(this.getTaskInstance().getProcessInstance().getId(), activityId);
        
        if (workItems==null || workItems.size()==0) throw new EngineException("Not found have done workitems for activity[id="+activityId+"]");
        */
        
                
    }
    public IWorkflowSession getCurrentWorkflowSession() {
        return this.workflowSession;
    }

    public void setCurrentWorkflowSession(IWorkflowSession session) {
        this.workflowSession = session;
    }

    public void junpToNextActivity(List<String> nextActorIds, boolean needSign) throws EngineException, KenelException {
        WorkflowProcess workflowProcess = this.getTaskInstance().getWorkflowProcess();
        Activity thisActivity = this.getTaskInstance().getActivity();
        Transition leavingTransition = thisActivity.getLeavingTransition();
        if (leavingTransition==null) throw new EngineException("Next activity NOT found.");
        Synchronizer synchronizer = (Synchronizer)leavingTransition.getToNode();
        if (synchronizer==null) throw new EngineException("Next activity NOT found.");
        List leavingTransitionList = synchronizer.getLeavingTransitions();
        if (leavingTransitionList==null || leavingTransitionList.size()==0) throw new EngineException("Next activity NOT found.");
        
        leavingTransition = (Transition)leavingTransitionList.get(0);
        Activity targetActivity = (Activity)leavingTransition.getToNode();
        
        if (targetActivity==null){
            throw new EngineException("Next activity NOT found.");
        }
        
        jumpTo(targetActivity.getId(),nextActorIds,needSign);
    }

    public void jumpTo(String activityId, List<String> nextActorIds, boolean needSign) throws EngineException, KenelException {
        //首先检查是否可以正确跳转
        //1）检查是否在同一个“执行线”上
        WorkflowProcess workflowProcess = this.getTaskInstance().getWorkflowProcess();
        String thisActivityId = this.getTaskInstance().getActivityId();
        boolean isInSameLine = workflowProcess.isInSameLine(thisActivityId, activityId);
        if (!isInSameLine) throw new EngineException("Jumpto refused because of the current activitgy and the target activity are NOT in the same 'Execution Thread'.");
        
        
        //2）检查目标Activity Form Task的数量(暂时关闭该检查项目)
//        Activity targetActivity = (Activity)workflowProcess.findWFElementById(activityId);
//        int count = getFormTaskCount(targetActivity);
//        if (count!=1){
//            if (!isInSameLine) throw new EngineException("Jumpto refused because of the  FORM-type-task count of the target activitgy  is NOT 1; the count is "+count);
//        }
        
        //3)检查当前的 taskinstance是否可以结束
        if (Task.ALL.equals(this.getTaskInstance().getAssignmentStrategy())){
            IPersistenceService persistenceService = rtCtx.getPersistenceService();
            List workItemList = persistenceService.findWorkItemsForTaskInstance(this.getTaskInstance().getId());
            for (int i=0;workItemList!=null && i<workItemList.size();i++){
                IWorkItem wi = (IWorkItem)workItemList.get(i);
                if (!wi.getId().equals(this.id) && (wi.getState()!=IWorkItem.COMPLETED || wi.getState()!=IWorkItem.CANCELED)){
                    throw new EngineException("Jumpto refused because of current taskinstance can NOT be completed. some workitem of this taskinstance is in runing state or initialized state");
                }
            }
        }

        //4)检查当前的activity instance是否可以结束

        if (Activity.ALL .equals(this.getTaskInstance().getActivity().getCompletionStrategy())){
            IPersistenceService persistenceService = rtCtx.getPersistenceService();
            List taskinstanceList = persistenceService.findTaskInstancesForProcessInstance(this.getTaskInstance().getProcessInstanceId(), this.getTaskInstance().getActivityId());
            
            for (int i=0;i<taskinstanceList.size();i++){
                TaskInstance taskInst = (TaskInstance)taskinstanceList.get(i);
                if (!taskInst.getId().equals(this.getTaskInstance().getId()) 
                        && (taskInst.getState()!=ITaskInstance.COMPLETED || taskInst.getState()!=ITaskInstance.CANCELED)){
                    throw new EngineException("Jumpto refused because of current activity instance can NOT be completed. some task instance of this activity instance is in runing state or initialized state");
                }
            }
        }
        
//        this.getTaskInstance().geta
        INetInstance netInstance = rtCtx.getKenelManager().getNetInstance(workflowProcess.getId(), this.getTaskInstance().getVersion());
        if (netInstance==null) throw new EngineException("Not find the net instance for workflow process [id="+workflowProcess.getId()+", version="+ this.getTaskInstance().getVersion()+"]");
        Object obj = netInstance.getWFElementInstance(activityId);
        IActivityInstance targetActivityInstance = (IActivityInstance)obj;
        if (targetActivityInstance==null){
             throw new EngineException("Not find the activity instance  for activity[process id="+workflowProcess.getId()+", version="+ this.getTaskInstance().getVersion()+",activity id="+activityId+"]");
        }

        if (nextActorIds!=null && nextActorIds.size()>0){
            DynamicAssignmentHandler handler = new DynamicAssignmentHandler();
            handler.setActorIdsList(nextActorIds);
            handler.setNeedSign(needSign);
            ((WorkflowSession)this.workflowSession).setCurrentDynamicAssignmentHandler(handler);
        }else{
            ((WorkflowSession)this.workflowSession).setCurrentDynamicAssignmentHandler(null);
        }
        
        this.complete(targetActivityInstance);
    }
    
    protected int getFormTaskCount(Activity activity){
        int count = 0;
        List tasksList = activity.getTasks();
        for (int i=0;i<tasksList.size();i++){
            Task task = (Task)tasksList.get(i);
            if (Task.FORM.equals(task.getType())){
                count = count+1;
            }
        }
        return count;
    }
}