workflowlogdao.java

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

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

/**
 * <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.*;
import cn.com.iaspec.workflow.vo.workflow.*;

public class WorkflowLogDAO{
  /**
   * 根据申诉登记号码查询流程实例ID
   * @param register_no String
   * @return List
   */
  public ArrayList getWorkflowLogInfo(String register_no)
      throws WorkFlowLogInfoException{
    ArrayList list=new ArrayList();
    ResultSet rs=null;
    java.sql.PreparedStatement prep=null;
    Connection conn=null;

    String sql="select t.pro_inst_id, t.parent_pro_inst_id,t.flow_type from wf_process_case_info t where t.case_register_id=?";
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      prep=conn.prepareStatement(sql);
      prep.setString(1,register_no);
      rs=prep.executeQuery();
      while(rs.next()){
        workflowLogInfo workflowlogInfo=new workflowLogInfo();
        workflowlogInfo.setRegisterNO(register_no);
        workflowlogInfo.setProInstanceID(rs.getLong("pro_inst_id"));
        workflowlogInfo.setFproInstanceID(rs.getLong("parent_pro_inst_id"));
        workflowlogInfo.setFlowtype(WorkitemStateName.getInstanceName(rs.getInt(
            "flow_type")));
        list.add(workflowlogInfo);
      }

    }
    catch(Exception e){
      e.printStackTrace();
      throw new WorkFlowLogInfoException("根据申诉登记号查询所有的流程实例异常。");
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(rs);
      WorkflowDBConnectionManager.getInstance().close(prep,false);
      WorkflowDBConnectionManager.getInstance().close(conn);

    }
    return list;
  }

  /**
   * 取到流程活动工作项的送达人
   * @param conn Connection
   * @param workItemID long
   * @return String
   */
  public String getSendWorkflowUserName(Connection conn,long workItemID)
      throws WorkFlowLogInfoException{
    ResultSet rs=null;
    java.sql.PreparedStatement prep=null;
    String sendUserName=null;
    String sql="select b.user_name from wf_workitem_rel a,wf_user b "+
        " where b.user_id=a.from_user_id and a.to_item_id=?";
    try{
      prep=conn.prepareStatement(sql);
      prep.setLong(1,workItemID);
      rs=prep.executeQuery();
      while(rs.next()){
        sendUserName=rs.getString("user_name");
      }

    }
    catch(Exception e){
      e.printStackTrace();
      throw new WorkFlowLogInfoException("根据工作项ID查询工作项的送达人异常。");
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(rs);
      WorkflowDBConnectionManager.getInstance().close(prep,false);
    }

    return sendUserName;
  }

  /**
   * 取到流程活动工作项的办理人
   * @param conn Connection
   * @param workItemID long
   * @return String
   */
  public String getTransactionWorkflowUserName(Connection conn,String userID)
      throws WorkFlowLogInfoException{
    ResultSet rs=null;
    java.sql.PreparedStatement prep=null;
    String UserName=null;
    String sql="select t.user_name from wf_user t where t.user_id=?";
    try{
      prep=conn.prepareStatement(sql);
      prep.setString(1,userID);
      rs=prep.executeQuery();
      while(rs.next()){
        UserName=rs.getString("user_name");
      }

    }
    catch(Exception e){
      e.printStackTrace();
      throw new WorkFlowLogInfoException("根据UsrINdID查询工作项的办理人名称异常。");
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(rs);
      WorkflowDBConnectionManager.getInstance().close(prep,false);
    }

    return UserName;
  }

  /**
   * 取得可以查看该活动对应的信息的人员集合
   * @param work_id long
   * @return ArrayList
   */
  public ArrayList getPurviewUserList(long work_id)
      throws WorkFlowLogInfoException{
    ArrayList list=new ArrayList();
    ResultSet rs=null;
    java.sql.PreparedStatement prep=null;
    Connection conn=null;
    String sql="select * from v_worklog where wki_id='"+work_id+"'";
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      prep=conn.prepareStatement(sql);
      rs=prep.executeQuery();
      while(rs.next()){
        String user_id=rs.getString("user_id");
        System.out.println("wki_id="+rs.getString("wki_id")+"---user_id="+
            user_id);
        list.add(user_id);
      }

    }
    catch(Exception e){
      throw new WorkFlowLogInfoException("取得可以查看该活动对应的信息的人员集合异常。");
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(rs);
      WorkflowDBConnectionManager.getInstance().close(prep,false);
      WorkflowDBConnectionManager.getInstance().close(conn);

    }
    return list;
  }
}