wfmanageroleauthorizationdao.java

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

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

import cn.com.iaspec.workflow.db.WorkflowDBConnectionManager;
import org.apache.log4j.Logger;
import java.sql.Statement;
import java.sql.Connection;
import cn.com.iaspec.workflow.vo.db.WfManageRoleAuthorization;
import cn.com.iaspec.workflow.util.GetTableSequenceId;
import java.util.List;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Hashtable;

public class WfManageRoleAuthorizationDAO{
  private static Logger logger=Logger.getLogger(WfManageRoleAuthorizationDAO.class);
  private String dataBaseType=WorkflowDBConnectionManager.getInstance().
      getDataBaseType();

  public WfManageRoleAuthorizationDAO(){
    super();
  }

  public String insertManageAuthorization(WfManageRoleAuthorization authorziation,
      String authorziationType)
      throws Exception{
    logger.info("begin insert(WfManageRoleAuthorization authorziation)...");
    Connection conn=null;
    Statement stm=null;
    String sql=null;
    String keyId=null;
    try{

      if(authorziationType.equals("org")){
        keyId = GetTableSequenceId.getTableId("WF_ROLE_MANAGE_ORG");
        sql=
            "insert into WF_ROLE_MANAGE_ORG (ROLE_ORG_ID,ROLE_ID,ORG_ID) values('"+
            keyId+"','"+
            authorziation.getManageRoleId()+"','"+authorziation.getManagedId()+
            "')";
      }
      else if(authorziationType.equals("user")){
        keyId=GetTableSequenceId.getTableId("WF_ROLE_MANAGE_USER");
        sql=
            "insert into WF_ROLE_MANAGE_USER (ROLE_USER_ID,ROLE_ID,USER_ID) values('"+
            keyId +"','"+
            authorziation.getManageRoleId()+"','"+authorziation.getManagedId()+
            "')";
      }
      else if(authorziationType.equals("role")){
        keyId= GetTableSequenceId.getTableId("WF_ROLE_MANAGE_ROLE");
        sql="insert into WF_ROLE_MANAGE_ROLE (ROLE_MANAGEDROLE_ID,ROLE_ID,MANAGED_ROLE_ID) values('"+
            keyId +"','"+
            authorziation.getManageRoleId()+"','"+authorziation.getManagedId()+
            "')";
      }
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      stm=conn.createStatement();
      logger.info("......insert sql:"+sql);
      stm.execute(sql);
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(stm,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
    return keyId;
  }

  public void insertOperationAuthorization(String role_managed_id, String operation_id)
     throws Exception{
   logger.info("begin insertOperationAuthorization()...");
   Connection conn=null;
   Statement stm=null;
   String sql=null;
   try{
       sql="insert into WF_MANAGED_OPERATION_AUTH (ROLE_MANAGED_ID,OPERATION_ID,OPERATION_VALUE) values('"+
           role_managed_id +"','"+operation_id+"','1')";
     conn=WorkflowDBConnectionManager.getInstance().getConnection();
     stm=conn.createStatement();
     logger.info("......insert sql:"+sql);
     stm.execute(sql);
   }
   finally{
     WorkflowDBConnectionManager.getInstance().close(stm,false);
     WorkflowDBConnectionManager.getInstance().close(conn);
   }
 }


  public void insert(List authorizationList,String authorizationType,List orgOperationList)
      throws Exception{
    logger.info("begin insert(List authorizationList)...");
    String  role_managed_id = null;
    String orgOperationId =null;
    if(authorizationList!=null&&authorizationList.size()>0){
      for(int i=0;i<authorizationList.size();i++){
        WfManageRoleAuthorization authorization=(WfManageRoleAuthorization)
            authorizationList.get(i);
        if(!checkExists(authorization,authorizationType)){
          role_managed_id = insertManageAuthorization(authorization,authorizationType);
          if (orgOperationList!=null && orgOperationList.size()>0 && authorization.isHavaOperationAuthorization()){
            for(int j=0;j<orgOperationList.size();j++){
                 orgOperationId = (String)orgOperationList.get(j);
                 insertOperationAuthorization(role_managed_id,orgOperationId);
            }
          }
        }
      }
    }
  }

  /**
   * 检查是否已经存在记录
   * @param rel WfOrgUserRole
   * @return boolean
   */
  public boolean checkExists(WfManageRoleAuthorization authorization,
      String authorizationType)
      throws Exception{
    logger.info("begin checkExists...");
    boolean b=false;
    if(authorization!=null){
      List list=query(authorization,authorizationType);
      if(list!=null&&list.size()>0){
        b=true;
      }
    }
    return b;
  }

  public List query(WfManageRoleAuthorization authorization,
      String authorizationType)
      throws SQLException{
    Connection conn=null;
    Statement stm=null;
    String sql = null;
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      stm=conn.createStatement();
      if(authorizationType.equals("role")){
         sql=" select * from WF_ROLE_MANAGE_ROLE ";
      }else  if(authorizationType.equals("org")){
         sql=" select * from WF_ROLE_MANAGE_ORG ";
      }else  if(authorizationType.equals("user")){
         sql=" select * from WF_ROLE_MANAGE_USER ";
      }
      StringBuffer sbWhere=getQueryString(authorization,authorizationType);
      sql=sql+sbWhere.toString();
      logger.info("......query sql:"+sql);
      ResultSet rs=stm.executeQuery(sql);
      List list=resultsetToVO(rs,authorizationType);
      return list;
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(stm,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
  }

  private StringBuffer getQueryString(WfManageRoleAuthorization authorization,
      String authorizationType){
    StringBuffer sb=new StringBuffer();
    if(authorization!=null){
      if(authorizationType.equals("role")){
        if(authorization.getManageRoleId()!=null&&
            !authorization.getManageRoleId().equals("")){
          sb.append(" ROLE_ID = '"+authorization.getManageRoleId()+"' ");
          sb.append(" and ");
        }
        if(authorization.getManagedId()!=null&&
            !authorization.getManagedId().equals("")){
          sb.append(" MANAGED_ROLE_ID = '"+authorization.getManagedId()+"' ");
          sb.append(" and ");
        }
      }
      else if(authorizationType.equals("org")){
        if(authorization.getManageRoleId()!=null&&
            !authorization.getManageRoleId().equals("")){
          sb.append(" ROLE_ID = '"+authorization.getManageRoleId()+"' ");
          sb.append(" and ");
        }
        if(authorization.getManagedId()!=null&&
            !authorization.getManagedId().equals("")){
          sb.append(" ORG_ID = '"+authorization.getManagedId()+"' ");
          sb.append(" and ");
        }
      }
      else if(authorizationType.equals("user")){
        if(authorization.getManageRoleId()!=null&&
            !authorization.getManageRoleId().equals("")){
          sb.append(" ROLE_ID = '"+authorization.getManageRoleId()+"' ");
          sb.append(" and ");
        }
        if(authorization.getManagedId()!=null&&
            !authorization.getManagedId().equals("")){
          sb.append(" USER_ID = '"+authorization.getManagedId()+"' ");
          sb.append(" and ");
        }
      }
    }
    if(sb.length()>0){
      //增加查询条件关键字
      sb.insert(0," where ");
      //去除最后一个" AND "操作符
      sb.delete(sb.length()-5,sb.length());
    }
    return sb;
  }

  private List resultsetToVO(ResultSet rs,String authorizationType)
      throws SQLException{
    List list=new ArrayList();