employeeserviceimpl.java

人力资源管理系统

package org.HumResManSys.service.impl;

import java.util.List;

import org.HumResManSys.dao.EmployeeDAO;
import org.HumResManSys.dao.Kq_infoDAO;
import org.HumResManSys.dao.EvaluateDAO;
import org.HumResManSys.dao.JxdDAO;
import org.HumResManSys.dao.Salary_infoDAO;
import org.HumResManSys.factory.DAOFactory;
import org.HumResManSys.service.EmployeeService;
import org.HumResManSys.vo.Salary_info;
import org.HumResManSys.vo.Employee;
import org.HumResManSys.vo.Evaluate;
import org.HumResManSys.vo.Kq_info;
import org.HumResManSys.vo.Jxd;
import org.HumResManSys.vo.Ypinfo;

public class EmployeeServiceImpl implements EmployeeService {

	private DAOFactory daoFactory;

	public boolean addEmployee(Employee employee) {

		try {
			//得到Employee	
			EmployeeDAO employeeDAO = daoFactory.getEmployeeDAO();
			//得到Salary_infoDAO	

			Salary_info salary_info = new Salary_info();
			//得到Kq_info

			Kq_info kq_info = new Kq_info();
			//得到Jxd

			Jxd jxd = new Jxd();
			//及联增加员工工资信息
			salary_info.setBasic_sal((long)2000);
			salary_info.setTax_rate((long)0.07);
			employee.getSalary_info().add(salary_info);
			//及联增加员工考勤信息
			kq_info.setMonth("0801");
			kq_info.setTimes((long)30);
			employee.getKq_info().add(kq_info);
			//及联增加员工绩效信息
			jxd.setMonth("0801");
			employee.getJxd().add(jxd);
			//创建新员工
			employeeDAO.createEmployee(employee);

			//一定要关闭session	
			employeeDAO.closeSession();

		} catch (Exception e) {
			System.out.print("EmployeeService add Employee error\n");
			e.printStackTrace();
			return false;
		}
		return true;
	}

	public boolean deleteEmployee(String name) {

		try {
			//获得EmployeeDAO
			EmployeeDAO employeeDAO = daoFactory.getEmployeeDAO();
			System.out.println("传过来的参数是：" + name);
			Employee employee = employeeDAO.queryOneEmployeeByCondition(
					"emp_name", name);
			System.out.println("删除的员工的名字是：" + employee.getEmp_name());
			//及联删除员工
			boolean result = employeeDAO.deleteEmployee(employee);
			//一定要关闭session
			employeeDAO.closeSession();
			return result;

		} catch (Exception e) {
			System.out.print("EmployeeService  delete Employee error\n");
			e.printStackTrace();
			return false;
		}

	}

	public List<Employee> showAllEmployees() {
		try {
			//获得EmployeeDAO
			EmployeeDAO employeeDAO = daoFactory.getEmployeeDAO();
			List<Employee> list = employeeDAO.queryAllEmployees();
			//一定要关闭session
			employeeDAO.closeSession();
			return list;
		} catch (Exception e) {
			// TODO Auto-generated catch block
			System.out.print("EmployeeService  show AllEmployee error\n");
			e.printStackTrace();
			return null;
		}
	}

	public boolean saveEmployee(Employee employee) {
		try {
			//获得EmployeeDAO
			EmployeeDAO employeeDAO = daoFactory.getEmployeeDAO();
			Employee emp = employeeDAO.queryOneEmployeeByCondition("emp_name",
					employee.getEmp_name());
			emp.setBirthday(employee.getBirthday());

			//System.out.println(employee.getEmp_id());
			emp.setDept_name(employee.getDept_name());
			emp.setPsw(employee.getPsw());
			emp.setJob(employee.getJob());
			boolean result = employeeDAO.updateEmployee(emp);
			//一定要关闭session
			employeeDAO.closeSession();
			return result;
		} catch (Exception e) {
			// TODO Auto-generated catch block
			System.out.print("EmployeeService  save Employee error\n");
			e.printStackTrace();
			return false;
		}

	}

	/**
	 * 查询员工信息,分页查询
	 */
	public List<Employee> queryEmployeesByPage(int firstResult, int maxResults) {
		List list = null;
		try {
			list = daoFactory.getEmployeeDAO()
					.queryEmployeesByPageOrderByCondition("emp_name",
							firstResult, maxResults);
			daoFactory.getEmployeeDAO().closeSession();
		} catch (RuntimeException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return list;
	}

	public DAOFactory getDaoFactory() {
		return daoFactory;
	}

	public void setDaoFactory(DAOFactory daoFactory) {
		this.daoFactory = daoFactory;
	}

	//显示一个员工的详细信息
	public Employee showSelfInfos(String name) {
		// TODO Auto-generated method stub

		//获得EmployeeDAO
		EmployeeDAO employeeDAO = daoFactory.getEmployeeDAO();
		Employee employee = employeeDAO.queryOneEmployeeByCondition("emp_name",
				name);
		employeeDAO.closeSession();
		return employee;
	}

	//	更新员工信息
	public boolean updateSelfInfo(Employee emp) {
		// TODO Auto-generated method stub
		//获得EmployeeDAO
		boolean okOrNot = false;
		try {
			EmployeeDAO employeeDAO = daoFactory.getEmployeeDAO();
			okOrNot = employeeDAO.updateEmployee(emp);
			employeeDAO.closeSession();
		} catch (RuntimeException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			System.out.println("update employee error.");
			return false;
		}
		return okOrNot;
	}

	//按条件排序显示所有员工
	public List<Employee> displayAllOrderByCondition(String condition) {
		// TODO Auto-generated method stub
		//获得EmployeeDAO
		EmployeeDAO employeeDAO = daoFactory.getEmployeeDAO();
		List<Employee> emps = employeeDAO
				.queryAllEmployeesOrderByCondition(condition);
		employeeDAO.closeSession();
		return emps;
	}

	//按部门查找员工
	public List<Employee> queryEmpsByOneCondition(String condition, String value) {
		// TODO Auto-generated method stub
		List<Employee> emps = null;
		try {
			EmployeeDAO employeeDAO = daoFactory.getEmployeeDAO();
			emps = employeeDAO.queryAllEmployeesByCondition(condition, value);
			employeeDAO.closeSession();
		} catch (RuntimeException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			System.out.println("search failed.");
			return null;
		}
		return emps;
	}

	//	根据给定的ID查找员工
	public Employee showSelfInfosByID(String id) {
		// TODO Auto-generated method stub
		//获得EmployeeDAO
		Employee employee = null;
		try {
			EmployeeDAO employeeDAO = daoFactory.getEmployeeDAO();
			employee = employeeDAO.queryOneEmployeeByCondition("emp_id", id);
			employeeDAO.closeSession();
		} catch (RuntimeException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			System.out.println("search employee by id failed.");
			return null;
		}
		return employee;
	}

	//根据给定的id删除员工
	public boolean deleteEmployeeByID(String id) {
		// TODO Auto-generated method stub
		try {
			//获得EmployeeDAO
			EmployeeDAO employeeDAO = daoFactory.getEmployeeDAO();
			Employee employee = employeeDAO.queryOneEmployeeByCondition(
					"emp_id", id);
			//及联删除员工
			boolean result = employeeDAO.deleteEmployee(employee);
			//一定要关闭session
			employeeDAO.closeSession();
			return result;

		} catch (Exception e) {
			System.out.print("EmployeeService  delete Employee by id error\n");
			e.printStackTrace();
			return false;
		}
	}

	public int getEmployeesCount() {
		List list = this.daoFactory.getEmployeeDAO().getCurrentSession()
				.createQuery("select count(*) from Employee")
				.setCacheable(true).list();
		int size = ((Number) list.get(0)).intValue();
		//		this.daoFactory.getEmployeeDAO().closeSession();
		return size;

	}

}