package com.laoer.bbscs.user;

import java.sql.*;
import java.io.*;
import java.util.*;
import com.laoer.bbscs.db.*;
import com.laoer.bbscs.txthtml.*;
import com.laoer.bbscs.tool.MD5;

/**
 * Title:        BBS-CS
 * Description:  BBS-CS(BBS式虛擬社區系統)
 * Copyright:    Copyright (c) 2002
 * Company:      loveroom.com.cn
 * @author laoer
 * @version 3.0
 */

public class User {

  String SQL = "";
  DbTrans myDbTrans;
  DoText myDoText;
  ResultSet rs = null;
  MD5 myMD5;
  public User() {
      this.myDbTrans = new DbTrans();
      this.myDoText = new DoText();
      this.myMD5 = new MD5();
  }

  public boolean isUser(String userName) {
      boolean isUser = false;
      int numIsUser = 0;
      SQL = "select count(*) as numIsUser from user where name='"+ userName +"'";
      try {
          rs = myDbTrans.executeQuery(SQL);
          if (rs.next()) {
              numIsUser = rs.getInt("numIsUser");
          }
          rs.close();
      }
      catch (SQLException e){
      }
      if (numIsUser != 0) {
          isUser = true;
      }
      else {
          isUser = false;
      }
      return isUser;
  }

  public boolean isUser(String userName, String userPassWD) {
      boolean isUser = false;
      int numIsUser = 0;
      SQL = "select count(*) as numIsUser from user where name='"+ userName +"' and passwd1='"+ myMD5.getMD5ofStr(userPassWD) +"'";
      try {
          rs = myDbTrans.executeQuery(SQL);
          if (rs.next()) {
              numIsUser = rs.getInt("numIsUser");
          }
          rs.close();
      }
      catch (SQLException e){
      }
      if (numIsUser != 0) {
          isUser = true;
      }
      else {
          isUser = false;
      }
      return isUser;
  }

  public String getUserID(String userName) {
      String userID = "";
      SQL = "select ID from user where name ='"+ userName +"'";
      try {
          rs = myDbTrans.executeQuery(SQL);
          if (rs.next()) {
              userID = rs.getString("ID");
          }
          rs.close();
      }
      catch (SQLException e){
      }
      return userID;
  }

  public boolean isHaveEmail(String strEmailAdd) {
      boolean isHaveEmail = false;
      int numIsHaveEmail = 0;
      SQL = "select count(*) as numIsHaveEmail from user where email='" + strEmailAdd + "'";
      try {
          rs = myDbTrans.executeQuery(SQL);
          if (rs.next()) {
              numIsHaveEmail = rs.getInt("numIsHaveEmail");
          }
          rs.close();
      }
      catch (SQLException e){
      }
      if (numIsHaveEmail != 0) {
          isHaveEmail = true;
      }
      else {
          isHaveEmail = false;
      }
      return isHaveEmail;
  }

  public boolean addUser(String strName,String strNick,String strEmailAdd,String strPasswd,String strQuestion,String strAnswer) {
      boolean addUser = false;
      String strPasswd1 = "";
      strPasswd1 = myMD5.getMD5ofStr(strPasswd);
      SQL = "insert into user (name,nick,email,passwd,passwd1,question,answer,logintime) values ('"+ strName +"','"+ strNick +"','"+ strEmailAdd +"','"+ strPasswd +"','"+ strPasswd1 +"','"+ strQuestion +"','"+ strAnswer +"',now())";
      try {
          myDbTrans.executeUpdate(SQL);
          addUser = true;
      }
      catch (SQLException e){
          return false;
      }
      int intUID = 0;
      SQL = "select ID from user where name = '"+ strName +"'";
      try {
          rs = myDbTrans.executeQuery(SQL);
          if (rs.next()) {
              intUID = rs.getInt("ID");
          }
          else {
              return false;
          }
          rs.close();
      }
      catch (SQLException e){
      }
      SQL = "insert into userdata (UID,power,hpower) values ('"+ intUID +"',10,10)";
      try {
          myDbTrans.executeUpdate(SQL);
          addUser = true;
      }
      catch (SQLException e){
          return false;
      }
      SQL = "insert into mydata (UID) values ('"+ intUID +"')";
      try {
          myDbTrans.executeUpdate(SQL);
          addUser = true;
      }
      catch (SQLException e){
          return false;
      }
      return addUser;
  }

  public boolean userLogin(String userName) {
      String strUserID = getUserID(userName);
      SQL = "select (UNIX_TIMESTAMP(now())-UNIX_TIMESTAMP(likai)) as nstaytime from user where ID="+ strUserID;
      int nstaytime = 0;
      try {
          rs = myDbTrans.executeQuery(SQL);
          if (rs.next()) {
              nstaytime = rs.getInt("nstaytime");
              nstaytime=nstaytime/3600;
          }
          rs.close();
      }
      catch (SQLException e){
      }
      SQL = "select power,hpower from userdata where UID="+ strUserID;
      int power = 0;
      int hpower = 0;
      int hfpower = 0;
      try {
         rs = myDbTrans.executeQuery(SQL);
         if (rs.next()) {
            power=rs.getInt("power");
	    hpower=rs.getInt("hpower");
         }
         rs.close();
      }
      catch (SQLException e){
      }
      hfpower = hpower*nstaytime/12;
      int zpower = hfpower + power;
      if (zpower >= hpower) {
          hfpower = hpower - power;
      }
      SQL = "update userdata set nstaytime="+ nstaytime +",power=power+"+ hfpower +" where UID="+ strUserID;
      try {
          myDbTrans.executeUpdate(SQL);
      }
      catch (SQLException e){
          return false;
      }
      SQL = "update user set logintime=now(),cishu=cishu+1 where ID="+ strUserID;
      try {
          myDbTrans.executeUpdate(SQL);
      }
      catch (SQLException e){
          return false;
      }
      return true;
  }

  public int guestLogin() {
      int guestID = getGuestMaxID();
      while (!addGuest(guestID)) {
          guestID = getGuestMaxID();
      }
      return guestID;
  }

  public int getGuestMaxID() {
      int numMaxID = 1;
      SQL = "select max(ID)+1 as numMaxID from guestuser";
      try {
          rs = myDbTrans.executeQuery(SQL);
          if (rs.next()) {
              numMaxID = rs.getInt("numMaxID");
          }
          rs.close();
          if (numMaxID == 0) {
              numMaxID = 1;
          }
      }
      catch (SQLException e) {
      }
      return numMaxID;
  }

  public boolean addGuest(int guestID) {
      SQL = "insert into guestuser (ID,guestname,glogintime) values ('"+ guestID +"','Guest"+ guestID +"',now())";
      try {
          myDbTrans.executeQuery(SQL);
          return true;
      }
      catch (SQLException e) {
          return false;
      }
  }

  public int getOlineUser() {
      int numOlineUser = 0;
      SQL = "select count(*) as numOlineUser from user WHERE (UNIX_TIMESTAMP(NOW())-UNIX_TIMESTAMP(logintime))<=180";
      try {
          rs = myDbTrans.executeQuery(SQL);
          if (rs.next()) {
              numOlineUser = rs.getInt("numOlineUser");
          }
          rs.close();
      }
      catch (SQLException e) {
      }
      return numOlineUser;
  }

  public void userRef(String strUserID) {
      int staytime = 0;
      SQL = "select (UNIX_TIMESTAMP(now())-UNIX_TIMESTAMP(logintime)) as tltime from user where ID="+ strUserID;
      try {
          rs = myDbTrans.executeQuery(SQL);
          if (rs.next()) {
              staytime = rs.getInt("tltime");
          }
          rs.close();
      }
      catch (SQLException e) {
      }
      SQL = "update userdata set staytime=staytime+"+ staytime +",nstaytime=0 where UID="+ strUserID;
      try {
          myDbTrans.executeUpdate(SQL);
      }
      catch (SQLException e) {
      }
      SQL = "update user set logintime=now(),likai=now() where ID="+ strUserID;
      try {
          myDbTrans.executeUpdate(SQL);
      }
      catch (SQLException e) {
      }
  }

  public void guestRef(String strGuestID) {
      SQL = "update guestuser set glogintime = now() where ID = "+strGuestID;
      try {
          myDbTrans.executeUpdate(SQL);
      }
      catch (SQLException e) {
      }
  }

  public int getOlineGuest() {
      int numOlineGuest = 0;
      SQL = "select count(*) as numOlineGuest from guestuser WHERE (UNIX_TIMESTAMP(NOW())-UNIX_TIMESTAMP(glogintime))<=180";
      try {
         rs = myDbTrans.executeQuery(SQL);
         if (rs.next()) {
             numOlineGuest = rs.getInt("numOlineGuest");
         }
         rs.close();
      }
      catch (SQLException e) {
      }
      return numOlineGuest;
  }

  public boolean isUnPost(String strUserName) {
      int numIsUnPost = 0;
      SQL = "select count(*) as numIsUnPost from unpost where (UNIX_TIMESTAMP(unposttime)-UNIX_TIMESTAMP(NOW()))>0 and Uname='"+strUserName+"'";
      try {
          rs = myDbTrans.executeQuery(SQL);
          if (rs.next()) {
              numIsUnPost = rs.getInt("numIsUnPost");
          }
          rs.close();
      }
      catch (SQLException e) {
      }
      if (numIsUnPost != 0) {
          return true;
      }
      else {
          return false;
      }
  }

  public boolean setUserUnPost(String strUserID) {
      SQL = "update user set post = 1 where ID="+strUserID;
      try {
          myDbTrans.executeUpdate(SQL);
          return true;
      }
      catch (SQLException e) {
          return false;
      }
  }

  public boolean setUserPost(String strUserName) {
      SQL = "update user set post = 0 where name='"+strUserName+"'";
      try {
          myDbTrans.executeUpdate(SQL);
          return true;
      }
      catch (SQLException e) {
          return false;
      }
  }

  public void close() {
      try {
          myDbTrans.close();
      }
      catch (SQLException e){
      }
  }
}