package com.lzw;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.Enumeration;
import java.util.Hashtable;
import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

public class Server extends HttpServlet {

	private Hashtable players = new Hashtable();

	private int NUM = 2;

	private int DESKNUM = 10; // 定義桌子數(shù)量

	private Desk[] desks = new Desk[DESKNUM];

	private int counter = 1; // 玩家計(jì)數(shù)器

	private Player player;

	PrintWriter out;

	/*
	 * 初始化 對(duì)players(Hashtable)、desks(所有桌子)初始化
	 */
	public void init(ServletConfig config) throws ServletException { // 初始化
		super.init(config);
		players.clear();
		for (int i = 0; i < DESKNUM; i++) {
			desks[i] = new Desk();
			desks[i].setID(i);
		}
	}

	/*
	 * 接受信息主方法 接受各種信息，然后調(diào)用相應(yīng)的處理方法
	 */
	public void doGet(HttpServletRequest request, HttpServletResponse response) // 接受信息
			throws ServletException, IOException {
		out = response.getWriter();
		String message = request.getParameter("message");
		String port = request.getParameter("port");
		port = port.trim();
		if (!message.startsWith("hello"))
			System.out.println(message);
		if (message.startsWith("register")) {// 登陸信息
			System.out.println("register is start");
			denglu(request);
			return;
		}
		if (!port.equals("-1"))
			player = (Player) players.get(request.getRemoteAddr() + ":" + port);
		else
			player = (Player) players.get(request.getRemoteAddr() + ":"
					+ request.getRemotePort());
		if(player==null)return;
		if (message.startsWith("take")) {// 落座信息
			// System.out.println("take info start:1");
			luozuo(message, player);
			return;
		} else if (message.startsWith("start")) {// 開(kāi)始信息move:
			tryStart(player);
			return;
		} else if (message.startsWith("move")) {// 走棋信息
			Desk desk = player.getDesk();
			desk.moveChess(message);
		} else if (message.startsWith("hello")) {
			if (!player.data.empty())
				out.println((String) player.data.pop());
			else
				out.println("noData");
			return;
		} else if (message.startsWith("exitgame")) {// 退出信息
			tryExit(players, player, request);
			return;
		} else if (message.startsWith("exit")) {// 退出信息
			tryExit(players, player, request);
			return;
		} else {
			System.out.println("No desk exist");
		}
	}

	public void sendMessage(Player p, String str) { // 發(fā)送信息，等待用戶(hù)讀取
		p.data.push(new String(str));
	}

	public void updateClientsDesk(int deskid) { // 更新所有客戶(hù)桌面
		for (Enumeration en = players.elements(); en.hasMoreElements();) {
			Player player = (Player) en.nextElement();
			if (player != null)
				updateDesk(player, deskid);
		}
	}

	public void updateDesk(Player isa, int deskid) { // 更新單個(gè)桌面
		String message = "updatedesk," + deskid;
		String str = "";
		for (int i = 0; i < desks[deskid].getPlayersCounter(); i++) {
			if (i == 0) {
				if (desks[deskid].isEmpty(i))
					str = "0";
				else
					str = "1";
			} else {
				if (desks[deskid].isEmpty(i))
					str = str + ",0";
				else
					str = str + ",1";
			}
		}
		message = message + ":" + str;
		sendMessage(isa, message);
	}

	public void sendDeskList(Player player) { // 獲得桌面列表
		String message = "desks," + DESKNUM;
		for (int i = 0; i < DESKNUM; i++) {
			String str = "";
			for (int j = 0; j < desks[i].getPlayersCounter(); j++) {
				if (j == 0) {
					if (desks[i].isEmpty(j))
						str = "0";
					else
						str = "1";
				} else {
					if (desks[i].isEmpty(j))
						str = str + ",0";
					else
						str = str + ",1";
				}
			}
			message = message + ":" + str;
		}
		sendMessage(player, message);
	}

	public void denglu(HttpServletRequest request) { // 處理登陸信息
		Player player = new Player(request.getRemoteAddr(), request
				.getRemotePort());
		player.setID(counter);

		counter++;
		players.put(request.getRemoteAddr() + ":" + request.getRemotePort(),
				player);

		sendMessage(player, "port=" + request.getRemotePort());
		sendDeskList(player); // 發(fā)送大廳信息
	}

	public void luozuo(String message, Player player) {// 處理落座信息
		try {
			int index1 = message.indexOf(",");
			int index2 = message.indexOf(",", index1 + 1);
			int dindex = Integer
					.parseInt(message.substring(index1 + 1, index2));
			int pindex = Integer.parseInt(message.substring(index2 + 1));
			if (dindex < DESKNUM && dindex >= 0) {
				if (desks[dindex].isEmpty(pindex)) {
					desks[dindex].setPlayer(pindex, player);
					player.setDesk(desks[dindex]);
					sendMessage(player, "takeseat");
					updateClientsDesk(dindex);
				}
			}
		} catch (Exception exc) {
		}
	}

	public void tryStart(Player player) {// 處理開(kāi)始信息
		player.start();
		Desk d1 = player.getDesk();
		if (d1.isReady()) {
			d1.start();
		}
	}

	public void tryExit(Hashtable players, Player player,
			HttpServletRequest request) {
		Desk de = player.getDesk();
		player.init();
		de.removePlayer(player);
		player=null;
		players.remove(request.getRemoteHost() + ":" + request.getRemotePort());
		updateClientsDesk(de.getID());
	}
}