import java.io.BufferedReader;
import java.io.IOException;
import java.io.PRintWriter;
import java.sql.SQLException;

import util.*;
/*
 *
 * @author zhang
 * 完成客戶端請求處理
 *
 */
public class ServerThread extends Thread{
 private final int  Error=0; //查詢出錯
 private final int  N_VALIDE=1;//不合法
 private final int  VALIDE=2;//合法
 private Angent angent; 
 private PrintWriter out;
 private String userId;
 private String passWord;
 private ChatProtocol cp;
 
 public ServerThread(Angent aangent) {
  angent=aangent;
  userId=angent.getUserId();//得到用戶的帳號密碼
  password=angent.getPassword();
  cp=new ChatProtocol(angent);//根據聊天內容建立一個protocol對象
 }

 public void run() {
  int i=isValid();
  out.println(i);/*向客戶端發送驗證信息*/
  if(i<VALIDE) this.stop(); //本線程中止
  //登陸成功,進行消息處理和轉接
     cp.chat();//開始聊天
  
 }
 private int isValid() {//驗證用戶的合法性
  String sql="select from user where userId=? and password=?";
  try {
   return SqlFactory.getPassSql().isValidate(sql,userId,password)?VALIDE:N_VALIDE;
  } catch (SQLException e) {
   System.out.println("用戶驗證查詢時出錯");
   e.printStackTrace();
   return Error;
  }
 }
}