dept_manage.java

1.员工添加 2.人事调动 3.在职人员管理 4.部门（分厂）管理

package pmsys.wyj;

import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;
import org.apache.struts.action.DynaActionForm;
import org.apache.struts.actions.DispatchAction;

import javax.servlet.http.HttpSession;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;
import java.sql.DriverManager;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.PreparedStatement;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import pmsys.*;
import pmsys.wyj.*;

public class Dept_manage extends DispatchAction {
	/**
	 * 添加部门
	 */
	public ActionForward deptadd(ActionMapping mapping,
									ActionForm form,
									HttpServletRequest request,
									HttpServletResponse response) {
			
		DynaActionForm dyform = (DynaActionForm) form;
		String deptnames = (String) dyform.get("deptname");
		String depttel = (String) dyform.get("depttel"); 
		
		Connection conn = null; 
		try{
			
			String deptname = new String(deptnames.getBytes("iso-8859-1"),"gbk");
			//链接池链接数据库
			DataSource ds = (DataSource)this.getDataSource(request,"oracledb");	
			conn = ds.getConnection();
			//查找数据库中是否已有添加的部门名
			String sql3 = "SELECT * FROM departments where dep_name=?";
			PreparedStatement pstmt3 = conn.prepareStatement(sql3);
			pstmt3.setString(1,deptname);
			ResultSet rs3 = pstmt3.executeQuery();
			if(rs3.next()){     //如果部门名已存在，不添加
				request.setAttribute("dept_add_ok","部门名已存在，添加失败！");
			}else{    //插入记录
				
				String sql2 = "SELECT max(dep_id) id FROM departments";
				Statement stmt2 = conn.createStatement();
				ResultSet rs2 = stmt2.executeQuery(sql2);
				rs2.next();
				int deptid = rs2.getInt("id") + 1;				
				
				String sql1 = "INSERT INTO departments VALUES(?,?,?)";
				PreparedStatement pstmt1 = conn.prepareStatement(sql1);
				pstmt1.setInt(1,deptid);
				pstmt1.setString(2,deptname);
				pstmt1.setString(3,depttel);
				ResultSet rs1 = pstmt1.executeQuery();
				if(rs1.next()){
					request.setAttribute("dept_add_ok","添加成功！");
				}
			}
		} catch(Exception e1) {
			e1.printStackTrace();
		} finally {
			if (conn != null) {
				try {
					conn.close();
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}

		return mapping.findForward("dept_add");
	}
	/**
	 * 查看部门
	 */
	public ActionForward deptlookup(ActionMapping mapping,
									ActionForm form,
									HttpServletRequest request,
									HttpServletResponse response) {
		ArrayList dlist = new ArrayList();
		Connection conn = null; 
		try{
			//链接池链接数据库
			DataSource ds = (DataSource)this.getDataSource(request,"oracledb");	
			conn = ds.getConnection();
			//查找数据库中部门
			String sql = "SELECT * FROM departments";
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery(sql);
			while(rs.next()){
				UserForm deptlookup = new UserForm();
				deptlookup.setDeptno(rs.getString("dep_name"));
				deptlookup.setDname(rs.getString("dep_tel"));
				dlist.add(deptlookup);
				request.setAttribute("dept_lookup",dlist);
			}
		} catch(Exception e1) {
			e1.printStackTrace();
		} finally {
			if (conn != null) {
				try {
					conn.close();
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}
		return mapping.findForward("dept_lookup");
	}
}