package ymodem;
|
|
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.FileInputStream;
|
import java.io.FileNotFoundException;
|
import java.io.IOException;
|
|
public class YModemUpgradeThread extends Thread {
|
|
private static byte[][] dataBytes; // 数据帧
|
private static byte[] startBytes; // 起始帧
|
private static byte[] endBytes ; // 结束帧
|
private static final long TIMEOUT = 30000; // 超过30秒未回应则退出升级模式
|
private static SerialPort serialPort;
|
|
static int numSend = 0;
|
static boolean SendDataFlag = false;
|
|
|
public static void shengji(SerialPort serialPort1, String filePath1,byte[] byt){
|
SendDataFlag=false;
|
numSend=0;
|
serialPort = serialPort1;
|
SerialPortUtil.sendData(serialPort, byt);
|
ComSendUpdateFile(filePath1);
|
chushihua();
|
}
|
|
// 构造函数，接收串口和文件路径
|
public static void chushihua() {
|
if (versionUpgradeComp.isWrite()) {
|
if (serialPort == null) {
|
return;
|
} else {
|
new YModemUpgradeThread().startThread();
|
}
|
}
|
}
|
|
public void startThread() {
|
Thread t = new Thread(this);
|
t.start();
|
}
|
|
public void run() {
|
try {
|
// 调用升级过程
|
upgtade();
|
} catch (Exception e) {
|
Thread.currentThread().interrupt(); // 恢复中断标志
|
System.out.println("线程被中断，正在退出升级过程...");
|
e.printStackTrace();
|
}
|
}
|
|
//升级固件
|
private void upgtade(){
|
long startTime = System.currentTimeMillis();
|
long l = System.currentTimeMillis() - startTime;
|
boolean b = l< TIMEOUT;
|
while (b&&!SendDataFlag) {
|
b=System.currentTimeMillis()-startTime<TIMEOUT;
|
// 等待回应
|
byte[] response = SerialPortUtil.readData(serialPort);
|
// 如果设备没有回应（回应为空）,则认为是超时
|
if (response == null || response.length == 0) {
|
continue; // 如果没有回应，继续等待
|
}
|
showDataComp.addAreaTextMes(response,"127.0.0.1",9999);
|
if (response[0] == ymodem.ACK) {
|
numSend++;
|
sendData(numSend);
|
} else if (response[0] == ymodem.NAK || response[0] == ymodem.C) {
|
// 收到NAK或CA，退出升级
|
sendData(numSend);
|
}else if (response[0]==ymodem.CA){
|
break;
|
}
|
}
|
if (!b){
|
ShowMessage.zidingyi("数据接收超时,退出升级模式");
|
}
|
versionUpgradeComp.exitUpgrade();
|
}
|
|
|
//发送数据包
|
public static void sendData(int shuJuZhen) {
|
int length = dataBytes.length;
|
if (shuJuZhen == 0) {
|
SerialPortUtil.sendData(serialPort, startBytes);
|
getProgress(shuJuZhen, length);
|
} else if (shuJuZhen <= length && shuJuZhen > 0) {
|
SerialPortUtil.sendData(serialPort, dataBytes[shuJuZhen - 1]);
|
getProgress(shuJuZhen, length);
|
} else if (shuJuZhen == length + 1||shuJuZhen == length + 2) {
|
SerialPortUtil.sendData(serialPort,new byte[]{(byte) ymodem.EOT});
|
getProgress(shuJuZhen, length);
|
} else if (shuJuZhen == length + 3) {
|
SerialPortUtil.sendData(serialPort,endBytes);
|
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 boolean isSendDataFlag() {
|
return SendDataFlag;
|
}
|
|
public static void setSendDataFlag(boolean sendDataFlag) {
|
SendDataFlag = sendDataFlag;
|
}
|
}
|
