workflow_control.java

用java实现的工作流

package treedoc;

// 功能

// WORKFLOW客户处理层和底层的接口,功能是调用workflow_engine获得流程访问序列
// 通知服务器调用活动节点对应的USERID开始处理预先定义的活动,并将需要处理的数
// 据提交给客户处理界面
// 一旦客户处理完成,返回该类,则重新激活workflow_engine,进行下一个节点的处理流程
// 该类主要为JSP客户端来调用////////////////

/**
 * 名称       : WORKFLOW_CONTROL
 * 描述       : WWW.FANGFA.NET 工作流管理系统--流程运行控制类/客户端驱动
 * 版权信息   : Copyright (c) 2004 COMSCI
 * @作者      : COMSCI Sichuan Fangfa Digital
 * @版本      : 0.9 builder 2004091910
 * @日期      : 2004/09/19
 */




public class workflow_Control {
  private static workflow_StepMain stm;
  private workflow_DB_connection db_conn;
  public workflow_Control() {

    db_conn = new workflow_DB_connection();
    stm = new workflow_StepMain("");
  }

  //获得开始运行的FLOW的ID,如果无活动FLOW则返回0
  public java.util.ArrayList Scan_flowstatus() {
    java.util.ArrayList aflow = new java.util.ArrayList();
    try {
      db_conn.rs = db_conn.stmt.executeQuery
          ("select flow_name from flow_manager where flow_status = 1 ");
      while (db_conn.rs.next()) {
        aflow.add( (String) db_conn.rs.getString("flow_name"));
      }
    //  db_conn.stmt.close();
    //  db_conn.rs.close();
    }
    catch (Exception e) {
      System.out.println(e + "异常发生");
    }
    return aflow;
  }

  // 得到活动FLOW的用户ID
  public java.util.ArrayList get_actived_step() {

    java.util.ArrayList flow = this.Scan_flowstatus();
    java.util.ArrayList sid = new java.util.ArrayList();
    if (!flow.isEmpty()) {
      for (int i = 0; i < flow.size(); i++) {
        sid.add(stm.is_step_active(flow.get(i).toString()));

      }
    }
    return sid;
  }


  public java.util.ArrayList get_uid() {
   java.util.ArrayList uid = new java.util.ArrayList();
   // java.util.ArrayList sidd = this.get_actived_step();

   try {
     if (!this.get_actived_step().isEmpty()) {
       for (int i = 0; i < this.get_actived_step().size(); i++) {
         db_conn.rs1 = db_conn.stmt1.executeQuery
             ("select user_id from step_detail where step_id = '" +
              this.get_actived_step().get(i) +
              "' ");
         while (db_conn.rs1.next()) {
           uid.add(db_conn.rs1.getString("user_id"));
         }
       }
       //   db_conn.stmt1.close();
       db_conn.rs1.close();
     }
   }
   catch (Exception e) {
     System.out.println(e);
   }

   return uid;
 }




 public static void main(String argv[]) {

   workflow_Control wc = new workflow_Control();
   java.util.ArrayList uid = wc.get_uid();
   if (!uid.isEmpty()) {

     for (int i = 0; i < uid.size(); i++) {
       System.out.println(uid.get(i));

     }
   }
 }



  //调用workflow_engine得到该FLOW的当前活动stepID(如果是开始节点则,开始运行engine,如果是结束点,则输出over
  // public String get_ActiveStepId(String flowid) {}

  // 主动/被动通知系统中该用户ID,提醒用户调用处理程序
  // 在服务器页面上维持刷新
}