dbuser.java

天乙代码src_531.rar 天乙代码src_531.rar 天乙代码src_531.rar 天乙代码src_531.rar

      return Sys.RESULT_OBJECTEXCEPTION;
    }
    finally {
      DBSQL.freeCon();
    }
  }

  public synchronized void createUserFile() {
    TranContext myDBTrans = new TranContext();
    try {
      List myList = null;
      this.pages = PagesFactory.getInstance();
      this.pages.setPages(1);
      this.pages.setPerPageNum(10);
      myList = this.loadDBs(myDBTrans, "byExp");
      int len = myList.size();
      StringBuffer sb = new StringBuffer();
      UserInfo aui = new UserInfo();
      for (int i = 0; i < len; i++) {
        aui = (UserInfo) myList.get(i);
        sb.append("<tr><td width='50%'>\n");
        sb.append("<font color=\"#999999\" size=\"1\" face=\"Verdana, Arial, Helvetica, sans-serif\">" +
                  (i + 1) +
            ".</font><a href='userInfoAction.do?sid=###&showtype=userID&uid=" +
            aui.getID() + "'>" + aui.getNickName() + "[" + aui.getUserName() +
            "]</a><font face='Tahoma' size='1' color='#FF0000'> [" +
            aui.getExp() + "]</font></li>");
        sb.append("</td></tr>");
      }
      String filepath = Util.getPubFilePath();
      File file = new File(filepath + "userexp.htm");
      if (file.exists()) {
        file.delete();
      }
      FileOutputStream wf = new FileOutputStream(filepath + "userexp.htm");
      if (Sys.isLocale()) {
        wf.write(sb.toString().getBytes());
      }
      else {
        wf.write(sb.toString().getBytes("UTF8"));
      }
      wf.close();

    }
    catch (ObjectException e) {
      logger.error(e);
    }
    catch (IOException e) {
      logger.error(e);
    }
    finally {
      myDBTrans.freeCon();
    }
  }

  public void loadDB(TranContext myDB, String key, boolean isLoad) throws
      ObjectException, ObjectNoExistException {
    try {
      if (key.equals("UserName")) {
        myDB.prepareStatement(ISUSERNAME);
        myDB.setString(1, this.myUserInfo.getUserName());
        rs = myDB.executeQuery();
      }
      if (key.equals("Passwd")) {
        myDB.prepareStatement(ISUSERPASSWD);
        myDB.setString(1, this.myUserInfo.getUserName());
        myDB.setString(2, this.myUserInfo.getRePasswd());
        rs = myDB.executeQuery();
      }
      if (key.equals("ID")) {
        myDB.prepareStatement(ISUSERID);
        myDB.setLong(1, this.myUserInfo.getID());
        rs = myDB.executeQuery();
      }
      if (key.equals("Email")) {
        myDB.prepareStatement(ISUSEREMAIL);
        myDB.setString(1, this.myUserInfo.getEmail());
        rs = myDB.executeQuery();
      }
      if (rs.next()) {
        if (isLoad) {
          this.myUserInfo.setID(rs.getLong("ID"));
          this.myUserInfo.setUserName(rs.getString("UserName"));
          this.myUserInfo.setNickName(rs.getString("NickName"));
          this.myUserInfo.setPasswd(rs.getString("Passwd"));
          this.myUserInfo.setRePasswd(rs.getString("RePasswd"));
          this.myUserInfo.setEmail(rs.getString("Email"));
          this.myUserInfo.setQuestion(rs.getString("Question"));
          this.myUserInfo.setAnswer(rs.getString("Answer"));
          this.myUserInfo.setLogintime(rs.getLong("LoginTime"));
          this.myUserInfo.setLogoutTime(rs.getLong("LogoutTime"));
          this.myUserInfo.setLoginTimes(rs.getInt("LoginTimes"));
          this.myUserInfo.setPost(rs.getInt("Post"));
          this.myUserInfo.setExp(rs.getInt("Exp"));
          this.myUserInfo.setExpression(rs.getInt("Expression"));
          this.myUserInfo.setArticleNum(rs.getInt("ArticleNum"));
          this.myUserInfo.setStayTime(rs.getLong("StayTime"));
          this.myUserInfo.setNstaytime(rs.getLong("Nstaytime"));
          this.myUserInfo.setPower(rs.getInt("Power"));
          this.myUserInfo.setHpower(rs.getInt("Hpower"));
          this.myUserInfo.setSign_Name1(rs.getString("Sign_Name1"));
          this.myUserInfo.setSign_Detail1(rs.getString("Sign_Detail1"));
          this.myUserInfo.setSign_Name2(rs.getString("Sign_Name2"));
          this.myUserInfo.setSign_Detail2(rs.getString("Sign_Detail2"));
          this.myUserInfo.setSign_Name3(rs.getString("Sign_Name3"));
          this.myUserInfo.setSign_Detail3(rs.getString("Sign_Detail3"));
          this.myUserInfo.setFriend(rs.getString("Friend"));
          this.myUserInfo.setBoardSave(rs.getString("BoardSave"));
          this.myUserInfo.setCanInBoards(rs.getString("CanInBoards"));
          this.myUserInfo.setHavePic(rs.getInt("HavePic"));
          this.myUserInfo.setPicFileName(rs.getString("PicFileName"));
          this.myUserInfo.setStyle(rs.getInt("Style"));
        }
      }
      else {
        throw new ObjectNoExistException();
      }
    }
    catch (SQLException e) {
      throw new ObjectException(e.toString());
    }
    finally {
      try {
        if (rs != null) {
          rs.close();
          rs = null;
        }
      }
      catch (SQLException e) {
      }
      try {
        if (myDB != null) {
          myDB.close();
        }
      }
      catch (SQLException e) {
      }
    }

  }

  public List loadDBs(TranContext myDB, String key) throws
      ObjectException {
    List alist = ListFactory.getInstance(2);
    UserInfo aUserInfo = null;
    try {
      if (key.equals("byExp")) {
        String SQLStr = "select * from userinfo order by Exp desc";
        this.pages.setTotals(10);
        this.pages.doPageBreak();
        //this.sListPageBreak = this.pages.getListPageBreak();
        this.pages.setSQL(SQLStr);
        myDB.prepareStatement(this.pages.getSQLString("ID"));
        rs = myDB.executeQuery();
      }
      if (key.equals("UserManage")) {
        String strSQL = "select * from userinfo order by " + this.getOrders() +
            " " + this.getOrderBy();
        this.pages.setTotals(this.getUserNum(myDB, "All"));
        this.pages.doPageBreak();
        this.sListPageBreak = this.pages.getListPageBreak();
        this.pages.setSQL(strSQL);
        myDB.prepareStatement(this.pages.getSQLString("ID"));
        rs = myDB.executeQuery();
      }
      while (rs.next()) {
        aUserInfo = new UserInfo();
        aUserInfo.setID(rs.getLong("ID"));
        aUserInfo.setUserName(rs.getString("UserName"));
        aUserInfo.setNickName(rs.getString("NickName"));
        aUserInfo.setPasswd(rs.getString("Passwd"));
        aUserInfo.setRePasswd(rs.getString("RePasswd"));
        aUserInfo.setEmail(rs.getString("Email"));
        aUserInfo.setQuestion(rs.getString("Question"));
        aUserInfo.setAnswer(rs.getString("Answer"));
        aUserInfo.setLogintime(rs.getLong("LoginTime"));
        aUserInfo.setLogoutTime(rs.getLong("LogoutTime"));
        aUserInfo.setLoginTimes(rs.getInt("LoginTimes"));
        aUserInfo.setPost(rs.getInt("Post"));
        aUserInfo.setExp(rs.getInt("Exp"));
        aUserInfo.setExpression(rs.getInt("Expression"));
        aUserInfo.setArticleNum(rs.getInt("ArticleNum"));
        aUserInfo.setStayTime(rs.getLong("StayTime"));
        aUserInfo.setNstaytime(rs.getLong("Nstaytime"));
        aUserInfo.setPower(rs.getInt("Power"));
        aUserInfo.setHpower(rs.getInt("Hpower"));
        aUserInfo.setSign_Name1(rs.getString("Sign_Name1"));
        aUserInfo.setSign_Detail1(rs.getString("Sign_Detail1"));
        aUserInfo.setSign_Name2(rs.getString("Sign_Name2"));
        aUserInfo.setSign_Detail2(rs.getString("Sign_Detail2"));
        aUserInfo.setSign_Name3(rs.getString("Sign_Name3"));
        aUserInfo.setSign_Detail3(rs.getString("Sign_Detail3"));
        aUserInfo.setFriend(rs.getString("Friend"));
        aUserInfo.setBoardSave(rs.getString("BoardSave"));
        aUserInfo.setCanInBoards(rs.getString("CanInBoards"));
        aUserInfo.setHavePic(rs.getInt("HavePic"));
        aUserInfo.setPicFileName(rs.getString("PicFileName"));
        aUserInfo.setStyle(rs.getInt("Style"));
        alist.add(aUserInfo);
        aUserInfo = null;
      }
      return alist;
    }
    catch (SQLException e) {
      throw new ObjectException(e.toString());
    }
    finally {
      try {
        if (rs != null) {
          rs.close();
          rs = null;
        }
      }
      catch (SQLException e) {
      }
      try {
        if (myDB != null) {
          myDB.close();
        }
      }
      catch (SQLException e) {
      }
    }
  }

  public void insertDB(TranContext myDB) throws ObjectException {
    try {
      myDB.prepareStatement(ADDUSER);
      long atime = Util.getaLongTime();
      myDB.setLong(1, this.myUserInfo.getID());
      myDB.setString(2, this.myUserInfo.getUserName());
      myDB.setString(3, this.myUserInfo.getNickName());
      myDB.setString(4, this.myUserInfo.getPasswd());
      myDB.setString(5, this.myUserInfo.getRePasswd());
      myDB.setString(6, this.myUserInfo.getEmail());
      myDB.setString(7, this.myUserInfo.getQuestion());
      myDB.setString(8, this.myUserInfo.getAnswer());
      myDB.setLong(9, atime);
      myDB.setLong(10, atime);
      myDB.executeUpdate();
    }
    catch (SQLException e) {
      throw new ObjectException(e.toString());
    }
    finally {
      try {
        if (myDB != null) {
          myDB.close();
        }
      }
      catch (SQLException e) {
      }
    }
  }

  public void updateDB(TranContext myDB, String key) throws
      ObjectException {
    try {
      if (key.equals("NickName")) {
        myDB.prepareStatement(UPDATE_NICKNAME);
        myDB.setString(1, myUserInfo.getNickName());
        myDB.setLong(2, myUserInfo.getID());
        myDB.executeUpdate();
      }
      if (key.equals("Passwd")) {
        MD5 myMD5 = new MD5();
        myDB.prepareStatement(UPDATE_PASSWD);
        myDB.setString(1, myUserInfo.getPasswd());
        myDB.setString(2, myMD5.getMD5ofStr(myUserInfo.getPasswd()));
        myDB.setLong(3, myUserInfo.getID());
        myDB.executeUpdate();
      }
      if (key.equals("updateUserData")) {
        myDB.prepareStatement(UPDATE_USERDATA);
        myDB.setInt(1, myUserInfo.getExp());
        myDB.setInt(2, myUserInfo.getPower());
        myDB.setInt(3, myUserInfo.getHpower());
        myDB.setLong(4, myUserInfo.getID());
        myDB.executeUpdate();
      }
      if (key.equals("userLogin")) {
        myDB.prepareStatement(UPDATE_USERLOGIN);
        myDB.setInt(1, myUserInfo.getPower());
        myDB.setLong(2, Util.getaLongTime());
        myDB.setLong(3, myUserInfo.getID());
        myDB.executeUpdate();
      }
      if (key.equals("userLogin1")) {
        myDB.prepareStatement(UPDATE_USERLOGIN1);
        myDB.setInt(1, myUserInfo.getPower());
        myDB.setLong(2, Util.getaLongTime());
        myDB.setLong(3, myUserInfo.getID());
        myDB.executeUpdate();
      }
      if (key.equals("stayTime")) {
        long atime = Util.getaLongTime();
        myDB.prepareStatement(UPDATE_USERSTAYTIME);
        myDB.setLong(1, (120 * 1000));
        myDB.setLong(2, atime);
        myDB.setLong(3, atime);
        myDB.setLong(4, myUserInfo.getID());
        myDB.executeUpdate();
      }
      if (key.equals("userSign")) {
        myDB.prepareStatement(UPDATE_USERSIGN);
        myDB.setString(1, myUserInfo.getSign_Name1());
        myDB.setString(2, myUserInfo.getSign_Detail1());
        myDB.setString(3, myUserInfo.getSign_Name2());
        myDB.setString(4, myUserInfo.getSign_Detail2());
        myDB.setString(5, myUserInfo.getSign_Name3());
        myDB.setString(6, myUserInfo.getSign_Detail3());
        myDB.setLong(7, myUserInfo.getID());
        myDB.executeUpdate();
      }
      if (key.equals("friend")) {
        myDB.prepareStatement(UPDATE_USERFRIEND);
        myDB.setString(1, myUserInfo.getFriend());
        myDB.setLong(2, myUserInfo.getID());
        myDB.executeUpdate();
      }
      if (key.equals("boardsave")) {
        myDB.prepareStatement(UPDATE_BOARDSAVE);
        myDB.setString(1, myUserInfo.getBoardSave());
        myDB.setLong(2, myUserInfo.getID());
        myDB.executeUpdate();
      }
      if (key.equals("datapost")) {
        myDB.prepareStatement(UPDATE_USERDATAPOST);
        myDB.setInt(1, myUserInfo.getExpression());
        myDB.setInt(2, myUserInfo.getArticleNum());
        myDB.setInt(3, myUserInfo.getPower());
        myDB.setLong(4, myUserInfo.getID());
        myDB.executeUpdate();
      }
      if (key.equals("userPic")) {
        myDB.prepareStatement(UPDATE_USERPIC);
        myDB.setInt(1, myUserInfo.getHavePic());
        myDB.setString(2, myUserInfo.getPicFileName());
        myDB.setLong(3, myUserInfo.getID());
        myDB.executeUpdate();
      }
      if (key.equals("caninboards")) {
        myDB.prepareStatement(UPDATE_CANINBOARDS);
        myDB.setString(1, this.myUserInfo.getCanInBoards());
        myDB.setLong(2, this.myUserInfo.getID());
        myDB.executeUpdate();
      }
    }
    catch (SQLException e) {
      throw new ObjectException(e.toString());
    }
    finally {
      try {
        if (myDB != null) {
          myDB.close();
        }
      }
      catch (SQLException e) {
      }
    }
  }

  public void delDB(TranContext aDBTrans, String key) throws ObjectException {
    /**@todo Implement this com.laoer.bbscs.db.DBInf method*/
    throw new java.lang.UnsupportedOperationException(
        "Method delDB() not yet implemented.");
  }

}