departmentmanageimpl.java

本代码是一个权限管理系统源代码

/**
 * 
 */
package com.seavision.PermissionManage.components;

import java.sql.Connection;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.seavision.PermissionManage.help.Constants;
import net.sf.hibernate.HibernateException;
import com.seavision.PermissionManage.vo.DepartmentVO;
import com.seavision.PermissionManage.help.HibernateUtil;

/**
 * @author Administrator
 * 
 */
public class DepartmentManageImpl implements DepartmentManage {

	/**
	 * 1.获取部门列表
	 * 
	 * @param companyId
	 * @return首先判断参数是否为空， 如果为空根据参数从表department中读取全部信息，
	 *                    如果不为空根据参数从表department中读取相应信息。 成功返回List，失败返回null。
	 */
	public List getDepartmentList(String companyId) {
		List result = new ArrayList();

		Connection conn = HibernateUtil.getConnection();
		if (companyId == null || companyId.trim().length() == 0) {
			String hql = "from DepartmentVO";
			try {
				// 调用HibernateUtil方法进行查询
				result = HibernateUtil.queryHQL(hql);
			} catch (HibernateException e) {
				e.printStackTrace();
			}
			if (null == result || result.size() == 0) {
				return result;
			} else {
				return result;
			}
		}
		String sql = "select * from department where companyId=" + companyId;
		try {
			// 创建Statement对象
			Statement stat = conn.createStatement();
			System.out.println("sql==" + sql);
			// 定义数据集
			ResultSet rs = stat.executeQuery(sql);
			while (rs.next()) {
				DepartmentVO department = new DepartmentVO();
				department.setCompanyId(rs.getInt("companyId"));
				department.setDepartment_p(rs.getInt("department_p"));
				department.setDepartmentAuthority(rs
						.getInt("departmentAuthority"));
				department.setDepartmentId(rs.getInt("departmentId"));
				department.setDepartmentName(rs.getString("departmentName"));
				department.setDepartmentPhone(rs.getString("departmentPhone"));
				department.setDepartmentState(rs.getInt("departmentState"));
				department.setDepartmentType(rs.getString("departmentType"));
				result.add(department);
			}
			rs.close();
			stat.close();

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
		}
		return result;
	}

	public List getDepartmentList(String companyId, String departmentId) {
		List result = new ArrayList();

		Connection conn = HibernateUtil.getConnection();
		if (companyId == null || companyId.trim().length() == 0) {
			String hql = "from DepartmentVO";
			try {
				// 调用HibernateUtil方法进行查询
				result = HibernateUtil.queryHQL(hql);
			} catch (HibernateException e) {
				e.printStackTrace();
			}
			if (null == result || result.size() == 0) {
				return result;
			} else {
				return result;
			}
		}
		String sql = "select * from department where companyId=" + companyId
				+ " and department_p != " + departmentId;
		try {
			// 创建Statement对象
			Statement stat = conn.createStatement();
			// 定义数据集
			ResultSet rs = stat.executeQuery(sql);
			while (rs.next()) {
				DepartmentVO department = new DepartmentVO();
				department.setCompanyId(rs.getInt("companyId"));
				department.setDepartment_p(rs.getInt("department_p"));
				department.setDepartmentAuthority(rs
						.getInt("departmentAuthority"));
				department.setDepartmentId(rs.getInt("departmentId"));
				department.setDepartmentName(rs.getString("departmentName"));
				department.setDepartmentPhone(rs.getString("departmentPhone"));
				department.setDepartmentState(rs.getInt("departmentState"));
				department.setDepartmentType(rs.getString("departmentType"));
				result.add(department);
			}
			rs.close();
			stat.close();

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
		}
		return result;
	}

	/**
	 * 2.获取部门信息
	 * 
	 * @param departmentId
	 * @return根据参数从表departement中读取信息， 成功返回DepartmentVO，失败返回null。
	 */
	public DepartmentVO getDepartment(String departmentId) {
		DepartmentVO departmentVO = (DepartmentVO) HibernateUtil.getVOByID(
				DepartmentVO.class, Integer.parseInt(departmentId));

		return departmentVO;
	}

	/**
	 * 3.获取上级部门名称
	 * 
	 * @param departmentId
	 * @return根据参数从表department中读取信息， 封装String类型的对象中，成功返回String类型对象， 失败返回null。
	 */
	public String getParentOfDepartment(String departmentId) {
		DepartmentVO departmentVO = (DepartmentVO) HibernateUtil.getVOByID(
				DepartmentVO.class, Integer.parseInt(departmentId));
		if (departmentVO == null) {
			return "无";
		} else {
			String name = departmentVO.getDepartmentName();
			return name;
		}
	}

	/**
	 * 4.获取下级部门信息列表
	 * 
	 * @param departmentId
	 * @return根据参数从表departmentRelation中读取下级部门编号， 封装到List对象中。根据List编号列表，从表company中读取信息，
	 *                                           封装到DepartmentVO对象中，成功返回List，失败返回null。
	 */
	public List getSonOfDepartmentList(String departmentId) {
		Connection conn = HibernateUtil.getConnection();
		String sql = "select * from department where department_p = "
				+ departmentId;
		List result = new ArrayList();
		Statement stat = null;
		ResultSet rs = null;
		try {
			// 创建Statement对象
			stat = conn.createStatement();
			rs = stat.executeQuery(sql);
			while (rs.next()) {
				DepartmentVO departmentvo = new DepartmentVO();
				departmentvo.setDepartment_p(rs.getInt("department_p"));
				departmentvo.setCompanyId(rs.getInt("companyId"));
				departmentvo.setDepartmentAuthority(rs
						.getInt("departmentAuthority"));
				departmentvo.setDepartmentId(rs.getInt("departmentId"));
				departmentvo.setDepartmentName(rs.getString("departmentName"));
				departmentvo
						.setDepartmentPhone(rs.getString("departmentPhone"));
				departmentvo.setDepartmentState(rs.getInt("departmentState"));
				departmentvo.setDepartmentType(rs.getString("departmentType"));
				result.add(departmentvo);
			}
			rs.close();
			stat.close();
			return result;
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}

	/** 通过departmentId获得department_s */
	private List getDepartment_sId(String departmentId) {
		// 建立数据库连接
		Connection conn = HibernateUtil.getConnection();
		String sql = "select department_s from departmentrelation where department_p="
				+ departmentId;

		Statement stat = null;
		ResultSet rs = null;
		try {
			stat = conn.createStatement();
			rs = stat.executeQuery(sql);

			List c_s = new ArrayList();
			// if(!rs.next())
			// {System.out.println("ceshi:::"+rs.getArray("company_s"));}
			while (rs.next()) {
				c_s.add(rs.getString("department_s"));
				// System.out.println("ceshi:::" + rs.getInt("company_s"));
				// i++;
			}
			return c_s;
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				rs.close();
				stat.close();

			} catch (SQLException e1) {
				e1.printStackTrace();
			}
		}
		return null;
	}

	/**
	 * 5.获取公司下的所有部门
	 * 
	 * @param companyId
	 * @return根据参数从表department中读取信息， 封装到DepartmentVO对象中。成功返回List，失败返回null。
	 */
	public List getDepartmentListByCompanyId(String companyId) {
		List result = new ArrayList();
		Connection conn = HibernateUtil.getConnection();
		String sql = "select * from department where companyId=" + companyId;
		Statement stm = null;
		ResultSet rs = null;
		try {
			stm = conn.createStatement();
			rs = stm.executeQuery(sql);
			while (rs.next()) {
				DepartmentVO departmentvo = new DepartmentVO();
				departmentvo.setDepartment_p(rs.getInt("department_p"));
				departmentvo.setCompanyId(rs.getInt("companyId"));
				departmentvo.setDepartmentAuthority(rs
						.getInt("departmentAuthority"));
				departmentvo.setDepartmentId(rs.getInt("departmentId"));
				departmentvo.setDepartmentName(rs.getString("departmentName"));

				departmentvo
						.setDepartmentPhone(rs.getString("departmentPhone"));
				departmentvo.setDepartmentState(rs.getInt("departmentState"));
				departmentvo.setDepartmentType(rs.getString("departmentType"));
				result.add(departmentvo);