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.SocketException;
/**
 * 發送游戲開始的消息類
 * @author Nightelf暗夜精靈
 *
 */
public class GameStartMsg implements Msg {

	int msgType = Msg.GAME_START_MSG;

	private TankClient tc;

	public GameStartMsg(TankClient tc) {
		this.tc = tc;
	}

	public void send(DatagramSocket ds, String IP, int udpPort) {
        System.out.println("我發送出去一個GameStart的數據！");
        
		ByteArrayOutputStream baos = new ByteArrayOutputStream();
		DataOutputStream dos = new DataOutputStream(baos);
		try {
			dos.writeInt(msgType);
			dos.writeInt(tc.tank.getTankId());
			dos.writeBoolean(tc.tank.isReady());
			byte[] buf = baos.toByteArray();
			DatagramPacket dp = new DatagramPacket(buf, buf.length,
					new InetSocketAddress(IP, udpPort));
			ds.send(dp);
		} catch (Exception e) {
			e.printStackTrace();
		}

	}

	public void parse(DataInputStream dis) {
		
		System.out.println("客戶端接收一份服務端發來GrameStrat的數據！");
		// 如果所有人都準備了，游戲就正式開始了
		int tankId;
		boolean ready;
		try {
			tankId = dis.readInt();
			ready = dis.readBoolean();

			for (int i = 0; i < tc.playerTanks.size(); i++) {
				Tank tank = tc.playerTanks.get(i);
				if (tankId == tank.getTankId()) {
					tank.setReady(ready);
					break;
				}
			}
			
			
			int goodCount = 0,badCount = 0;
			 
			 if(tc.tank.isGood()){
			 goodCount++;
			 }else{
			 badCount++;
			 }
			 
			for (int i = 0; i < tc.playerTanks.size(); i++) {
				Tank tank = tc.playerTanks.get(i);
				if(tank.isGood()){
					goodCount++;
				}else{
					badCount++;
				}
			}
			
			if(goodCount==0 || badCount==0) return;

			if (tc.getReadyer() == tc.playerTanks.size()) {
				tc.setVisible(true);
				tc.join.setVisible(false);
				System.out.println("游戲開始運行了");
                tc.gameStarted=true;
                //取出TankId最小值的當主機
                int min = tc.tank.getTankId();
                for(int i=0; i<tc.playerTanks.size(); i++){
                	Tank pt = (Tank)tc.playerTanks.get(i);
                	if(min<pt.getTankId()){
                		min=pt.getTankId();
                	}
                }
 
                //主機負責發送障礙物給其他客戶端
                if((tc.tank.getTankId()==min && tc.gameStarted)||(tc.tank.getTankId()==min && tc.gameOver)){
                	
            		//讓這個循環在游戲開始或游戲重新開始時的時候只運行一次,創建墻
                	    
            			if(tc.walls.size()==0){
            				tc.createSingleTankandWall();
            			}else{
            				tc.walls.removeAll(tc.walls);
            				tc.createSingleTankandWall();
            			}
            			System.out.println(tc.walls.size());
            			for(int i=0; i<tc.walls.size(); i++){
            				Wall wall = tc.walls.get(i);
            				System.out.println("x:"+wall.x+"  y:"+wall.y+" step"+wall.step+"  life"+wall.life);
            			}
            			Msg msg= new CreateWallsMsg(tc);
        				tc.client.send(msg);
        				System.out.println(tc.walls.size()+"發布createWall包！");
        				tc.setVisible(true);
        				
        				tc.gameOver=false;
                }
			} else {
				int count = tc.getReadyer();
				count++;
				tc.setReadyer(count);
			}
			
			//刷新頁面
			tc.join.repaint();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}

}