package tserver;

/*
 * 作者：褚廷軍
 * 項目名稱：學生考試系統；
 * 項目要求：畢業設計；
 * 模塊名稱：服務器端驗證教師登錄模塊
 * 模塊功能：接收教師的登陸請求，并驗證用戶信息， 如果正確則登陸成功，如果錯誤重新登陸
 */
import java.io.*;
import java.net.*;
import java.sql.*;
import java.util.StringTokenizer;

import tools.ConnectBean;

public class Server_techLogin extends Thread {

	String str1 = null;// 用戶輸入的考號

	String str2 = null;// 用戶輸入的密碼

	String dbn = ""; // 數據庫中的用戶名

	String dbp = ""; // 數據庫中存的密碼

	Socket socket;

	PreparedStatement pstmt = null;
	Statement stmt=null;

	ResultSet rs;

	DataOutputStream out = null;

	DataInputStream in = null;

	String s = null;

	public Server_techLogin(Socket socket) {
		this.socket = socket;

		try { // 創建網絡連接
			in = new DataInputStream(socket.getInputStream());

			out = new DataOutputStream(socket.getOutputStream());

		} catch (IOException e) {

			e.printStackTrace();
		}

	}

	public void run() {

		String s = null;
	

		String sql;
		try {
			s = in.readUTF(); // 接收考試號和密碼,然后分別取出
			
			StringTokenizer st = new StringTokenizer(s, ",");

			if (st.hasMoreTokens()) {

				str1 = st.nextToken();
				str2 = st.nextToken();
				System.out.println("username :" + str1);
				System.out.println("password :" + str2);
			}

		} catch (IOException e) {

			e.printStackTrace();
		}

		// 讀取數據庫里的用戶信息 并進行驗證
		try {
			ConnectBean cb = new ConnectBean();
			if (!cb.openConnection()) {
				System.out.println("連接數據失敗");
				System.exit(1);
				return;
			}
		
			
			sql = "select tname,tpass from tinfo where tid='" + str1 + "'";
			cb.createPreparedStatement(sql, false);

			ResultSet rs = cb.executeQuery();
			while (rs.next()) {
				dbn = rs.getString("tname");
				dbp = rs.getString("tpass");
				System.out.println("用戶: " + str1 + "  你的用戶名為：" + dbn
						+ ",  你的密碼為:" + dbp);
			}
			cb.close();

			// 驗證用戶密碼

			if (str2.equals(dbp.trim())) {

				out.writeUTF("教師 " + dbn + " 登陸成功");
				System.out.println("用戶 " + dbn + " 登陸成功");
				out.flush();
				out.close();
				

			

			} else {

				out.writeUTF("密碼錯誤");

				System.out.println("登陸密碼錯誤");

				out.close();

			}

		} catch (IOException e) {

			e.printStackTrace();
		} catch (SQLException e) {

			e.printStackTrace();
		}

	}
}