package ymodem;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;
import BaoWen.Dell_55AA01;
import BaoWen.Dell_55AA02;
import BaoWen.Dell_55AA03;
import BaoWen.Dell_55AA0A;
import Frame.AnchorSet;
import PbuliClass.ShowMessage;
import PbuliClass.Systems;
import tbDataModel_Dell.Tools;
public class Update implements Runnable{	
	public static final int SOH = 0X01;		//128×Ö½ÚÊý¾Ý°ü
	public static final int STX = 0X02;		//1024×Ö½ÚÊý¾Ý°ü
	public static final int EOT = 0X04;		//½áÊø´«Êä
	public static final int ACK = 0x06;		//»ØÓ¦
	public static final int NAK = 0X15;		//²»»ØÓ¦
	public static final int CA = 0X18;			//´«ÊäÖÕÖ¹
	public static final int C = 0x43;			//ÇëÇóÊý¾Ý°ü
	static public int num = 0;						//Ö¡ÐòºÅ
	public int mport;							//±¾µØ¶Ë¿Ú
	static public int errorNum = 100;			//´íÎó´ÎÊý
	static boolean update_star=false;
	static byte[] startBytes;//»ñÈ¡Æðʼ֡Êý¾Ý°ü
	static byte[][] dataBytes ;//»ñÈ¡Êý¾ÝÖ¡Êý¾Ý°ü
	static byte[] endBytes ;//½áÊøÖ¡Êý¾Ý°ü
	static String ip;//Ä¿±êÉ豸ipµØÖ·
	static int port;//Ä¿±êÉ豸¶Ë¿Ú
	static  String path;
	static int zusai=0;
	private static DatagramSocket socket;
	static byte[] dat;
	static DatagramPacket packet;
	static String nowip="";
	static int nowport;

	public static void chushihua() {
		if(socket==null) {
			int port=Integer.parseInt(Systems.sys().getBaoliu1());
			try {
				socket =new DatagramSocket(port);	
				new Update().startThread();
			} catch (SocketException e) {
				ShowMessage.zidingyi(port+"¶Ë¿Ú±»Õ¼ÓÃ");
			}
		}
	}



	public static void shengji(String ip1,int port1,String path1,byte[] byt) throws IOException {
		chushihua();
		ip=ip1;
		port=port1;
		fasongdata(byt,ip,port);
		AnchorSet.addmesg("·¢ËÍÉý¼¶ÇëÇó");		
		path=path1;
		UDPSendUpdateFile(ip,port, path);
		AnchorSet.setShengjimoshi(true);
	}

	/**Æô¶¯Ï̵߳ķ½·¨*/
	public void startThread() {
		Thread t=new Thread(this);
		t.start();
	}

	public void run() {
		while(true) {
			if(AnchorSet.isShengjimoshi()) {
				kaishishengji();				
			}else {
				getRecDat();
			}

		}
	}

	public static int getRecDat()  {		
		int a=-1;
		if(!AnchorSet.isShengjimoshi()) {
			dat = new byte[1024];
			packet = new DatagramPacket(dat,1024);
		}else {
			dat = new byte[100];
			packet = new DatagramPacket(dat,100);
		}
		try {
			socket.receive(packet);	
			Dell_55AA01.dell_gui();
			nowip=packet.getAddress().getHostAddress();
			nowport=packet.getPort();
			String ip=AnchorSet .getIschooseip();
			if(ip.equals(nowip)) {	
				int lenth=packet.getLength();
				byte[] adat=subBytes(packet.getData(),0, lenth);		
				String datas=Tools.Bytes2HexString(adat);
				int lenth2=datas.length();				
				dell_message(datas,lenth2);//´¦Àí±¨ÎÄÊý¾Ý
				if(AnchorSet.isShengjimoshi()) {
					a=dat[0] & 0xff;
				}
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
		return a;
	}



	/**Éý¼¶Ä£Ê½½ÓÊÕÊý¾Ý*/
	public static int kaishishengji() {	
		int eNum = 0;
		String ip=AnchorSet .getIschooseip();
		while (getRecDat() != C ) {//½ÓÊÕÇëÇó
			AnchorSet.addmesg("µÈ´ýÖÕ¶ËÏìÓ¦C...");
			return 0;
		}
		//·¢ËÍÆðʼ֡Êý¾Ý°ü
		AnchorSet.addmesg("·¢ËÍÆðʼÊý¾Ýto"+ip+":"+port);
		fasongdata(startBytes,ip,port);	


		while (getRecDat() != ACK) {//½ÓÊÕÏìÓ¦
			if (eNum ++ >= errorNum) {
				AnchorSet.addmesg("Æðʼ֡·¢ËÍʧ°Ü£¡");
				AnchorSet.setShengjimoshi(false);
				return 0;
			}
		}
		eNum = 0;		
		while (getRecDat() != C) {//½ÓÊÕÇëÇó
			if (eNum ++ >= errorNum) {
				AnchorSet.addmesg("δÊÕµ½CÉý¼¶Ê§°Ü");
				AnchorSet.setShengjimoshi(false);
				return 0;
			}
		}

		eNum = 0;
		AnchorSet.addmesg("»ñÈ¡ÇëÇó³É¹¦£¬¿ªÊ¼·¢ËÍÊý¾ÝÖ¡...");
		for (int i = 0; i < dataBytes.length; i++) {
			AnchorSet.addmesg("ÕýÔÚ·¢Ë͵Ú:"+(i+1)+"¸öÊý¾Ý°ü,×ܹ²:"+dataBytes.length+"¸ö  ");
			fasongdata(dataBytes[i],ip,port);
			while (getRecDat() != ACK) {
				if (eNum ++ >= errorNum) {
					AnchorSet.addmesg("Êý¾Ý·¢ËÍʧ°Ü");
					AnchorSet.setShengjimoshi(false);
					return 0;
				}
			}
			eNum = 0;
			AnchorSet.addmesg("Êý¾Ý·¢Ëͳɹ¦");
		}

		eNum = 0;
		fasongdata(new byte[] {(byte)EOT},ip,port);		//µÚÒ»´ÎEOT		
		while (getRecDat() != ACK) {//½ÓÊÕÏìÓ¦					
			if (eNum ++ >= errorNum) {
				AnchorSet.addmesg("µÚÒ»´ÎEOT·´À¡Ê§°Ü£¡");
				AnchorSet.setShengjimoshi(false);
				return 0;
			}
		}

		eNum = 0;
		fasongdata(new byte[] {(byte)EOT},ip,port);	//½ÓÊÕµ½NAK ÔÙ·¢Ò»´ÎµÚ¶þ´ÎEOT
		while (getRecDat() != ACK) {
			if (eNum ++ >= errorNum) {
				AnchorSet.addmesg("µÚ¶þ´ÎEOT·´À¡Ê§°Ü£¡");
				AnchorSet.setShengjimoshi(false);
				return 0;
			}
		}

		eNum = 0;	
		while (getRecDat() != C) {//½ÓÊÕÇëÇó
			if (eNum ++ >= errorNum) {
				AnchorSet.addmesg("δÊÕµ½CÉý¼¶Ê§°Ü");
				AnchorSet.setShengjimoshi(false);
				return 0;
			}
		}
		eNum = 0;
		fasongdata(endBytes,ip,port);
		AnchorSet.setShengjimoshi(false);
		ShowMessage.zidingyi(ip+":"+port+"Éý¼¶³É¹¦");
		AnchorSet.addmesg(ip+":"+port+"Éý¼¶³É¹¦");
		return 1;

	}

	/**½«Êý¾Ý·¢¸ø»ùÕ¾*/
	public static void fasongdata(byte[] data,String ipout,int portout) {		
		DatagramPacket packet=null;	
		InetAddress address=null;
		//Èç¹ûÊý¾ÝÀàÐÍÏàͬ
		try {
			address=InetAddress.getByName(ipout);
		} catch (UnknownHostException e) {
			e.printStackTrace();
		}
		packet=new DatagramPacket(data,data.length, address, portout);

		try {
			socket.send(packet);
//			String datas=Tools.Bytes2HexString(data).substring(0, packet.getLength()*2);
//			AnchorSet.addmesg("·¢:"+datas);
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	public static void dell_message(String datas,int lenth2) {				
		if(!AnchorSet.isShengjimoshi()) {
			if(datas.startsWith("55AA03") && lenth2==202) {
				Dell_55AA03.ok_55AA03_sj(nowip,datas);
			}else if(datas.startsWith("55AA02") && lenth2==32){
				Dell_55AA02.dellrgs(datas,nowip,nowport);
			}else if(datas.startsWith("55AA0A") && lenth2==48) {
				Dell_55AA0A.dell55aa0a(datas, nowip, nowport);
			}
		}
		AnchorSet.addmesg(nowip+":"+nowport+"ÊÕ: "+datas);
	}


	public static boolean isUpdate_star() {
		return update_star;
	}


	public static void setUpdate_star(boolean update_star) {
		Update.update_star = update_star;
	}



	/**
	 * »ñÈ¡Êý¾ÝÖ¡Êý¾Ý
	 * @param file	Îļþ
	 * @return Êý¾ÝÖ¡Êý×é
	 * @throws IOException 
	 */
	public static byte[][] getData(File file) throws IOException{
		long len = file.length();
		int size = (int) Math.ceil(len/1024d);		//»ñÈ¡Êý¾ÝÖ¡¸öÊý
		byte[][] result = new byte[size][1029];			
		FileInputStream fis = new FileInputStream(file);

		for (int i = 0; i < size-1; i++) {			//Éú³ÉÊý¾ÝÖ¡
			result[i][0] = STX;						//1024×Ö½ÚÊý¾Ý°üÍ·
			result[i][1] = (byte)(num ++);			//×Ô¶¯Ìî³äÖ¡ÐòºÅ
			if (num > 255) {						//Ö¡ÐòºÅ×î´ó255
				num = 0;	
			}
			result[i][2] = (byte)~result[i][1];		//È¡·´Ö¡ÐòºÅ
			fis.read(result[i], 3, 1024);
			byte[] crc16 = CRC16.getCRC16(result[i],3);	//»ñÈ¡crc16УÑé
			result[i][result[i].length-2] = crc16[0];
			result[i][result[i].length-1] = crc16[1];	//Ìî³äcrc16УÑé
		}

		int endLen = (int)len % 1024;
		//Èç¹û×îºóÒ»Ö¡²»ÊÇÕû1024¸ö×Ö½Ú
		if (endLen > 0) {
			//Èç¹û×îºóÒ»Ö¡³¤¶ÈСÓÚµÈÓÚ128
			if (endLen <= 128) {
				//×îºóһ֡ʹÓÃ128×Ö½Ú´«Êä
				result[size-1] = new byte[133];
				result[size-1][0] = SOH;						//128×Ö½ÚÊý¾Ý°üÍ·
				int n = fis.read(result[size-1], 3, 128);		//Ìî³ä128¸ö×Ö½ÚÊý¾Ý
				for(int i = n+3;i<131;i++) {					//Ê£ÓàλÌî³ä0x1A
					result[size-1][i] = 0x1A;
				}
			}else{
				//×îºóһ֡ʹÓÃ1024×Ö½Ú´«Êä
				result[size-1][0] = STX;						//1024×Ö½ÚÊý¾Ý°üÍ·

				int n = fis.read(result[size-1], 3, 1024);		//Ìî³ä1024¸öÊý¾Ý
				for(int i = n+3;i<1027;i++) {					//Ê£ÓàλÌî³ä0x1A
					result[size-1][i] = 0x1A;
				}
			}
			result[size-1][1] = (byte)(num ++);				//×Ô¶¯Ìî³äÖ¡ÐòºÅ
			if (num > 255) {								//Ö¡ÐòºÅ×î´ó255
				num = 0;	
			}
			result[size-1][2] = (byte)~result[size-1][1];	//È¡·´Ö¡ÐòºÅ
			byte[] crc16 = CRC16.getCRC16(result[size-1],3);	//»ñÈ¡crc16УÑé
			result[size-1][result[size-1].length-2] = crc16[0];
			result[size-1][result[size-1].length-1] = crc16[1];	//Ìî³äcrc16УÑé
		}
		fis.close();
		return result;
	}

	/**
	 * »ñÈ¡Æðʼ֡Êý¾Ý
	 * @param num Ö¡ÐòºÅ
	 * @param file Òª·¢Ë͵ÄÎļþ
	 * @return
	 */
	public static byte[] getStartData(File file) {
		int index = 0;							//Êý¾Ýϱê
		byte[] dat = new byte[133];
		byte[] nameBytes = file.getName().getBytes();		            //»ñÈ¡ÎļþÃû×Ö½ÚÊý×é
		byte[] lengthBytes = String.valueOf(file.length()).getBytes();  //Îļþ³¤¶È×Ö½ÚÊý×é

		dat[index++] = SOH;						//SOH128×Ö½ÚÊý¾Ý°ü
		dat[index++] = (byte) num++;			//Ö¡ÐòºÅ
		dat[index++] = (byte) ~dat[1];		    //È¡·´ÐòºÅ
		//×éºÏÎļþÃûÊý¾Ý
		for (int i = 0; i < nameBytes.length; i++) {
			dat[i+index] = nameBytes[i];		
		}
		index += nameBytes.length;				
		dat[index++] = 0x00;					//ÎļþÃûºó²¹0x00
		//×éºÏÎļþ³¤¶ÈÊý¾Ý
		for (int i = 0; i < lengthBytes.length; i++) {
			dat[i+index] = lengthBytes[i];		
		}
		index += lengthBytes.length;	
		dat[index++] = 0x00;					//Îļþ³¤¶Èºó²¹0x00

		byte[] crcDat = CRC16.getCRC16(dat,3);	//»ñÈ¡crc16УÑé
		dat[dat.length-2] = crcDat[0];			//Ìî³äcrc16УÑé
		dat[dat.length-1] = crcDat[1];	
		return dat;
	}

	/**
	 * »ñÈ¡½áÊøÖ¡Êý¾Ý
	 * @return
	 */
	public static byte[] getEndData() {
		byte[] dat = new byte[133];
		dat[0] = SOH;
		dat[1] = (byte)0x00;
		dat[2] = (byte)0xFF;
		byte[] crcDat = CRC16.getCRC16(dat,3);	//»ñÈ¡crc16УÑé
		dat[dat.length-2] = crcDat[0];			//Ìî³äcrc16УÑé
		dat[dat.length-1] = crcDat[1];	
		return dat;
	}



	/**
	 * ·¢ËÍÉý¼¶Îļþ
	 * @param ip ¿Í»§¶ËIpµØÖ·
	 * @param port ¿Í»§¶Ë¶Ë¿Ú
	 * @param filePath ÎļþĿ¼
	 * @return 0-ʧ°Ü 1-³É¹¦
	 * @throws IOException IOÒì³£
	 */
	public static void UDPSendUpdateFile(String ip1,int port1,String filePath) throws IOException  {
		ip = ip1;
		port = port1;
		File file = new File(filePath);
		if (!file.exists()) {								//Èç¹ûÎļþ²»´æÔÚ
			ShowMessage.zidingyi("Îļþ²»´æÔÚ"+filePath);		//Å׳öÎļþÕÒ²»µ½Òì³£
			return;
		}
		num = 0;
		startBytes = getStartData(file);				//»ñÈ¡Æðʼ֡Êý¾Ý°ü
		dataBytes = getData(file);					//»ñÈ¡Êý¾ÝÖ¡Êý¾Ý°ü
		endBytes = getEndData();		
	}

	public static byte[] subBytes(byte[] src, int begin, int count) {
		byte[] bs = new byte[count];
		System.arraycopy(src, begin, bs, 0, count);
		return bs;
	}


}