package ymodem;

import baowen.Dell_udpReceive;
import gnu.io.SerialPort;
import index.JPanelMoudle.showDataComp;
import index.JPanelMoudle.versionUpgradeComp;
import tools.ChuanKou.SerialPortUtil;
import tools.ShowMessage;
import tools.Tools;

import java.io.File;
import java.io.IOException;
import java.net.*;

public class netWorkUpgradeThread extends Thread {


    private static byte[][] dataBytes; // 数据帧
    private static byte[] startBytes; // 起始帧
    private static byte[] endBytes ; // 结束帧

    private static final long TIMEOUT = 600000; // 超过30秒未回应则退出升级模式
    static int numSend = 0;
    static boolean SendDataFlag = false;
    static String ip = "";//目标设备ip地址
    static int port;//目标设备端口
    static DatagramSocket socket;
    static int bytlenth=1024;
    static DatagramPacket packet;


    public static void shengji(String ip1,int port1, String filePath1,byte[] byt,int nowPort){
        SendDataFlag=false;
        numSend=0;
        ip = ip1;
        port = port1;
        Dell_udpReceive.sendData(byt,ip,port);
        ComSendUpdateFile(filePath1);
        Dell_udpReceive.stopThread();//暂停解析线程
        chushihua(nowPort);

        new Dell_udpReceive(nowPort);//重新开始解析线程
    }
    
    // 构造函数，接收串口和文件路径
    public static void chushihua(int nowPort) {
        if (versionUpgradeComp.isWrite()) {
          if (socket==null){
              try {
                  socket = new DatagramSocket(nowPort);//创建socket
                  byte[] data = new byte[bytlenth]; // 创建byte数组
                  packet= new DatagramPacket(data,bytlenth);
                  new netWorkUpgradeThread().startThread();
              } catch (SocketException e) {
                  throw new RuntimeException(e);
              }
          }else {
              new netWorkUpgradeThread().startThread();
          }
        }
    }

    public void startThread() {
        Thread t = new Thread(this);
        t.start();
    }

    public void run() {
        try {
            // 调用升级过程
            upgtade();
            stopThread();
        } catch (Exception e) {
            Thread.currentThread().interrupt(); // 恢复中断标志
            System.out.println("线程被中断，正在退出升级过程...");
            e.printStackTrace();
        }
    }

    //升级固件
    private void upgtade(){
        long startTime = System.currentTimeMillis();
        boolean b = System.currentTimeMillis() - startTime < TIMEOUT;
        while (b&&!SendDataFlag) {
            // 等待回应
            byte[] recDat = getRecDat();
            // 如果设备没有回应（回应为空）,则认为是超时
            if (recDat == null || recDat.length == 0) {
                continue;
            }

            showDataComp.addAreaTextMes(recDat,ip,port);
            if (recDat[0] == ymodem.ACK) {
                numSend++;
                sendData(numSend);
            } else if (recDat[0] == ymodem.NAK || recDat[0] == ymodem.C) {
                // 收到NAK或CA，退出升级
                sendData(numSend);
            }else if (recDat[0]==ymodem.CA){
                break;
            }
        }
        versionUpgradeComp.exitUpgrade();
    }


    //发送数据包
    public static void sendData(int shuJuZhen) {
        int length = dataBytes.length;
        if (shuJuZhen == 0) {
            sendData(startBytes,ip,port);
            getProgress(shuJuZhen, length);
        } else if (shuJuZhen <= length && shuJuZhen > 0) {
            sendData(dataBytes[shuJuZhen - 1],ip,port);
            getProgress(shuJuZhen, length);
        } else if (shuJuZhen == length + 1||shuJuZhen == length + 2) {
            sendData(new byte[]{(byte) ymodem.EOT},ip,port);
            getProgress(shuJuZhen, length);
        } else if (shuJuZhen == length + 3) {
            sendData(endBytes,ip,port);
            getProgress(shuJuZhen, length);
            ShowMessage.zidingyi("升级完成");
            SendDataFlag=true;
            numSend = 0;
        }
    }

    //计算当前包的进度
    private static void getProgress(double shuJuZhen, int length) {
        int i =(int) Math.round((shuJuZhen / (length +3)) * 100);
        versionUpgradeComp.getJindu_SaoMiaoQi().setValue(i);
    }

    //获取要发送的帧数据
    public static void ComSendUpdateFile(String filePath){
        try {
            File file = new File(filePath);
            if (!file.exists()) {                                //如果文件不存在
                ShowMessage.zidingyi("文件不存在" + filePath);        //抛出文件找不到异常
                return;
            }
            getFilesDataBytes.setNum(0);
            startBytes = getFilesDataBytes.getStartData(file);//获取起始帧数据包
            dataBytes = getFilesDataBytes.getData(file);//获取数据帧数据包
            endBytes = getFilesDataBytes.getEndData();//获取结束帧数据包
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }

    public static byte[] getRecDat()  {
        byte[] dat = new byte[0];
        try {
            dat = null;
            packet = new DatagramPacket(dat,100);
            socket.receive(packet);
            String hostAddress = packet.getAddress().getHostAddress();
            if (hostAddress.equals(ip)){
                int lenth=packet.getLength();
                dat=subBytes(packet.getData(),0, lenth);
            }
            return dat;
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }


        /**将数据发给网关*/
    public static void sendData(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);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

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




    public static void stopThread() {
        if (socket != null && !socket.isClosed()) {
            socket.close();//关闭socket对象
        }
    }
}