logininfosave.java

基于J2EE的网络物流系统 用户操作： 1． 录入出库商品信息 2． 查询出库单信息 3． 录入入库商品信息 4． 查询入库单信息 5． 查询商品位置信息 6． 查询商品信息 7． 查

package com.logistic.servlet;

import java.io.IOException;
import java.sql.ResultSet;
import java.sql.Statement;
import com.logistic.business.LoginManager;
import javax.servlet.RequestDispatcher;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import com.logistic.data.DataConnect;

public class LoginInfoSave extends HttpServlet {

	private static final long serialVersionUID = -2305260907601477327L;
	HttpSession session=null;
	DataConnect dc=new DataConnect();
	Statement stat=null;
	ResultSet rs=null;
	int       id=0;
	int      flag=0;
	String  loginid=null;
	String  loginname=null;
	String  password=null;
	String  repassword=null;
	String  loginpower=null;
	String  employeeid=null;
	RequestDispatcher requestdispatcher;
	
	public void doPost(HttpServletRequest request, HttpServletResponse response)
			throws ServletException, IOException {

		request.setCharacterEncoding("GB2312");
		response.setContentType("text/html; charset=gb2312");
		session=request.getSession();
		
/*
* 获取logintable表的LoginId字段的最后插入的值，生成下一条记录的LoginId
* 字段的值！
* */
	  try{			
		    String sql="select * from logintable order by ID desc limit 1";
			stat=dc.getStmtread();				 
			  rs=stat.executeQuery(sql);
			  rs.previous();
			while(rs.next()){
				  id=Integer.valueOf(rs.getString("LoginId"));
				 }
				 if(id>0){
				      id+=1;
				     }else{
				     id=10000+1;
				     }
	    }catch(Exception ex){ex.printStackTrace();}finally{dc.close();}	
	    
//根据员工编号取得员工姓名
	   try{
		     employeeid=(String)request.getParameter("employeename");
		     String strsql="select * from employeeinfotable where EmployeeId="+employeeid;
		     stat=dc.getStmtread();
		     rs  =stat.executeQuery(strsql);
		     while(rs.next()){
		    	 loginname=rs.getString("EmployeeName");
		     }		   
	   }catch(Exception ex){ex.printStackTrace();}finally{dc.close();}
	   
//检测要添加的职员是否已经存在
	   System.out.println(loginname);
	   int selectflag=0;
	   String selectstr="select * from logintable where EmployeeId="+employeeid;
	   selectflag=dc.selectdata(selectstr);
	   if(selectflag>0){
		   session.setAttribute("error", "对不起您要添加的用户已经存在!");
	       requestdispatcher=request.getRequestDispatcher("/viewpage/datainput/logininfosave.jsp");
	       requestdispatcher.forward(request, response);
	   }
	    
//从页面获取参数进行添加操作
	    loginid=String.valueOf(id);
	    loginpower=(String)request.getParameter("power");
	    password=(String)request.getParameter("password").trim();
	    repassword=(String)request.getParameter("repassword").trim();
	    
//检测数据合法性,通过检测进行数据插入操作
	 if(loginid==null||employeeid==null||loginpower==null){	
         session.setAttribute("errors","*标识项必须填写!!");
 		 requestdispatcher=request.getRequestDispatcher("/errors/errorpage.jsp");
 		 requestdispatcher.forward(request, response);	    		   
	     }else{	    	 
		    if(!password.equals(repassword)){	
		    	session.setAttribute("errors","密码不等，请重新确认密码!");
		 		requestdispatcher=request.getRequestDispatcher("/errors/errorpage.jsp");
		 		requestdispatcher.forward(request, response);
		    }else{
	    	
	    	     try{
	    		     LoginManager lm=new LoginManager();
	    		     flag=lm.AddLogin(loginid, loginname, password, loginpower, employeeid);
	    		     if(flag>0){
	    		    	 session.setAttribute("success", "登陆信息添加成功!");
	    		    	 requestdispatcher=request.getRequestDispatcher("/viewpage/datainput/logininfosave.jsp");
	    		    	 requestdispatcher.forward(request, response);
	    		     }else{
	    		    	 System.out.println("登陆信息添加失败!");
	    		    	 session.setAttribute("errors", " 登陆信息添加失败!");
	    		    	 requestdispatcher=request.getRequestDispatcher("/errors/errorpage.jsp");
	    		    	
	    		     }
	    		
	    	     	}catch(Exception ex){ex.printStackTrace();}finally{dc.close();}
	         }
	    }	    
	
	}
	
	public void doGet(HttpServletRequest request, HttpServletResponse response)
	throws ServletException, IOException {

		doPost(request,response);
    }

}