package four;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;

/**
 *监听客户端发送过来的信息
 *
 *发送服务器的信息
 *
 * @author czx
 */
public class VoteThread extends Thread {
	private Socket toClientSocket = null;// 会话套接字
	public BufferedReader in; // 网络输入流
	PrintWriter out; // 网络输出流
	@SuppressWarnings("unused")
	private int clientCounts = 0;// 在线客户机总数

	public VoteThread(Socket toClientSocket, int clientCounts) { // 构造函数
		this.toClientSocket = toClientSocket;
		this.clientCounts = clientCounts;
	}

	@Override
	public void run() {
		try {
			// 创建绑定到套接字toClientSocket上的网络输入流与输出流
			in = new BufferedReader(new InputStreamReader(toClientSocket.getInputStream(), "UTF-8"));
			out = new PrintWriter(new OutputStreamWriter(toClientSocket.getOutputStream(), "UTF-8"), true);
			String recvStr;
			recvStr = in.readLine();
			
			while (recvStr != null) {

				switch (recvStr) {

				case "Info":

					// 发送候选人信息
					out.println(VoteServer.str1);
					out.println(VoteServer.str2);
					out.println(VoteServer.str3);
					out.println(VoteServer.str4);
					out.println(VoteServer.str5);

					// 发送票数信息
					out.println(VoteServer.textField_7.getText());
					out.println(VoteServer.textField_8.getText());
					out.println(VoteServer.textField_9.getText());
					out.println(VoteServer.textField_10.getText());
					out.println(VoteServer.textField_11.getText());
					out.flush();

				case "submit":

					// 接收票数信息
					@SuppressWarnings("unused")
					String str = in.readLine();
					String str1 = in.readLine();
					String str2 = in.readLine();
					String str3 = in.readLine();
					String str4 = in.readLine();
					String str5 = in.readLine();

					VoteServer.textField_7.setText(str1);
					VoteServer.textField_8.setText(str2);
					VoteServer.textField_9.setText(str3);
					VoteServer.textField_10.setText(str4);
					VoteServer.textField_11.setText(str5);

				case "refresh":

					// 发送票数信息
					out.println(VoteServer.textField_7.getText());
					out.println(VoteServer.textField_8.getText());
					out.println(VoteServer.textField_9.getText());
					out.println(VoteServer.textField_10.getText());
					out.println(VoteServer.textField_11.getText());

				default:
					break;
				}
			}
		} catch (IOException ex) {
		} finally {
			try {
				if (toClientSocket != null)
					toClientSocket.close(); // 断开连接
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	} // end run
} // end class