import java.io.ByteArrayOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.util.ArrayList;

import javax.swing.JApplet;

/**
 * TankWar2.0坦克大戰(zhàn)服務(wù)器
 * 
 * @author Nighelf暗夜精靈
 * 
 */
public class TankServer extends JApplet {

	public static int TCP_PORT = 8888; // 玩家加入游戲的TCP端口

	public static int TCP_EXIT_PORT = 9999; // 預(yù)留玩家退出的TCP端口

	public static int UDP_PORT = 7777; // UDP端口

	private int tankId = 1000; // 分配坦克的起始ID

	private int msgType = 1000;
	
	static int totalPlayer=8;

	ArrayList<Wall> walls = new ArrayList<Wall>(); // 預(yù)留服務(wù)器創(chuàng)建障礙物的列表

	private ArrayList<Client> clients = new ArrayList<Client>(); // 保存現(xiàn)在玩家信息的List,在線人數(shù)的判斷

	DatagramSocket ds = null;
	
	private ArrayList<Integer> removeTanksId = new ArrayList<Integer>(); //記錄退出玩家的ID，重復(fù)利用ID
	
	ServerSocket exitSer = null;
	Socket s2 = null;

	{
		int wallCount = (int) (Math.random() * 100) + 10;
		for (int i = 0; i < wallCount; i++) {
			int x = (int) (Math.random() * 800 + 40);
			int y = (int) (Math.random() * 600 - 40);
			int style = (int) (Math.random() * 10) % 3;

			// 使程序隨機(jī)到3的機(jī)率小一點(diǎn)，類型3的障礙物是，油桶
			if (style == 3) {
				if ((int) (Math.random() * 10) != 0) {
					style = (int) (Math.random() * 10) % 3;
				}
			}
			walls.add(new Wall(x, y, style, null));
		}
	}

	public TankServer() {
		try {
			ds = new DatagramSocket(UDP_PORT);
			System.out.println("一個(gè)UDP端口" + UDP_PORT + "已啟動(dòng)");
			exitSer = new ServerSocket(TCP_EXIT_PORT);
			System.out.println("第二個(gè)TCP端口啟動(dòng)");
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	/**
	 * 讓TCP服務(wù)器保存新玩家的信息
	 */
	public void start() {
		UDPThread ut = new UDPThread();
		Socket s = null;
		ServerSocket ser = null;
		try {
			ser = new ServerSocket(TCP_PORT);
			while (true) {
				s = ser.accept();
				System.out.println(s.getInetAddress() + "已連接上服務(wù)器！");
				DataInputStream dis = new DataInputStream(s.getInputStream());
				DataOutputStream dos = new DataOutputStream(s.getOutputStream());
				if (clients.size() < totalPlayer) {
					int clientPort = dis.readInt();
					String ip = s.getInetAddress().getHostAddress();
					System.out.println(ip);
					Client client = new Client(ip, clientPort);
					clients.add(client);
					System.out.println("得到一個(gè)客戶端的IP和端口了！");
					//判斷空閑Id有沒有，有的話分配空閑Id
					if(removeTanksId.size()==0){
						
					dos.writeInt(tankId++);
					}
					else{
						System.out.println("加空閑Id這個(gè)的坦克！！");
						int tankId = removeTanksId.get(0);
						dos.writeInt(tankId);
						removeTanksId.remove(0);
					}
					
				} else {
					dos.writeInt(-1);
				}
				
				// 第二個(gè)TCP/IP端口,取消客戶端的用戶信息
				new Tcp2Thread();
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				s.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}

	class Tcp2Thread implements Runnable {

		public Tcp2Thread() {
			new Thread(this).start();
		}

		public void run() {
			
			try {
				while (true) {
					s2 = exitSer.accept();
					System.out.println(s2.getInetAddress() + "第二個(gè)TCP端口得到數(shù)據(jù)");
					DataInputStream dis2 = new DataInputStream(s2
							.getInputStream());
					String exitip = s2.getInetAddress().getHostAddress();
					int exitport = dis2.readInt();
					int tankId = dis2.readInt();
					for (int i = 0; i < clients.size(); i++) {
						Client ec = (Client) clients.get(i);
						System.out.println("exitIP:"+exitip+"IP是否相等："+exitip.equals(ec.getIp()));
						System.out.println("exitport:"+exitport+"port是否相等："+(exitport==ec.getPort()));
						System.out.println("ClientIP:"+ec.getIp()+"port:"+ec.getPort());
						if (exitip.equals(ec.getIp())&&exitport==ec.getPort()) {
							clients.remove(ec);
							removeTanksId.add(tankId);
							System.out.println("空閑ID:"+removeTanksId.size());
							System.out.println(exitip + "的客戶端已刪除！");
							System.out.println("現(xiàn)在的在線人數(shù)有："+clients.size()+"人");
						}
					}
					// 取得某個(gè)客戶端的IP將其刪除
				}
			} catch (Exception e) {
				e.printStackTrace();
			} finally {
				try {
					s2.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}
	}

	/**
	 * 讓服務(wù)器給所有玩家轉(zhuǎn)發(fā)消息
	 */
	class UDPThread implements Runnable {

		DatagramPacket dp;

		public UDPThread() {
			new Thread(this).start();
		}

		public void send() {
			try {
				for (int i = 0; i < clients.size(); i++) {
					Client client = (Client) clients.get(i);

					ByteArrayOutputStream baos = new ByteArrayOutputStream();
					DataOutputStream dos = new DataOutputStream(baos);
					dos.writeInt(msgType);
					dos.writeInt(clients.size());
					for (int j = 0; j < clients.size(); j++) {
						Client c = clients.get(i);
						dos.writeUTF(c.ip);
						dos.writeInt(c.port);
						System.out.println("發(fā)送第" + i + "個(gè)用戶包！！");

						byte[] buf = baos.toByteArray();
						dp.setSocketAddress(new InetSocketAddress(client.ip,
								client.port));
						dp.setPort(client.port);
						ds.send(dp);

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

		public void run() {

			while (true) {
				try {

					if (ds != null) {
						byte[] buf = new byte[1024];
						dp = new DatagramPacket(buf, buf.length);
						ds.receive(dp);
						System.out.println("服務(wù)器接收到一個(gè)UDP數(shù)據(jù)包");
						for (int i = 0; i < clients.size(); i++) {
							Client client = (Client) clients.get(i);
							dp.setSocketAddress(new InetSocketAddress(
									client.ip, client.port));
							dp.setPort(client.port);
							ds.send(dp);
						}
					}
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}

	}

	public static void main(String[] args) {
		new TankServer().start();
	}

}