usermn.java

来自「JSP的电子商务系统（源代码) 基于JSP的网上拍卖系统的分析与设计」· Java 代码 · 共 387 行

package org.pan.web;

import java.sql.*;
import java.util.Date;
import java.util.Vector;
import org.pan.util.*;
import javax.servlet.http.HttpServletRequest;
import org.pan.web.book.shopuser;
import org.pan.web.book.books;

/**
 * Title:        网站用户类列表
 * Description:
 * Copyright:    Copyright (c) 2003
 * Company:      多智能网络有限公司
 * @author:		 siny pan
 * @version 1.0
 */

public class usermn extends DataBase {
	private shopuser user = new shopuser();	//新的用户对象
	private javax.servlet.http.HttpServletRequest request; //建立页面请求
	private Vector userlist;				//显示用户列表向量数组
	private int page = 1;					//显示的页码
	private int pageSize=5;					//每页显示的图书数
	private long pageCount =0;				//页面总数
	private long recordCount =0;			//查询的记录总数
	private String message = "";			//出错信息提示
	private String username = "";			//注册后返回的用户名
	private long userid = 0;				//注册后返回的用户ID

	
	public usermn() throws Exception{
		super();
	}

	public Vector getUserlist() {
		return userlist;
	}

	public String getGbk( String str) {
		try
		{
			return new String(str.getBytes("ISO8859-1"));
		}
		catch (Exception e)
		{
			return str;
		}
	}
	
	//将页面表单传来的资料分解
	public boolean getRequest(javax.servlet.http.HttpServletRequest newrequest) {
		boolean flag = false;
		try
		{	
			request = newrequest;
			String ID = request.getParameter("userid");
	/*		if (ID!=null )
			{
				userid = 0;
				try
				{
					userid = Long.parseLong(ID);
					user.setId(userid);
				}
				catch (Exception e)
				{
					message = message + "你要修改的用户号出错！";
				}
			}			
			*/
			long userID = 0;
			try
			{
				ResultSet rs=stmt.executeQuery("select max(id) from my_users");
			    if(rs.next())
			    {
			    	userID = rs.getInt(1)+1;
			    }
			    else
			    {
			    	userID = 100;			
			    }
			}catch(SQLException sql)
			{
				message = message + "你要修改的用户号出错！";
			}
			user.setId(userID);
			username = request.getParameter("username");
			if (username==null || username.equals(""))
			{
				username = "";
				message = message + "用户名为空!";
			}
			user.setUserName(getGbk(username)); 
			String password = request.getParameter("passwd");
			if (password==null || password.equals(""))
			{	
				password = "";
				message = message + "密码为空!";
			}
			String pwdconfirm = request.getParameter("passconfirm");
			if (!password.equals(pwdconfirm))
			{
				message = message + "确认密码不相同!";
			}
			user.setPassWord(getGbk(password));
			String names = request.getParameter("names");;
			if (names==null)
			{
				names = "";
			}
			user.setNames(getGbk(names));
			String sex = request.getParameter("sex");				
			user.setSex(getGbk(sex));
			String address = request.getParameter("address");
			if (address == null)
			{
				address = "";
			}
			user.setAddress(getGbk(address));
			String post = request.getParameter("post");
			if (post == null)
			{
				post = "";
			}
			user.setPost(getGbk(post));
			String phone = request.getParameter("phone");
			if (phone== null)
			{
				phone = "";
			}
			user.setPhone(phone);
			String email = request.getParameter("email");
			if (email == null)
			{	
				email = "";
			}
			user.setEmail(getGbk(email));
			String IP = request.getRemoteAddr();
			user.setRegIpAddress(IP);
			if (message.equals(""))
			{
				flag = true;
			}
			return flag;					
		}
		catch (Exception e)
		{
			return flag;
		}
	}

	public String getSql() {
		sqlStr = "select * from my_users order by id";
		return sqlStr;
	}


	public boolean execute(HttpServletRequest request) throws Exception {
		this.request = request;
		String PAGE = request.getParameter("page");
		if(PAGE != null)
		{
			page = Integer.parseInt(PAGE);
			System.out.println("page11111111:"+page);
		}
		else
		{
			page = 1;
		}
		sqlStr = "select count(*) from my_users";    //取出记录数
		try
		{
			rs = stmt.executeQuery(sqlStr);
			while(rs.next())
			{
				recordCount = rs.getInt(1);
			}
			pageCount = (recordCount+pageSize-1)/pageSize;//页数
		    rs.close();
		}
		catch(SQLException e)
		{
			return false;
		}
		sqlStr = "select * from my_users";
		try
		{
			rs = stmt.executeQuery(sqlStr);
			userlist = new Vector();
			userlist.removeAllElements();
			while (rs.next())
			{	
				int intTemp1 = (page-1)*pageSize;
				int intTemp2 = page*pageSize;
				if(intTemp1 < (rs.getRow()+1)&& rs.getRow() <= intTemp2)
				{
					shopuser user = new shopuser();
					user.setId(rs.getLong(1));
					user.setUserName(rs.getString(2));
					user.setPassWord(rs.getString(3));
					user.setNames(rs.getString(4));
					user.setSex(rs.getString(5));
					user.setAddress(rs.getString(6));
					user.setPhone(rs.getString(7));
					user.setPost(rs.getString(8));
					user.setEmail(rs.getString(9));
					user.setRegTime(rs.getString(10));
					user.setRegIpAddress(rs.getString(11));
					userlist.addElement(user);			
				}
			}
			rs.close();
			return true;
		}
		catch (SQLException e)
		{
			return false;
		}
	}

	public boolean insert(HttpServletRequest req) throws Exception {
		if (getRequest(req)) {
			sqlStr = "select username from My_users where username = '" + user.getUserName() +"'";
			rs = stmt.executeQuery(sqlStr);
			if (rs.next())
			{
				message = message + "该用户名已存在!";
				rs.close();
				return false;
			}
	/*		sqlStr = "insert into my_users (username,password,Names,sex,Address,Phone,Post,Email,RegTime,RegIpaddress) values ('";
			sqlStr = sqlStr + strFormat.toSql(user.getUserName()) + "','";
			sqlStr = sqlStr + strFormat.toSql(user.getPassWord()) + "','";
			sqlStr = sqlStr + strFormat.toSql(user.getNames()) + "','";
			sqlStr = sqlStr + strFormat.toSql(user.getSex()) + "','";
			sqlStr = sqlStr + strFormat.toSql(user.getAddress()) + "','";
			sqlStr = sqlStr + strFormat.toSql(user.getPhone()) + "','";
			sqlStr = sqlStr + strFormat.toSql(user.getPost()) + "','";
			sqlStr = sqlStr + strFormat.toSql(user.getEmail()) + "',getdate(),'";
			sqlStr = sqlStr + user.getRegIpAddress() + "')";*/
			System.out.println(new Date());
			sqlStr = "INSERT INTO my_users " +"VALUES('"+user.getId()+"','"+user.getUserName()+"','"+user.getPassWord()+"','"+user.getNames()+"','"+user.getSex()+"','"+user.getAddress()+"','"+user.getPhone()+"','"+user.getPost()+"','"+user.getEmail()+"','"+new Date().toLocaleString()+"','"+user.getRegIpAddress()+"')";
			try
			{
				stmt.execute(sqlStr);
				message = message+"注册成功";
				return true;
			}
			catch (SQLException sqle)
			{
				return false;
			}
		}
		else
		{
			return false;
		}
	}

	public boolean update(HttpServletRequest req) throws Exception {
		if (getRequest(req)){
			sqlStr = "update my_users set ";
			sqlStr = sqlStr + "username = '" + strFormat.toSql(user.getUserName()) + "',";
			sqlStr = sqlStr + "password = '" + strFormat.toSql(user.getPassWord()) + "',";
			sqlStr = sqlStr + "Names = '" + strFormat.toSql(user.getNames()) + "',";
			sqlStr = sqlStr + "sex = '" + strFormat.toSql(user.getSex()) + "',";
			sqlStr = sqlStr + "address = '" + strFormat.toSql(user.getAddress()) + "',";
			sqlStr = sqlStr + "phone = '" + strFormat.toSql(user.getPhone()) + "',";
			sqlStr = sqlStr + "post = '" + strFormat.toSql(user.getPost()) + "',";
			sqlStr = sqlStr + "Email = '" + strFormat.toSql(user.getEmail()) + "' ";
			sqlStr = sqlStr + " where id = '" + user.getId() + "'";
			try
			{		
				stmt.execute(sqlStr);
				return true;
			}
			catch (SQLException e)
			{
				return false;
			}
		} else {
			return false;
		}
	
	}

	public boolean delete( long aid ) throws Exception {

		sqlStr = "delete from My_users where id = "  + aid ;
		try
		{
			stmt.execute(sqlStr);
			return true;
		}
		catch (SQLException e)
		{
			System.out.println(e);
			return false;
		}
	}

	public boolean getUserinfo(long newid ) throws Exception {
		try
		{
			sqlStr="select  * from My_users where Id = " + newid ;
			rs = stmt.executeQuery(sqlStr);			
			userlist = new Vector();
			while (rs.next()){				
				user.setId(rs.getLong("id"));
				user.setUserName(rs.getString("username"));
				user.setPassWord(rs.getString("password"));
				user.setNames(rs.getString("names"));
				user.setSex(rs.getString("sex"));
				user.setAddress(rs.getString("address"));
				user.setPhone(rs.getString("Phone"));
				user.setPost(rs.getString("post"));
				user.setEmail(rs.getString("email"));
				user.setRegTime(rs.getString("regtime"));
				user.setRegIpAddress(rs.getString("RegIpaddress"));
				userlist.addElement(user);			
			}
			rs.close();
			return true;
		}
		catch (SQLException e)
		{
			return false;
		}
		
	}

	public int getPage() {				//显示的页码
		return page;
	}
	public void setPage(int newpage) {
		page = newpage;
	}

	public int getPageSize(){			//每页显示的图书数
		return pageSize;
	}
	public void setPageSize(int newpsize) {
		pageSize = newpsize;
	}

	public long getPageCount() {				//页面总数
		return pageCount;
	}
	public void setPageCount(int newpcount) {
		pageCount = newpcount;
	}

	public long getRecordCount() {
		return recordCount;
	}
	public void setRecordCount(long newrcount) {
		recordCount= newrcount;
	}
	
	public String getMessage() {
		return message;
	}

	public void setMessage(String msg) {
		message = msg;
	}

	public void setUserid(long uid) {
		userid = uid;
	}
	public long getUserid() {
		return userid;
	}

	public void setUserName(String uName) {
		username = uName;
	}

	public String getUserName() {
		return username;
	}
};