agendao.java

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

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

import java.util.HashMap;
import org.apache.log4j.Logger;
import java.sql.Statement;
import java.sql.Connection;
import cn.com.iaspec.workflow.db.WorkflowDBConnectionManager;
import java.sql.ResultSet;
import java.util.ArrayList;
import cn.com.iaspec.workflow.vo.workflow.ActivityAgenInfo;

/**
 *
 * <p>Title: </p>
 * <p>Description: 任务代理dao</p>
 * <p>Copyright: Copyright (c) 2006</p>
 * <p>Company: iASPEC Technologies</p>
 * @author xiesonglin
 * @version 1.5
 */
public class AgenDAO{
  private static Logger logger=Logger.getLogger(AgenDAO.class);
  public AgenDAO(){

  }

  /**
   * 取得活动的代理信息
   * @param activitys 活动uid数组
   * @return HashMap
   */
  public HashMap getActivityAgenInfo(String[] activityUids)
      throws Exception{
    Connection conn=null;
    Statement stm=null;
    HashMap map=new HashMap();
    if(activityUids==null||activityUids.length<=0){
      return null;
    }
    String ids="";
    for(int i=0;i<activityUids.length;i++){
      ids=ids+",'"+activityUids[i]+"'";
    }
    if(ids.length()>0){
      //去掉“,”
      ids=ids.substring(1);
    }
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      stm=conn.createStatement();
      //查询活动在有效的时间内是否有代理
      String sql=
          " select distinct a.activity_uid,b.consign_user_id,b.agen_user_id from "+
          "  wf_agen_activity a inner join wf_agen_register b on a.agen_id=b.agen_id "+
          " and b.agen_state='agen' and trunc(sysdate)>=b.begin_date or (b.end_date is not null and trunc(sysdate)<=b.end_date) "+
          " where a.activity_uid in ("+
          ids+") "+
          " order by a.activity_uid,b.consign_user_id,b.agen_user_id ";
      logger.info("......query sql:"+sql);
      ResultSet rs=stm.executeQuery(sql);

      while(rs.next()){
        ActivityAgenInfo agenInfo=new ActivityAgenInfo();
        agenInfo.setUid(rs.getString("activity_uid"));
        agenInfo.setAgenUserId(rs.getString("agen_user_id"));
        agenInfo.setConsignUserId(rs.getString("consign_user_id"));
        ArrayList list=null;
        if(map.containsKey(agenInfo.getUid())){
          list=(ArrayList)map.get(agenInfo.getUid());
        }
        else{
          list=new ArrayList();
        }
        list.add(agenInfo);
        map.put(agenInfo.getUid(),list);
      }
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(stm,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
    return map;
  }

}