/*
 * 創建日期 2006-4-18
 * 作者：褚廷軍
 * 項目名稱：學生考試系統；
 * 項目要求：畢業設計；
 * 模塊名稱：服務器端總控制器
 * 模塊功能：建立一組線程接收用戶請求，并轉發到相應功能模塊；
 *          
 *          4.27號增加新功能：統計登陸人數，和定義最大連接數 
 *          5.12號增加新功能，如果考生已經考過，則不能進入考場 
 *        
 * 未完成功能：1 如果用戶考完后，讓出空間讓以后來的用戶登陸；
 *           
 * 更改所生成文件模板為
 * 窗口 > 首選項 > Java > 代碼生成 > 代碼和注釋
 */
package tserver;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerManager {
	// 服務器端，為建立的每個連接創建一個服務器線程；

	private static int counter = 0;          //記錄參加考試的人數；

	private static int Maxcount =0;          //此值為接收的管理員對此次參加考試人數的限定； 
//	private static int Timecount=0;
	
	static String userstatus="";
	static String linkstatus="";
	static String serstatus="";
	static  String ucount;

	public static String linkShow(String str) {
		
		System.out.println(str);
		return str;
	}

	public static String userShow(String str) {
		
		System.out.println(str);
		return str;
	}

	public static String serShow(String str) {
	   System.out.println(str);
		return str;
	}
	public static String countShow(String count) {
		return count;
		
	}
	public ServerManager() {

		Thread td1 = new Thread() {

			

			public void run() {
				

				serstatus= "login thread  start!\n";
				
				serShow(serstatus);

				ServerSocket ss1 = null;
				Socket you = null;
				int port1 = 8001;
				try {
					ss1 = new ServerSocket(port1);

					serstatus = "listener the port:" + port1;
					serShow(serstatus);

					
				} catch (IOException e) {

					e.printStackTrace();
				}

				while (true) {

					try {

						you = ss1.accept();

					} catch (IOException e) {

						e.printStackTrace();
					}
					if (you != null) {
						counter++;
						ucount = "現在參加考試的人數為:" + counter;
						
						countShow(ucount);
						
						if (counter < Maxcount) {
							userstatus= "user's IP" + you.getInetAddress()
									+ " connected " + port1 + "進行登陸";
							userShow(userstatus);
						
							// 第一個線程啟動
							new Server_login(you).start();

						} else {
							userstatus = "user's IP" + you.getInetAddress()
									+ " connected " + port1 + "中斷線程啟動";
							userShow(userstatus);
							
							// 中斷線程啟動
							new Maxcounter(you);
						}

					}

				}

			}

			

		};
		td1.start();

		
		// 啟動一個響應客戶端讀取試題的線程

		Thread td2 = new Thread("two") {
			public void run() {
				
				serstatus= "thread 2 start!";
				serShow(linkstatus);
				ServerSocket ss2 = null;
				int port2 = 8002;

				try {
					ss2 = new ServerSocket(port2);
					linkstatus = "listener the port:" + port2;
					linkShow(serstatus);
				} catch (IOException e) {

					e.printStackTrace();
				}

				while (true) {
					Socket you2 = null;
					try {
						you2 = ss2.accept();
					} catch (IOException e) {

						e.printStackTrace();
					}
					if (you2 != null) {
						userstatus = "user's IP" + you2.getInetAddress()
								+ " connected " + port2 + "進行讀題";
						userShow(userstatus);
						new Server_readTest(you2).start();

					}}}

		};
		td2.start();
		
		
		
		// 啟動一個接收用戶答應并存儲的線程
		Thread td3 = new Thread("three") {

			ServerSocket ss3 = null;

			int port3 = 8003;

			public void run() {
				serstatus="thread 3 start!";
			   serShow(serstatus);
			 
				try {
					ss3 = new ServerSocket(port3);
					linkstatus="listener the port:" + port3;
					  linkShow(linkstatus);
					
				} catch (IOException e) {

					e.printStackTrace();
				}
				while (true) {
					Socket you3 = null;

					try {
						you3 = ss3.accept();
					} catch (IOException e) {

						e.printStackTrace();
					}
					if (you3 != null) {
						userstatus="user's IP" + you3.getInetAddress()
								+ " connected " + port3 + "提交答案";
						userShow(userstatus);
						
						// 第3個線程啟動
						new Server_readScore(you3).start();

					}
				}
			}
		};
		td3.start();

		// 啟動一個用戶查詢的線程
		Thread td4 = new Thread("four") {

			ServerSocket ss4 = null;

			int port4 = 8004;

			public void run() {
				serstatus="thread 4 start!";
				serShow(serstatus);

				try {
					ss4 = new ServerSocket(port4);
					linkstatus="listener the port:" + port4;
					linkShow(linkstatus);
					
				} catch (IOException e) {

					e.printStackTrace();
				}
				while (true) {
					Socket you4 = null;

					try {
						you4 = ss4.accept();
					} catch (IOException e) {

						e.printStackTrace();
					}
					if (you4 != null) {
						userstatus="user's IP" + you4.getInetAddress()
								+ " connected " + port4 + "進行查詢";
						userShow(userstatus);
						
						// 第4個線程啟動
						new Server_userQuery(you4).start();
					}
				}

			}
		};
		td4.start();

		// 啟動一個教師登陸的線程
		Thread td5 = new Thread("five") {

			ServerSocket ss5 = null;

			int port5 = 8005;

			public void run() {
				serstatus="thread 5 start!";
				serShow(serstatus);

				try {
					ss5 = new ServerSocket(port5);
					linkstatus="listener the port:" + port5;
					linkShow(linkstatus);
				} catch (IOException e) {

					e.printStackTrace();
				}
				while (true) {
					Socket you5 = null;

					try {
						you5 = ss5.accept();
					} catch (IOException e) {

						e.printStackTrace();
					}
					if (you5 != null) {
						userstatus="user's IP" + you5.getInetAddress()
								+ " connected " + port5 + "進行查詢";
						userShow(userstatus);
						// 第4個線程啟動
						new Server_techLogin(you5).start();
					}
				}

			}
		};
		td5.start();

		// 啟動一個教師查詢的線程
		Thread td6 = new Thread("five") {

			ServerSocket ss6 = null;

			int port6 = 8006;

			public void run() {
				serstatus="thread 6 start!";
				serShow(serstatus);

				try {
					ss6 = new ServerSocket(port6);
					linkstatus="listener the port:" + port6;
					linkShow(linkstatus);
				} catch (IOException e) {

					e.printStackTrace();
				}
				while (true) {
					Socket you6 = null;

					try {
						you6 = ss6.accept();
					} catch (IOException e) {

						e.printStackTrace();
					}
					if (you6 != null) {
						userstatus="teacher's IP" + you6.getInetAddress()
								+ " connected " + port6 + "進行查詢";
						userShow(userstatus);
						// 第4個線程啟動
						new Server_techQuery(you6).start();
					}
				}

			}
		};
		td6.start();

	}

	public static int getMaxcount() {
		return Maxcount;
	}

	public static void setMaxcount(int maxcount) {
		Maxcount = maxcount;
	}

	
	public static int getCounter() {
		return counter;
	}

	public static void setCounter(int counter) {
		ServerManager.counter = counter;
	}
	
//	public static void main(String s[]) {
//		new ServerManager();
//	
//	}

}