splitcaseinfocontrol.java

公司自己开发的工作流引擎

package cn.com.iaspec.workflow.engine.business;

/**
 * <p>Title: 分案处理</p>
 *
 * <p>Description: 深圳市劳动仲裁信息管理系统</p>
 *
 * <p>Copyright: Copyright (c) 2005</p>
 *
 * <p>Company: 永泰软件工程有限公司</p>
 *
 * @author syj
 * @version 1.0
 */
import java.sql.*;
import java.util.*;
import cn.com.iaspec.workflow.db.*;
import cn.com.iaspec.workflow.engine.dao.*;
import cn.com.iaspec.workflow.vo.workflow.*;
import com.sunyard.sunflow.client.*;
import com.sunyard.sunflow.engine.context.*;

public class SplitCaseInfoControl{
  WfStartableProcessDAO laStartableProcessDAO=new WfStartableProcessDAO();
  public ArrayList getSplitCaseInfoByName(UserInfo userinfo,String actName){
    ArrayList list1=null;
    ArrayList list2=null;
    ArrayList list3=null;
    ArrayList list=new ArrayList();
    try{
      list1=getTaskCaseByUser(userinfo,1,actName);
      list2=getTaskCaseByUser(userinfo,2,actName);
      list3=getTaskCaseByUser(userinfo,4,actName);
    }
    catch(Exception e){
      e.printStackTrace();
    }
    list.addAll(list1);
    list.addAll(list2);
    list.addAll(list3);
    return list;
  }

  /**
   * 分案查询（取出可分案的任务）
   * @param userinfo UserInfo
   * @param state int
   * @param actName String
   */
  public ArrayList getTaskCaseByUser(UserInfo userinfo,int state,String actName){
    System.out.println("actName is:"+actName);
    System.out.println("userinfo is:"+userinfo.getUserId());
    SunflowClient sunflowClient=WorkflowSession.getSunflowClient(userinfo);;
    WorkItemContextCollection workItemCollection=null;
    ArrayList array=new ArrayList();
    Connection connection=null;
    try{
      connection=WorkflowDBConnectionManager.getInstance().getConnection();
      laStartableProcessDAO.setConection(connection);
      workItemCollection=sunflowClient.listWorkItemsByUserID(state);
      for(int i=0;i<workItemCollection.size();i++){
        TaskCase taskcase=null;
        WorkItemContext workItem=(WorkItemContext)workItemCollection.get(i);
        if((workItem.getWorkItemName()).compareTo(actName)==0){
          long ProInstanceID=workItem.getProInstanceID();
          taskcase=laStartableProcessDAO.getTaskCaseDAO(ProInstanceID);
          if(taskcase.getRegisterNo()!=null){
            taskcase.setProInstanceID(ProInstanceID);
            taskcase.setWorkItemID(workItem.getWorkItemID());
            taskcase.setWorkItemName(workItem.getWorkItemName());
            taskcase.setWorkState(workItem.getState());
            array.add(taskcase);
          }
        }
      }
    }
    catch(Exception e){
      e.printStackTrace();
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(connection);
      WorkflowSession.deleteSunflowClient(userinfo);
    }
    if(array!=null&&array.size()>0){
      for(int i=0;i<array.size();i++){
        TaskCase task=(TaskCase)array.get(i);
        System.out.println("case_no is:"+task.getCase_no());
        System.out.println("getProInstanceID is:"+task.getProInstanceID());
        System.out.println("getRegisterNo is:"+task.getRegisterNo());
        System.out.println("getWorkItemID is:"+task.getWorkItemID());
        System.out.println("getWorkItemName is:"+task.getWorkItemName());
        System.out.println("getWorkState is:"+task.getWorkState());
      }
    }
    return array;
  }

}