getorganizemanagedao.java

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

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

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

/**
 * <p>Title: 组织数据库操作DAO</p>
 *
 * <p>Description: 深圳市劳动仲裁信息管理系统</p>
 *
 * <p>Copyright: Copyright (c) 2005</p>
 *
 * <p>Company: 永泰软件工程有限公司</p>
 *
 * @author syj
 * @version 1.0
 */
public class GetOrganizeManageDAO{
  private static Logger logger=Logger.getLogger(GetOrganizeManageDAO.class);

  /**
   * 添加组织信息
   * @param organiztion Organiztion
   * @return int
   * @throws PurviewManageException
   */
  public int insertOrganiztion(Organiztion organiztion)
      throws PurviewManageException{
    PreparedStatement prep=null;
    Connection conn=null;
    int i=0;
    String sql=
        "insert into wf_organization (org_id,org_name,org_code,org_address,area_id,"+
        " org_description,up_org,org_level,org_order) values(?,?,?,?,?,?,?,?,?)";
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      String orgId=GetTableSequenceId.getTableId("wf_organization");
      prep=conn.prepareStatement(sql);
      prep.setString(1,orgId);
      prep.setString(2,organiztion.getOrg_name());
      prep.setString(3,organiztion.getOrg_code());
      prep.setString(4,organiztion.getOrg_address());
      prep.setString(5,organiztion.getArea_id());
      prep.setString(6,organiztion.getOrg_description());
      prep.setString(7,organiztion.getUp_org());
      prep.setInt(8,organiztion.getOrg_level());
      prep.setInt(9,organiztion.getOrg_order());
      i=prep.executeUpdate();

    }
    catch(Exception e){
      e.printStackTrace();
      throw new PurviewManageException("添加组织信息异常");
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(prep,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
    return i;
  }

  /**
   * 查询组织的信息
   * @param org_id String
   * @return Organiztion
   */
  public Organiztion query(String org_id)
      throws PurviewManageException{
    Organiztion organiztion=new Organiztion();
    PreparedStatement prep=null;
    Connection conn=null;
    ResultSet rs=null;
    String sql="select * from wf_organization where org_id=?";
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      prep=conn.prepareStatement(sql);
      prep.setString(1,org_id);
      rs=prep.executeQuery();
      while(rs.next()){
        organiztion.setOrg_id(org_id);
        organiztion.setOrg_name(rs.getString("org_name"));
        organiztion.setOrg_code(rs.getString("org_code"));
        organiztion.setOrg_address(rs.getString("org_address"));
        organiztion.setArea_id(rs.getString("area_id"));
        organiztion.setOrg_description(rs.getString("org_description"));
        organiztion.setUp_org(rs.getString("up_org"));
        organiztion.setOrg_level(rs.getInt("org_level"));
        organiztion.setOrg_order(rs.getInt("org_order"));
      }

    }
    catch(Exception e){
      e.printStackTrace();
      throw new PurviewManageException("查询组织的信息");
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(rs);
      WorkflowDBConnectionManager.getInstance().close(prep,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
    return organiztion;
  }

  /**
   * 更新组织信息
   * @param organiztion Organiztion
   * @return int
   */
  public int update(Organiztion organiztion)
      throws PurviewManageException{
    PreparedStatement prep=null;
    Connection conn=null;
    int i=0;
    String sql=
        "update wf_organization set org_name=?,org_code=?,org_address=?,area_id=?,"+
        " org_description=?,up_org=?,org_level=?,org_order=? where org_id=?";
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      prep=conn.prepareStatement(sql);
      prep.setString(1,organiztion.getOrg_name());
      prep.setString(2,organiztion.getOrg_code());
      prep.setString(3,organiztion.getOrg_address());
      prep.setString(4,organiztion.getArea_id());
      prep.setString(5,organiztion.getOrg_description());
      prep.setString(6,organiztion.getUp_org());
      prep.setInt(7,organiztion.getOrg_level());
      prep.setInt(8,organiztion.getOrg_order());
      prep.setString(9,organiztion.getOrg_id());
      i=prep.executeUpdate();

    }
    catch(Exception e){
      e.printStackTrace();
      throw new PurviewManageException("更新组织信息");
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(prep,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
    return i;
  }

  /**
   * 删除组织信息
   * @param org_id String
   * @return int
   */
  public int delete(String org_id)
      throws PurviewManageException{
    int i=0;
    PreparedStatement prep=null;
    Connection conn=null;
    String sql="{?=call f_delete_organization(?)}";
    CallableStatement callStm=null;
    String pId="0";
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      callStm=conn.prepareCall(sql);
      callStm.registerOutParameter(1,java.sql.Types.INTEGER);
      callStm.setString(2,org_id);
      callStm.executeUpdate();
      pId=callStm.getString(1);

    }
    catch(Exception e){
      e.printStackTrace();
      throw new PurviewManageException("删除组织信息异常");
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(prep,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
    return Integer.parseInt(pId);
  }

  /**
   * 更新指定部门及其子部门的所属行政区
   * @param orgId String
   */
  public void updateOrgAreaByOrgId(String orgId,String areaId)
      throws SQLException{
    Connection conn=null;
    Statement stm=null;
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      stm=conn.createStatement();
      String sql="";
      String dataBaseType=WorkflowDBConnectionManager.getInstance().
          getDataBaseType();
      if(dataBaseType.equals("ORACLE")){
        sql=" Update wf_organization Set area_id='"+areaId+"' Where org_id In "+
            " (Select org_id From wf_organization start with org_id = '"+orgId+
            "' "+" connect by prior org_id = up_org) ";
      }
      else if(dataBaseType.equals("MSSQLSERVER")){
        sql=" Update wf_organization Set area_id='"+areaId+"' Where org_id In "+
            " (select tree_id as org_id from FUNC_GET_ORG_INFO_INCLUDE_SUB('"+
            orgId+"')) ";
      }
      logger.info("......update sql:"+sql);
      stm.execute(sql);
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(stm,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }

  }

}