wfworkitemreldao.java

来自「公司自己开发的工作流引擎」· Java 代码 · 共 293 行

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

import java.sql.*;
import java.util.*;
import org.apache.log4j.*;
import cn.com.iaspec.workflow.db.*;
import cn.com.iaspec.workflow.*;
import cn.com.iaspec.workflow.vo.db.*;

public class WfWorkItemRelDAO{
  private static Logger logger=Logger.getLogger(WfWorkItemRelDAO.class);
  public WfWorkItemRelDAO(){
  }

  /**
   * 查询LaWorkItemRel信息
   * @param info LaWorkItemRel
   * @throws SQLException
   * @return List
   */
  public List query(WfWorkItemRel rel)
      throws SQLException{
    Connection conn=null;
    Statement stm=null;
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      stm=conn.createStatement();
      String sql=" select * from wf_workitem_rel ";
      StringBuffer sbWhere=getQueryString(rel);
      sql=sql+sbWhere.toString();
      logger.info("......query sql:"+sql);
      ResultSet rs=stm.executeQuery(sql);
      List list=this.resultsetToWorkItemRel(rs);
      return list;
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(stm,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
  }

  /**
   * 将list存贮的LaWorkItemRel信息，首先进行检查，如果数据库中不存在该记录，则往表wf_workitem_rel插入记录
   * @param list List
   * @throws Exception
   */
  public void insert(List list)
      throws Exception{
    logger.info("begin insert(List list)...");
    String sql="";
    if(list==null){
      return;
    }
    for(int i=0;i<list.size();i++){
      WfWorkItemRel rel=(WfWorkItemRel)list.get(i);
      //检查是否已经插入记录
      if(!this.checkIfExist(rel.getFromItemId(),rel.getToItemId())){
        insert(rel);
      }
    }
  }

  /**
   * 往表wf_workitem_rel插入记录
   * @param rel LaWorkItemRel
   * @throws Exception
   */
  public void insert(WfWorkItemRel rel)
      throws Exception{
    logger.info("begin insert(LaWorkItemRel rel)...");
    Connection conn=null;
    Statement stm=null;
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      stm=conn.createStatement();
      StringBuffer sbInsertValue=this.getStrInsertValues(rel);
      String sql=" insert into wf_workitem_rel ("+this.getStrFields()+") "+
          " values ("+sbInsertValue.toString()+")";
      logger.info("......insert sql:"+sql);
      stm.execute(sql);
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(stm,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
  }

  /**
   * 检查是否在数据库中是否已经存在记录
   * @param fromItemId long
   * @throws SQLException
   * @return boolean
   */
  public boolean checkIfExist(long fromItemId,long toItemId)
      throws SQLException{
    WfWorkItemRel rel=new WfWorkItemRel();
    if(fromItemId!=0){
      rel.setFromItemId(fromItemId);
    }
    rel.setToItemId(toItemId);
    List list=this.query(rel);
    if(list!=null&&list.size()>0){
      return true;
    }
    else{
      return false;
    }
  }

  private List resultsetToWorkItemRel(ResultSet rs)
      throws SQLException{
    List list=new ArrayList();
    while(rs.next()){
      WfWorkItemRel rel=new WfWorkItemRel();
      rel.setConsignId(rs.getString("consign_id"));
      rel.setFromActivityName(rs.getString("from_activity_name"));
      rel.setFromItemId(rs.getLong("from_item_id"));
      rel.setFromProInstId(rs.getLong("from_pro_inst_id"));
      rel.setFromUserId(rs.getString("from_user_id"));
      rel.setIfConsign(rs.getString("if_consign")==null?false:
          (rs.getString("if_consign").toUpperCase().equals("Y")?true:false));
      rel.setToActivityName(rs.getString("to_activity_name"));
      rel.setToItemId(rs.getLong("to_item_id"));
      rel.setToProInstId(rs.getLong("to_pro_inst_id"));

      list.add(rel);
    }
    return list;
  }

  /**
   * 取得查询条件
   * @param rel LaWorkItemRel
   * @return StringBuffer
   */
  private StringBuffer getQueryString(WfWorkItemRel rel){
    StringBuffer sb=new StringBuffer();
    if(rel!=null){
      if(rel.getConsignId()!=null&&!rel.getConsignId().equals("")){
        sb.append(" consign_id = '"+rel.getConsignId()+"' ");
        sb.append(" and ");
      }

      if(rel.getFromActivityName()!=null&&!rel.getFromActivityName().equals("")){
        sb.append(" from_activity_name = '"+rel.getFromActivityName()+"' ");
        sb.append(" and ");
      }
      if(rel.getFromItemId()!=WorkflowConstant.LONG_INIT_VALUE){
        sb.append(" from_item_id = "+rel.getFromItemId()+" ");
        sb.append(" and ");
      }
      if(rel.getFromProInstId()!=WorkflowConstant.LONG_INIT_VALUE){
        sb.append(" from_pro_inst_id = "+rel.getFromProInstId()+" ");
        sb.append(" and ");
      }
      if(rel.getFromUserId()!=null&&!rel.getFromUserId().equals("")){
        sb.append(" from_user_id = '"+rel.getFromUserId()+"' ");
        sb.append(" and ");
      }

      if(rel.getToActivityName()!=null&&!rel.getToActivityName().equals("")){
        sb.append(" to_activity_name = '"+rel.getToActivityName()+"' ");
        sb.append(" and ");
      }
      if(rel.getToItemId()!=WorkflowConstant.LONG_INIT_VALUE){
        sb.append(" to_item_id = "+rel.getToItemId()+" ");
        sb.append(" and ");
      }
      if(rel.getToProInstId()!=WorkflowConstant.LONG_INIT_VALUE){
        sb.append(" to_pro_inst_id = "+rel.getToProInstId()+" ");
        sb.append(" and ");
      }
    }
    if(sb.length()>0){
      //增加查询条件关键字
      sb.insert(0," where ");
      //去除最后一个" AND "操作符
      sb.delete(sb.length()-5,sb.length());
    }
    return sb;
  }

  /**
   * 得到本表内所有字段名，以","分开
   * @throws Exception
   * @return String
   */
  private String getStrFields()
      throws Exception{
    return "consign_id,from_activity_name,from_item_id,from_pro_inst_id,from_user_id,if_consign,to_activity_name,to_item_id,to_pro_inst_id";
  }

  /**
   * 根据info取得insert语句
   * @param info LaProcessCaseInfo
   * @throws Exception
   * @return StringBuffer
   */
  private StringBuffer getStrInsertValues(WfWorkItemRel rel)
      throws Exception{
    StringBuffer sbSQL=new StringBuffer();
    if(rel.getConsignId()!=null&&!rel.getConsignId().equals("")){
      sbSQL.append("'");
      sbSQL.append(rel.getConsignId());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(rel.getFromActivityName()!=null&&!rel.getFromActivityName().equals("")){
      sbSQL.append("'");
      sbSQL.append(rel.getFromActivityName());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(rel.getFromItemId()!=WorkflowConstant.LONG_INIT_VALUE){
      sbSQL.append(rel.getFromItemId());
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(rel.getFromProInstId()!=WorkflowConstant.LONG_INIT_VALUE){
      sbSQL.append(rel.getFromProInstId());
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(rel.getFromUserId()!=null&&!rel.getFromUserId().equals("")){
      sbSQL.append("'");
      sbSQL.append(rel.getFromUserId());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    sbSQL.append("'");
    sbSQL.append(rel.isIfConsign()?"Y":"N");
    sbSQL.append("'");
    sbSQL.append(",");

    if(rel.getToActivityName()!=null&&!rel.getToActivityName().equals("")){
      sbSQL.append("'");
      sbSQL.append(rel.getToActivityName());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(rel.getToItemId()!=WorkflowConstant.LONG_INIT_VALUE){
      sbSQL.append(rel.getToItemId());
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(rel.getToProInstId()!=WorkflowConstant.LONG_INIT_VALUE){
      sbSQL.append(rel.getToProInstId());
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    //删除最后一个逗号
    sbSQL.delete(sbSQL.length()-1,sbSQL.length());
    return sbSQL;
  }

}