package org.pan.web;

import java.sql.*;
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=8;					//每頁顯示的圖書數
	private int 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 + "你要修改的用戶號出錯！";
				}
			}			
			
			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() throws Exception {
		sqlStr = "select count(*) from my_users";    //取出記錄數
		int rscount = pageSize;
		try
		{
			ResultSet rs1 = stmt.executeQuery(sqlStr);
			if (rs1.next()) recordCount = rs1.getInt(1);				
			rs1.close();
		}
		catch (SQLException e)
		{
			close();
			return false;
		}
		//設定有多少pageCount
		if (recordCount < 1)
            pageCount = 0;
        else
            pageCount = (int)(recordCount - 1) / pageSize + 1;
		//檢查查看的頁面數是否在范圍內
		if (page < 1)  
            page = 1;
        else if (page > pageCount)
            page = pageCount;
		
		rscount = (int) recordCount % pageSize;	 // 最后一頁記錄數        

		//sql為倒序取值
		sqlStr = "select Top " + pageSize + " * from My_users ";
		if (page == 1)
		{
			sqlStr = sqlStr + " order by Id desc";
		} else {
			sqlStr = sqlStr + " where Id not in ( select TOP " + (recordCount-pageSize * page ) + " Id from My_users ORDER BY id) and Id in " +
			"(select TOP " + (recordCount - pageSize * (page-1)) + " Id from My_users ORDER BY ID) " + " order by Id desc";
		}
		try
		{
			rs = stmt.executeQuery(sqlStr);
			userlist = new Vector();
			while (rs.next()){	
				shopuser user = new shopuser();
				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 boolean insert(HttpServletRequest req) throws Exception {
		if (getRequest(req)) {
			sqlStr = "select * 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() + "')";
			try
			{
				stmt.execute(sqlStr);
				sqlStr = "select max(id) from My_users where username = '" +user.getUserName()+ "'";
				rs = stmt.executeQuery(sqlStr);
				while (rs.next())
				{
					userid = rs.getLong(1);
				}
				rs.close();
				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 int 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;
	}
};