activityacldao.java

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

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

import java.sql.PreparedStatement;
import java.sql.Connection;
import java.sql.SQLException;
import cn.com.iaspec.workflow.db.WorkflowDBConnectionManager;
import java.sql.ResultSet;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: IASPEC Technologies</p>
 *
 * @author Leigm
 * @version 1.0
 */

public class ActivityAclDAO{
  private Connection conn = null;
  private PreparedStatement ptmt = null;
  private ResultSet rowset = null;

  /**
   * 查询活动是否有转寄功能
   *
   * @param actiDefId long 活动ID
   * @return boolean
   * @throws Exception
   */
  public boolean getHasForwardPrivilege(long actiDefId)throws Exception{
    String privilegeVal = getActivityControlVal(actiDefId,"1");

    if("1".equals(privilegeVal)){
      return true;
    }else{
      return false;
    }
  }

  /**
   * 获取控制项的值
   *
   * @param workItemId long
   * @param controlCode String
   * @return String
   * @throws SQLException
   */
  private String getActivityControlVal(long actiDefId,String controlCode)throws SQLException{
    String sql = "select * from activityacl where atd_id = ? and aclcode = ?";

    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      ptmt=conn.prepareStatement(sql);

      ptmt.setLong(1,actiDefId);
      ptmt.setString(2,controlCode);

      rowset = ptmt.executeQuery();
      if(rowset.next()){
        return rowset.getString("aclvalue");
      }
    }catch(SQLException sqle){

      throw sqle;
    }finally{
      WorkflowDBConnectionManager.getInstance().close(rowset);
      WorkflowDBConnectionManager.getInstance().close(ptmt,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }

    return null;
  }

  public int getSignInVar(long actId)throws Exception{
    String sql = "select atr_numbvalue from actireledata where atr_atdid = ? and " +
        "atr_variablename = 'isNeedSignIn'";

    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      ptmt=conn.prepareStatement(sql);

      ptmt.setLong(1,actId);

      rowset = ptmt.executeQuery();
      if(rowset.next()){
        return rowset.getInt("atr_numbvalue");
      }
    }catch(SQLException sqle){

      throw sqle;
    }finally{
      WorkflowDBConnectionManager.getInstance().close(rowset);
      WorkflowDBConnectionManager.getInstance().close(ptmt,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }

    return -1;
  }

}