yh_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 YH_Manage extends DispatchAction {
	/**
	 * 添加用户
	 */
	public ActionForward tianjia(ActionMapping mapping,
									ActionForm form,
									HttpServletRequest request,
									HttpServletResponse response) {
									
		DynaActionForm dyform = (DynaActionForm) form;
		String username = (String) dyform.get("username");  //用户名
		String userpsw = (String) dyform.get("userpsw");   //密码
		String type = (String) dyform.get("type");    //登录类型
		
		Connection conn = null; 
		try{
			//链接池链接数据库
			DataSource ds = (DataSource)this.getDataSource(request,"oracledb");	
			conn = ds.getConnection();
			//查找数据库中是否已有添加的用户名
			String sql3 = "SELECT * FROM admins where admin_name=?";
			PreparedStatement pstmt3 = conn.prepareStatement(sql3);
			pstmt3.setString(1,username);
			ResultSet rs3 = pstmt3.executeQuery();
			if(rs3.next()){     //如果用户名已存在，不添加
				request.setAttribute("yhgl_tianjia_ok","用户名已存在，添加失败！");
			}else{    //插入记录
				String sql1 = "INSERT INTO admins VALUES(?,?,?)";
				PreparedStatement pstmt1 = conn.prepareStatement(sql1);
				pstmt1.setString(1,username);
				pstmt1.setString(2,userpsw);
				pstmt1.setString(3,type);
				ResultSet rs1 = pstmt1.executeQuery();
				if(rs1.next()){
					request.setAttribute("yhgl_tianjia_ok","添加成功！");
				}
			}
		} catch(Exception e1) {
			e1.printStackTrace();
		} finally {
			if (conn != null) {
				try {
					conn.close();
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}

		return mapping.findForward("yhgl_tianjia");
	}
	/**
	 * 查看用户
	 */
	public ActionForward chakan(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 sql3 = "SELECT * FROM admins";
			Statement stmt3 = conn.createStatement();
			ResultSet rs3 = stmt3.executeQuery(sql3);
			while(rs3.next()){
				UserForm yhxx = new UserForm();
				yhxx.setDeptno(rs3.getString("admin_name"));
				yhxx.setDname(rs3.getString("admin_mima"));
				yhxx.setLoc(rs3.getString("admin_grant"));
				dlist.add(yhxx);
				request.setAttribute("yhgl_chakanxx",dlist);
			}
		} catch(Exception e1) {
			e1.printStackTrace();
		} finally {
			if (conn != null) {
				try {
					conn.close();
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}

		return mapping.findForward("yhgl_chakan");
	}
	//查找用户信息(修改)
	public void xiugai_chazhao(DataSource ds,HttpServletRequest request) {
		ArrayList dlist = new ArrayList();
		Connection conn = null; 
		try{
			//链接池链接数据库	
			conn = ds.getConnection();
			//查找数据库中是否已有添加的用户名
			String sql3 = "SELECT * FROM admins";
			Statement stmt3 = conn.createStatement();
			ResultSet rs3 = stmt3.executeQuery(sql3);
			while(rs3.next()){
				UserForm yhxx = new UserForm();
				yhxx.setDeptno(rs3.getString("admin_name"));
				yhxx.setDname(rs3.getString("admin_mima"));
				yhxx.setLoc(rs3.getString("admin_grant"));
				dlist.add(yhxx);
				request.setAttribute("yhgl_chakanxx",dlist);
			}
		} catch(Exception e1) {
			e1.printStackTrace();
		} finally {
			if (conn != null) {
				try {
					conn.close();
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}
	}
	/**
	 * 修改用户(查找)
	 */
	public ActionForward xiugai(ActionMapping mapping,
									ActionForm form,
									HttpServletRequest request,
									HttpServletResponse response) {
		try{
			//链接池链接数据库
			DataSource ds = (DataSource)this.getDataSource(request,"oracledb");	
			xiugai_chazhao(ds,request);
		} catch(Exception e1) {
			e1.printStackTrace();
		}

		return mapping.findForward("yhgl_xiugai");
	}
	/**
	 * 修改用户(显示)
	 */
	public ActionForward xiugai_view(ActionMapping mapping,
									ActionForm form,
									HttpServletRequest request,
									HttpServletResponse response) {
		ArrayList dlist = new ArrayList();
		DynaActionForm dyform = (DynaActionForm) form;
		String name = (String) dyform.get("admin_name");
		Connection conn = null; 
		try{
			//链接池链接数据库
			DataSource ds = (DataSource)this.getDataSource(request,"oracledb");		
			conn = ds.getConnection();
			//查找数据库中是否已有添加的用户名
			String sql3 = "SELECT * FROM admins WHERE admin_name='" + name + "'";
			Statement stmt3 = conn.createStatement();
			ResultSet rs3 = stmt3.executeQuery(sql3);
			while(rs3.next()){
				UserForm yhxx = new UserForm();
				yhxx.setDeptno(rs3.getString("admin_name"));
				yhxx.setDname(rs3.getString("admin_mima"));
				yhxx.setLoc(rs3.getString("admin_grant"));
				dlist.add(yhxx);
				request.setAttribute("yhgl_xiugaixx",dlist);
				request.setAttribute("admin_grant",rs3.getString("admin_grant"));
			}
		} catch(Exception e1) {
			e1.printStackTrace();
		} finally {
			if (conn != null) {
				try {
					conn.close();
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}

		return mapping.findForward("yhgl_xiugai_view");
	}
	/**
	 * 修改用户(修改)
	 */
	public ActionForward xiugai_update(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();
			
			DynaActionForm dyform = (DynaActionForm) form;
			String name = (String) dyform.get("admin_name");
			String mima = (String) dyform.get("admin_mima");
			String grant = (String) dyform.get("admin_grant");
			//更新记录
			String sql3 = "UPDATE admins SET admin_mima=?,admin_grant=? WHERE admin_name=?";
			PreparedStatement pstmt3 = conn.prepareStatement(sql3);
			pstmt3.setString(1,mima);
			pstmt3.setString(2,grant);
			pstmt3.setString(3,name);
			ResultSet rs3 = pstmt3.executeQuery();
			if(rs3.next()){
				request.setAttribute("yhgl_xiugaixx","修改成功！");
			}
		} catch(Exception e1) {
			e1.printStackTrace();
		} finally {
			if (conn != null) {
				try {
					conn.close();
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}

		return mapping.findForward("yhgl_xiugai_update");
	}
	/**
	 * 删除用户(查找)
	 */
	public ActionForward shanchu(ActionMapping mapping,
									ActionForm form,
									HttpServletRequest request,
									HttpServletResponse response) {
		try{
			//链接池链接数据库
			DataSource ds = (DataSource)this.getDataSource(request,"oracledb");	
			xiugai_chazhao(ds,request);
		} catch(Exception e1) {
			e1.printStackTrace();
		}

		return mapping.findForward("yhgl_shanchu");
	}
	/**
	 * 删除用户(删除)
	 */
	public ActionForward shanchu_del(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();
			
			DynaActionForm dyform = (DynaActionForm) form;
			String name = (String) dyform.get("admin_name");
			//删除记录
			String sql3 = "DELETE admins WHERE admin_name=?";
			PreparedStatement pstmt3 = conn.prepareStatement(sql3);
			pstmt3.setString(1,name);
			ResultSet rs3 = pstmt3.executeQuery();
			if(rs3.next()){
				request.setAttribute("yhgl_shanchuxx","删除成功！");
			}
		} catch(Exception e1) {
			e1.printStackTrace();
		} finally {
			if (conn != null) {
				try {
					conn.close();
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}
		return mapping.findForward("yhgl_shanchu_update");
	}
}