workflow_intosql.java

用java实现的工作流

package treedoc;

// 将GXL数据提交入DB的类

public class workflow_IntoSql {

  private workflow_DB_connection db1;

  private String gr;

  public workflow_IntoSql(String dd) {
    db1 = new workflow_DB_connection();
    // gr = dd;
    gr = dd;
  }

// 写EDGE方法..
  public void into_edge(String edgeid, String from, String to, String gid) {

    try {

      db1.stmt.execute(
          "insert into edge_control(edge_id,from_step,to_step,graph_id) values ('" +
          edgeid + "','" + from +
          "','" + to + "','" + gid + "')"
          );

    }

    catch (Exception e) {
    }

  }

// 写节点方法
  public void into_node(String step_name, String step_id, String gid) {
    try {

      db1.stmt.execute(
          "insert into step_main(step_name,step_id,graph_id) values ('" +
          step_name +
          "','" + step_id + "','" + gid + "')"
          );

    }

    catch (Exception e) {
    }

  }

  public void set_routedStatus_pre(String graph_id) { //设置后趋节点路由状态

    try {
      db1.rs = db1.stmt1.executeQuery(
          "select distinct(step_id) from step_main");
      while (db1.rs.next()) {
        String sid = db1.rs.getString(1);
        db1.rs1 = db1.stmt1.executeQuery(
            "select count(edge_id) from edge_control where from_step = '" + sid +
            "'");

        if (db1.rs1.next()) {
          int count = db1.rs1.getInt(1);
          if (count > 1) {
            db1.rs2 = db1.stmt1.executeQuery(
                "update step_main set is_routed = 1 where step_id = '" + sid +
                "'");
            db1.rs2.close();
          }
          db1.rs1.close();
        }

      }
      db1.rs.close();
      db1.stmt1.close();
    }
    catch (Exception e) {
    }

  }

  public void set_routedStatus_next(String graph_id) { //设置前趋节点路由状态

    try {
      db1.rs = db1.stmt1.executeQuery(
          "select distinct(step_id) from step_main");
      while (db1.rs.next()) {
        String sid = db1.rs.getString(1);
        db1.rs1 = db1.stmt1.executeQuery(
            "select count(edge_id) from edge_control where to_step = '" + sid +
            "'");

        if (db1.rs1.next()) {
          int count = db1.rs1.getInt(1);
          if (count > 1) {
            db1.rs2 = db1.stmt1.executeQuery(
                "update step_main set is_routed = 2 where step_id = '" + sid +
                "'");
            db1.rs2.close();
          }
          db1.rs1.close();
        }

      }
      db1.rs.close();
      db1.stmt1.close();
    }
    catch (Exception e) {
    }

  }

  ////////////////////////读取全部DOC的内容///////////////////////////////////////
  public java.util.ArrayList get_doccontent(String receiveid) {
   // db1.rs = null;
   // db1.stmt = null;
    java.util.ArrayList juag = new java.util.ArrayList();
    try {

      db1.rs1 = db1.stmt1.executeQuery("select * from document where receiveid = '" +
                                       receiveid + "'");

      if(db1.rs1.next()){
         juag.add( (String)db1.rs1.getString("receiveid"));
         juag.add((String)db1.rs1.getString("secret_id"));
         juag.add((String)db1.rs1.getString("sender_time"));
         juag.add((String)db1.rs1.getString("writer"));
         juag.add((String)db1.rs1.getString("writer_time"));
         juag.add((String)db1.rs1.getString("doc_type"));
         juag.add((String)db1.rs1.getString("doc_head"));
         juag.add((String)db1.rs1.getString("doc_title"));
         juag.add((String)db1.rs1.getString("mainG_department"));
         juag.add((String)db1.rs1.getString("main_chars"));
         juag.add((String)db1.rs1.getString("main_sender"));
         juag.add((String)db1.rs1.getString("second_sender"));
         juag.add((String)db1.rs1.getString("typer"));
         juag.add((String)db1.rs1.getString("changer"));
         juag.add((String)db1.rs1.getString("doc_content"));
         juag.add((String)db1.rs1.getString("doc_readers"));
      }
    }
    catch (Exception e) {
      System.out.println("读取公文" + e);
    }
    return juag;
  }

///////////////////////////////////////////////////////////////////////////////
  public void AddDoc(String receiveid, String secretid, String sendtime,
                     String writer, String writetime, String doc_type,
                     String doc_head,
                     String doc_title, String mainG_Dep, String main_Chars,
                     String main_sender, String second_sender, String Typer,
                     String changer, String Doc_content, String doc_readers) {
    int mid = 0;

    try {
      db1.rs1 = db1.stmt1.executeQuery(
          "select max(docid) from document  ");
      if (db1.rs1.next()) {
        mid = db1.rs1.getInt(1);
      }
      //   db1.stmt1.close();
    }
    catch (Exception e) {
      System.out.println("get max id" + e);
    }
    mid = mid + 1;
    double rmid = Math.random() * 1000000 * mid;
    try {
      db1.stmt1.execute(
          "insert into document values(" + mid +
          "," + rmid + ",'" + receiveid + "','" + secretid + "','" + sendtime +
          "','" +
          writer + "','" + writetime +
          "','" + doc_type + "','" + doc_head + "','" + doc_title + "','" +
          mainG_Dep + "','" +
          main_Chars + "','" + main_sender + "','" + second_sender + "','" +
          Typer + "','" + changer + "','" + Doc_content + "','" + doc_readers +
          "') ");

      db1.stmt1.close();
    }
    catch (Exception e) {
      System.out.println("INSERT" + e);
    }
  }

///////////////////////////////////////////////////////////////////////
  public boolean delDoc(String reid) {
    boolean dd = false;
    try {
      db1.stmt.execute(
          "delete from document where  receiveid = '" + reid + "'  ");
      dd = true;
    }
    catch (Exception e) {

      System.out.println("删除公文" + e);

    }
    return dd;
  }

///////////////////////////////////////////////////////////////////////
  public void DocAflow(String fid, String did) {

    try {
      db1.stmt1.execute("update flow_manager set docid = '" + did +
                        "' where flow_name = '" + fid + "'");
      db1.stmt1.close();
    }
    catch (Exception e) {
    }
  }

}