package org.tya.web.dao.Impl;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import org.tya.web.dao.EmployeeInfoDao;
import org.tya.web.dao.RowCallbackHandler;
import org.tya.web.entity.AdminHelp;
import org.tya.web.entity.DeptInfo;
import org.tya.web.entity.EmployeeInfo;
import org.tya.web.entity.JobInfo;
import org.tya.web.util.DbHelper;
import org.tya.web.util.Page;
public class EmployeeInfoDaoImpl extends BaseDAO implements EmployeeInfoDao {
private Connection conn=null;
private PreparedStatement pstmt=null;
private ResultSet rs=null;
//查询所有的员工信息
public List<EmployeeInfo> getEmployeeInfoAll() {
List<EmployeeInfo> lstEmp=new ArrayList<EmployeeInfo>();
try {
conn=DbHelper.getConn();
String sql="select empId,empName,empPicture,empSex,empAge,empTelephone,empAddress,deptName,jobName,empIsWork,empPwd from (select * from employeeinfo a left join jobinfo b on a.empjobid=b.jobId)c left join deptinfo d on c.empDeptId=d.deptId";
pstmt=conn.prepareStatement(sql);
ResultSet rs=pstmt.executeQuery();
while(rs.next()){
EmployeeInfo emps=new EmployeeInfo();
emps.setEmpId(rs.getInt("empId"));
emps.setEmpName(rs.getString("empName"));
emps.setEmpPicture(rs.getString("empPicture"));
emps.setEmpSex(rs.getString("empSex"));
emps.setEmpAge(rs.getInt("empAge"));
emps.setEmpTelephone(rs.getString("empTelephone"));
emps.setEmpAddress(rs.getString("empAddress"));
emps.getDept().setDeptName(rs.getString("deptName"));
emps.getJob().setJobName(rs.getString("jobName"));
emps.setEmpIsWork(rs.getInt("empIsWork"));
emps.setEmpPwd(rs.getString("empPwd"));
lstEmp.add(emps);
}
} catch (SQLException e) {
e.printStackTrace();
}finally{
DbHelper.closeResource(rs, pstmt, conn);
}
return lstEmp;
}
//添加员工信息
public void addEmployeeInfo(EmployeeInfo employee) {
conn=DbHelper.getConn();
String sql="insert into employeeInfo(empName,empPicture,empSex,empAge,empTelephone,empAddress,empDeptId,empJobId,empIsWork,empPwd) values(?,?,?,?,?,?,?,?,?,?)";
try {
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,employee.getEmpName());
pstmt.setString(2, employee.getEmpPicture());
pstmt.setString(3,employee.getEmpSex());
pstmt.setInt(4,employee.getEmpAge());
pstmt.setString(5,employee.getEmpTelephone());
pstmt.setString(6, employee.getEmpAddress());
pstmt.setInt(7, employee.getDept().getDeptId());
pstmt.setInt(8, employee.getJob().getJobId());
pstmt.setInt(9,employee.getEmpIsWork());
pstmt.setString(10, employee.getEmpPwd());
pstmt.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}finally{
DbHelper.closeResource(rs, pstmt, conn);
}
}
//根据编号获取信息
public EmployeeInfo getEmployeeInfoforId(int empId) {
conn=DbHelper.getConn();
EmployeeInfo emps=null;
String sql="select * from employeeInfo where empId=?";
try {
pstmt=conn.prepareStatement(sql);
pstmt.setInt(1,empId);
rs=pstmt.executeQuery();
if(rs.next()){
emps=new EmployeeInfo();
emps.setEmpId(rs.getInt("empId"));
emps.setEmpName(rs.getString("empName"));
emps.setEmpPicture(rs.getString("empPicture"));
emps.setEmpSex(rs.getString("empSex"));
emps.setEmpAge(rs.getInt("empAge"));
emps.setEmpTelephone(rs.getString("empTelephone"));
emps.setEmpAddress(rs.getString("empAddress"));
// emps.setEmpDeptId(rs.getInt("empDeptId"));
// emps.setEmpJobId(rs.getInt("empJobId"));
emps.getDept().setDeptId(rs.getInt("empDeptId"));
emps.getJob().setJobId(rs.getInt("empJobId"));
emps.setEmpIsWork(rs.getInt("empIsWork"));
emps.setEmpPwd(rs.getString("empPwd"));
}
} catch (SQLException e) {
e.printStackTrace();
}finally{
DbHelper.closeResource(rs, pstmt, conn);
}
return emps;
}
//修改员工信息
public EmployeeInfo updateEmployeeInfo(EmployeeInfo employee) {
conn=DbHelper.getConn();
String sql="update employeeInfo set empName=?, empPicture =?,empSex=?,empAge=?,empTelephone=?,empAddress=?,empDeptId=?,empJobId=?,empIsWork=?,empPwd=? where empId=?";
try {
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,employee.getEmpName());
pstmt.setString(2, employee.getEmpPicture());
pstmt.setString(3,employee.getEmpSex());
pstmt.setInt(4,employee.getEmpAge());
pstmt.setString(5,employee.getEmpTelephone());
pstmt.setString(6, employee.getEmpAddress());
pstmt.setInt(7, employee.getDept().getDeptId());
// pstmt.setInt(7, employee.getEmpDeptId());
// pstmt.setInt(8, employee.getEmpJobId());
pstmt.setInt(8, employee.getJob().getJobId());
pstmt.setInt(9,employee.getEmpIsWork());
pstmt.setString(10, employee.getEmpPwd());
pstmt.setInt(11,employee.getEmpId());
pstmt.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}finally{
DbHelper.closeResource(rs, pstmt, conn);
}
return null;
}
//删除员工
public void deleteEmployeeInfo(int empId) {
conn=DbHelper.getConn();
String sql="delete from employeeInfo where empId=?";
try {
pstmt=conn.prepareStatement(sql);
pstmt.setInt(1,empId);
pstmt.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}finally{
DbHelper.closeResource(rs, pstmt, conn);
}
}
//查询所有的部门信息
public List<DeptInfo> getdeptInfoAll() {
List<DeptInfo> lstdept=new ArrayList<DeptInfo>();
conn=DbHelper.getConn();
String sql="select * from deptInfo";
try {
pstmt=conn.prepareStatement(sql);
ResultSet rs=pstmt.executeQuery();
while(rs.next()){
DeptInfo dept=new DeptInfo();
dept.setDeptId(rs.getInt("deptId"));
dept.setDeptName(rs.getString("deptName"));
dept.setDeptRemark(rs.getString("deptRemark"));
lstdept.add(dept);
}
} catch (SQLException e) {
e.printStackTrace();
}finally{
DbHelper.closeResource(rs, pstmt, conn);
}
return lstdept;
}
//查询所有的职位信息
public List<JobInfo> getJobInfoAll() {
List<JobInfo> lstjob=new ArrayList<JobInfo>();
try {
conn=DbHelper.getConn();
String sql="select * from jobInfo";
pstmt=conn.prepareStatement(sql);
ResultSet rs=pstmt.executeQuery();
while(rs.next()){
JobInfo job=new JobInfo();
job.setJobId(rs.getInt("jobId"));
job.setJobName(rs.getString("jobName"));
job.setJobLevel(rs.getInt("jobLevel"));
lstjob.add(job);
}
} catch (SQLException e) {
e.printStackTrace();
}finally{
DbHelper.closeResource(rs, pstmt, conn);
}
return lstjob;
}
//查询对应的子内容
public EmployeeInfo getEmployeeInfoByempDeptId(int empDeptId) {
conn=DbHelper.getConn();
EmployeeInfo emps=null;
String sql="select * from employeeInfo where empDeptId=?";
try {
pstmt=conn.prepareStatement(sql);
pstmt.setInt(1,empDeptId);
rs=pstmt.executeQuery();
if(rs.next()){
emps=new EmployeeInfo();
emps.setEmpId(rs.getInt("empId"));
emps.setEmpName(rs.getString("empName"));
emps.setEmpPicture(rs.getString("empPicture"));
emps.setEmpSex(rs.getString("empSex"));
emps.setEmpAge(rs.getInt("empAge"));
emps.setEmpTelephone(rs.getString("empTelephone"));
emps.setEmpAddress(rs.getString("empAddress"));
// emps.setEmpDeptId(rs.getInt("empDeptId"));
// emps.setEmpJobId(rs.getInt("empJobId"));
emps.getDept().setDeptId(rs.getInt("empDeptId"));
emps.getJob().setJobId(rs.getInt("empJobId"));
emps.setEmpIsWork(rs.getInt("empIsWork"));
emps.setEmpPwd(rs.getString("empPwd"));
}
} catch (SQLException e) {
e.printStackTrace();
}finally{
DbHelper.closeResource(rs, pstmt, conn