actiparticipantdao.java

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

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 ActiParticipantDAO{
  private static Logger logger=Logger.getLogger(ActiInsReleDataDAO.class);
  public ActiParticipantDAO(){
  }

  /**
   * 查询组织信息，关联到表wf_area中
   * @param org LaOrganization
   * @throws SQLException
   * @return List
   */
  public List query(ActiParticipant parti)
      throws SQLException{
    Connection conn=null;
    Statement stm=null;
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      stm=conn.createStatement();
      String sql=" select * from actiparticipant ";
      StringBuffer sbWhere=getQueryString(parti);
      sql=sql+sbWhere.toString();
      logger.info("......query sql:"+sql);
      ResultSet rs=stm.executeQuery(sql);
      List list=resultsetToActiParticipant(rs);
      return list;
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(stm,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
  }

  private List resultsetToActiParticipant(ResultSet rs)
      throws SQLException{
    List list=new ArrayList();
    while(rs.next()){
      ActiParticipant parti=new ActiParticipant();
      parti.setAtpAssignMethod(rs.getInt("atp_assignmethod"));
      parti.setAtpAtdId(rs.getLong("atp_atdid"));
      parti.setAtpCondition(rs.getString("atp_condition"));
      parti.setAtpDesc(rs.getString("atp_desc"));
      parti.setAtpOption(rs.getInt("atp_option"));
      parti.setAtpParticipantId(rs.getLong("atp_participantid"));
      parti.setAtpPartiName(rs.getString("atp_partiname"));
      parti.setAtpPartiType(rs.getInt("atp_partitype"));
      parti.setAtpSettingMode(rs.getInt("atp_settingmode"));
      list.add(parti);
    }
    return list;
  }

  private StringBuffer getQueryString(ActiParticipant parti){
    StringBuffer sb=new StringBuffer();
    if(parti!=null){
      if(parti.getAtpAssignMethod()!=WorkflowConstant.INT_INIT_VALUE){
        sb.append(" atp_assignmethod = "+parti.getAtpAssignMethod()+" ");
        sb.append(" and ");
      }
      if(parti.getAtpAtdId()!=WorkflowConstant.LONG_INIT_VALUE){
        sb.append(" atp_atdid = "+parti.getAtpAtdId()+" ");
        sb.append(" and ");
      }
      if(parti.getAtpCondition()!=null&&!parti.getAtpCondition().equals("")){
        sb.append(" atp_condition = '"+parti.getAtpCondition()+"' ");
        sb.append(" and ");
      }
      if(parti.getAtpDesc()!=null&&!parti.getAtpDesc().equals("")){
        sb.append(" atp_desc = '"+parti.getAtpDesc()+"' ");
        sb.append(" and ");
      }
      if(parti.getAtpOption()!=WorkflowConstant.INT_INIT_VALUE){
        sb.append(" atp_option = "+parti.getAtpOption()+" ");
        sb.append(" and ");
      }
      if(parti.getAtpParticipantId()!=WorkflowConstant.LONG_INIT_VALUE){
        sb.append(" atp_participantid = "+parti.getAtpParticipantId()+" ");
        sb.append(" and ");
      }
      if(parti.getAtpPartiName()!=null&&!parti.getAtpPartiName().equals("")){
        sb.append(" atp_partiname = '"+parti.getAtpPartiName()+"' ");
        sb.append(" and ");
      }
      if(parti.getAtpPartiType()!=WorkflowConstant.INT_INIT_VALUE){
        sb.append(" atp_partitype = "+parti.getAtpPartiType()+" ");
        sb.append(" and ");
      }
      if(parti.getAtpSettingMode()!=WorkflowConstant.INT_INIT_VALUE){
        sb.append(" atp_settingmode = "+parti.getAtpSettingMode()+" ");
        sb.append(" and ");
      }
    }
    //增加查询条件关键字
    if(sb.length()>0){
      //增加查询条件关键字
      sb.insert(0," where ");
      //去除最后一个" AND "操作符
      sb.delete(sb.length()-5,sb.length());
    }
    return sb;
  }

}