package bookshop.run;/** * <p>Title: </p> * <p>Description: </p> * <p>Copyright: Copyright (c) 2004</p> * <p>Company: </p> * @author not attributable * @version 1.0 */import java.sql.*;import java.util.Vector;import javax.servlet.http.HttpServletRequest;import bookshop.util.*;import bookshop.book.*;public class op_user extends DataBase{        private user user = new user();	                        //新的用戶對象        private javax.servlet.http.HttpServletRequest request;  //建立頁面請求        private Vector userlist;			//顯示用戶列表向量數(shù)組        private int page = 1;					//顯示的頁碼        private int pageSize=8;					//每頁顯示的圖書數(shù)        private int pageCount =0;				//頁面總數(shù)        private long recordCount =0;			        //查詢的記錄總數(shù)        private String message = "";			        //出錯信息提示        private String username = "";			      //注冊后返回的用戶名        private long userid = 0;			     //注冊后返回的用戶ID  public op_user() {  }  //添加新用戶  public boolean add(HttpServletRequest req) throws Exception {        if (getRequest(req)) {            DataBase db = new DataBase();            db.connect();            stmt = db.conn.createStatement ();            sqlStr = "select * from shop_user where username = '" +                      user.getUserName() +"'";            sqlStr = "insert into shop_user (username,password,Names,sex,"+                     "Address,Phone,Post,Email,RegTime,RegIpaddress) values ('";            sqlStr = sqlStr + dataFormat.toSql(user.getUserName()) + "','";            sqlStr = sqlStr + dataFormat.toSql(user.getPassWord()) + "','";            sqlStr = sqlStr + dataFormat.toSql(user.getNames()) + "','";            sqlStr = sqlStr + dataFormat.toSql(user.getSex()) + "','";            sqlStr = sqlStr + dataFormat.toSql(user.getAddress()) + "','";            sqlStr = sqlStr + dataFormat.toSql(user.getPhone()) + "','";            sqlStr = sqlStr + dataFormat.toSql(user.getPost()) + "','";            sqlStr = sqlStr + dataFormat.toSql(user.getEmail()) + "',now(),'";            sqlStr = sqlStr + user.getRegIpAddress() + "')";            try{                stmt.executeUpdate(sqlStr);                sqlStr = "select max(id) from shop_user where username = '" +                         user.getUserName()+ "'";                         rs = stmt.executeQuery(sqlStr);                         while (rs.next()){                              userid = rs.getLong(1);                              }                             rs.close();                             return true;                }catch (Exception sqle){                  System.out.print(sqle.getMessage());                  return false;                }           } else{            return false;           }  }  //分析頁面轉(zhuǎn)遞的參數(shù)  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 boolean get_alluser() throws Exception {      sqlStr = "select count(*) from shop_user";    //取出記錄數(shù)      int rscount = pageSize;      try{        DataBase db = new DataBase();        db.connect();        stmt = db.conn.createStatement ();        ResultSet rs1 = stmt.executeQuery(sqlStr);        if (rs1.next()) recordCount = rs1.getInt(1);        rs1.close();        }catch (SQLException e){          System.out.print("count:"+e.getMessage());          return false;        }                                //設(shè)定有多少pageCount        if (recordCount < 1)           pageCount = 0;        else           pageCount = (int)(recordCount - 1) / pageSize + 1;                                //檢查查看的頁面數(shù)是否在范圍內(nèi)        if (page < 1)           page = 1;        else if (page > pageCount)          page = pageCount;          rscount = (int) recordCount % pageSize;	 // 最后一頁記錄數(shù)                                //sql為倒序取值          sqlStr = "select  * from shop_user ";          if (page == 1){             sqlStr = sqlStr + " order by Id desc limit 0,"+pageSize;             } else {               sqlStr = sqlStr + " order by Id desc limit "+(recordCount-pageSize*page) +","+(recordCount - pageSize * (page-1));               }        try{          DataBase db = new DataBase();          db.connect();          stmt = db.conn.createStatement ();          rs = stmt.executeQuery(sqlStr);          userlist = new Vector();          while (rs.next()){                user user = new user();                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){              System.out.print(e.getMessage());              return false;              }}//修改用戶public boolean update(HttpServletRequest req) throws Exception {if (getRequest(req)){sqlStr = "update shop_user set ";sqlStr = sqlStr + "username = '" + dataFormat.toSql(user.getUserName()) + "',";sqlStr = sqlStr + "password = '" + dataFormat.toSql(user.getPassWord()) + "',";sqlStr = sqlStr + "Names = '" + dataFormat.toSql(user.getNames()) + "',";sqlStr = sqlStr + "sex = '" + dataFormat.toSql(user.getSex()) + "',";sqlStr = sqlStr + "address = '" + dataFormat.toSql(user.getAddress()) + "',";sqlStr = sqlStr + "phone = '" + dataFormat.toSql(user.getPhone()) + "',";sqlStr = sqlStr + "post = '" + dataFormat.toSql(user.getPost()) + "',";sqlStr = sqlStr + "Email = '" + dataFormat.toSql(user.getEmail()) + "' ";sqlStr = sqlStr + " where id = '" + user.getId() + "'";try{                  DataBase db = new DataBase();                  db.connect();                  stmt = db.conn.createStatement ();                  stmt.execute(sqlStr);                  return true;    } catch (SQLException e){      return false;       }} else {       return false;       }}//刪除用戶 public boolean delete( long aid ) throws Exception {    sqlStr = "delete from shop_user where id = "  + aid ;    try{      DataBase db = new DataBase();      db.connect();      stmt = db.conn.createStatement ();      stmt.execute(sqlStr);      return true;       }catch (SQLException e){        System.out.println(e);        return false;        }}//查詢指定id的用戶，用于支持頁面的查看詳細資料請求 public boolean  getUserinfo(long newid ) throws Exception {    try{      sqlStr="select  * from shop_user where Id = " + newid ;      DataBase db = new DataBase();      db.connect();      stmt = db.conn.createStatement ();      rs = stmt.executeQuery(sqlStr);      userlist = new Vector();      while (rs.next()){        user.setId(rs.getLong("id"));        System.out.print(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 (Exception e){          System.out.print(e.getMessage());          return false;        }}  public String getGbk( String str) {               try  {                return new String(str.getBytes("ISO8859-1"));                }catch (Exception e){                  return str;                  }          }  public int getPage() {				//顯示的頁碼                              return page;                      }                      public void setPage(int newpage) {                              page = newpage;                      }                      public int getPageSize(){			//每頁顯示的圖書數(shù)                              return pageSize;                      }                      public void setPageSize(int newpsize) {                              pageSize = newpsize;                      }                      public int getPageCount() {		//頁面總數(shù)                              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;                      }                      public Vector getUserlist() {                           return userlist;                       }};