package com.dev.fbs9600_mon;
|
import gnu.io.SerialPort;
|
|
import java.awt.Toolkit;
|
import java.io.InputStream;
|
import java.io.OutputStream;
|
import java.nio.ByteBuffer;
|
import java.nio.ByteOrder;
|
import java.util.Date;
|
import java.util.zip.CRC32;
|
|
import javax.swing.JOptionPane;
|
import javax.swing.JTextArea;
|
import javax.swing.JTextField;
|
|
import org.apache.logging.log4j.Logger;
|
|
import sp_comm.CommSerialPort;
|
import sp_comm.SP_COMM;
|
import main.page_debug_inf;
|
|
import com.Com;
|
import com.Crc16;
|
import com.PlaySound;
|
import com.app.reg.RegistCoade;
|
|
public class SPCommMon implements Runnable/*, SerialPortEventListener*/ {
|
public static final int COMM_PORT_TYPE_Serial = 0;
|
public static final int COMM_PORT_TYPE_Socket = 1;
|
|
public static final short CMD_TYPE_READ = 0x03;
|
public static final short CMD_TYPE_WRITE = 0x05;
|
|
public static final short UART_MonVolSetAddr_RegAddr = 0x000B;
|
public static final short UART_MonVol1AdjSlope_RegAddr = 0x000C;
|
public static final short UART_MonTmp1AdjSlope_RegAddr = 0x000D;
|
public static final short UART_MonVol1AdjOffset_RegAddr = 0x000E;
|
public static final short UART_MonVol1AdjReset_RegAddr = 0x000F;
|
public static final short UART_MonVol2AdjSlope_RegAddr = 0x00010;
|
public static final short UART_MonTmp2AdjSlope_RegAddr = 0x00011;
|
public static final short UART_MonVol2AdjOffset_RegAddr = 0x0012;
|
public static final short UART_MonVol2AdjReset_RegAddr = 0x0013;
|
|
public static final short UART_CurrAddrSet_RegAddr = 0x1010;
|
public static final short UART_CurrRangeSet_RegAddr = 0x1011;
|
public static final short UART_CurrOffset_RegAddr = 0x1012;
|
public static final short UART_SetCurrSlope_RegAddr = 0x1013;
|
public static final short UART_CurrTestStart_RegAddr = 0x1014;
|
public static final short UART_CurrFloat_Offset_RegAddr = 0x1016; //ÇåÁ㸡³äµçÁ÷Áãµã
|
public static final short UART_SetCurrFloat_Slope_RegAddr = 0x1017; //У׼¸¡³äµçÁ÷бÂÊ
|
|
public static final short UART_MonomerSetJunHengVol_RegAddr = 0x0008;
|
public static final short UART_MonomerClrTmpAddr_RegAddr = 0x0009;
|
public static final short UART_MonomerLowSign_RegAddr = 0x000A;
|
public static final short UART_MonomerSetAddr_RegAddr = 0x000B;
|
public static final short UART_MonomerResTest_RegAddr = 0x000C;
|
public static final short UART_MonomerAdjVol_RegAddr = 0x000D;
|
public static final short UART_MonomerAdjTemp_RegAddr = 0x000E;
|
public static final short UART_MonomerAdjRes_RegAddr = 0x000F;
|
public static final short UART_MonomerAdjOffSet_RegAddr = 0x0010; //Æ«ÒÆÁ¿
|
public static final short UART_MonomerAdjReset_RegAddr = 0x0011; //¸´Î»
|
public static final short UART_MonomerDFU_RegAddr = 0x0012; //Æô¶¯dfu
|
|
public static final byte CMD_FBS9100_WriteDFU = (byte) 0x86;
|
public static final byte CMD_FBS9100_ReadDFU = (byte) 0x87;
|
|
public static final byte BOOTLOADER_CMD_QUIT = 0;
|
public static final byte BOOTLOADER_CMD_GETINF = 1;
|
public static final byte BOOTLOADER_CMD_WRITE = 2;
|
public static final byte BOOTLOADER_CMD_READ = 3;
|
|
public static final int DEV_TYPE_MON_SAMD09 = 0;
|
public static final int DEV_TYPE_MON_MSP430 = 1;
|
public static final int DEV_TYPE_MON_MSP430_RF = 2;
|
public static final int DEV_TYPE_MON_SWM = 3; //»ªÐ¾ÍþÌØmcu
|
public static final int DEV_TYPE_Curr = 100;
|
public static final int DEV_TYPE_GroupVol = 110;
|
public static final int DEV_TYPE_FCF651GroupVol = 111;
|
public static final int DEV_TYPE_NTM = 120;
|
public static final int DEV_TYPE_BYBB = 130;
|
|
public int m_DEV_TYPE = DEV_TYPE_FCF651GroupVol;
|
|
private SP_COMM m_COMM = null;
|
private SPCommMon_DFU m_SPCommDFU = null;
|
|
// ÊäÈëÊä³öÁ÷
|
public InputStream inputStream;
|
public OutputStream outputStream;
|
// RS-232µÄ´®ÐпÚ
|
public SerialPort serialPort;
|
|
public boolean CommThreadRunning = false;
|
private ByteBuffer CommRxBuffer = ByteBuffer.allocate(512);
|
private ByteBuffer CommTxBuffer = ByteBuffer.allocate(512);
|
|
public int comm_tx_cnt = 0;
|
public int comm_rx_cnt = 0;
|
|
public short comm_OK_cnt = 0;
|
public short comm_Err_cnt = 0;
|
public boolean dt_new_tag = false;
|
|
private int comm_bautrate = 9600;
|
public int dt_target_addr = 0;
|
public short dt_dfu_addr_start = 0;
|
public short dt_dfu_addr_end = 0;
|
public short dt_addr = 0;
|
public short dt_junhengcurr = 0;
|
public short dt_vol = 0;
|
public short dt_tmp = 0;
|
public short dt_abn_curr = 0;
|
public int dt_res = 0;
|
public int dt_res_conn = 0;
|
public short dt_louye = 0;
|
public short dt_version = 0;
|
public short dt_voltype = -1;
|
public int dt_rescurr = 0;
|
public int dt_res_asyscode = 0;
|
public int dt_lockpage_count = 0;
|
public int dt_ssb = 0;
|
public short mAddrSettedNow = 0;
|
public int mBianHao_TestRes = -1;
|
public boolean mBianHaoPIN_Low = false;
|
|
//----------------------------------------------------------//
|
public short dt_curr = 0;
|
public short dt_curr_dir = 0;
|
public short dt_curr_float = 0;
|
public short dt_curr_float_dir = 0;
|
public short dt_peakavg_curr = 0;
|
public int dt_peak_curr = 0;
|
public int dt_currrange = 0;
|
public int dt_curr_slope = 0;
|
public int dt_curr_float_slope = 0;
|
//----------------------------------------------------------//
|
public short dt_vol_1 = 0;
|
public short dt_tmp_1 = 0;
|
public short dt_vol_2 = 0;
|
public short dt_tmp_2 = 0;
|
//----------------------------------------------------------//
|
|
private short dt_cmd = CMD_TYPE_READ;
|
private short dt_cmd_regaddr = 0;
|
private short dt_cmd_regcnt = 0;
|
private short dt_cmd_data = 0;
|
private short dt_cmd_data1 = 0;
|
private boolean dt_cmd_guangbo = false;
|
|
private boolean dt_normal_comm_en = true;
|
public boolean dt_update_en = false;
|
private String dt_update_file = "";
|
private int dt_dfu_bitrate = 9600;
|
boolean dt_dfu_read_check_en = false;
|
public JTextArea dt_show_dfu_inf = null;
|
public String dt_set_addr_res_inf = "";
|
public char[] dt_dfu_pwd = new char[6];
|
public Date dt_app_start_time = new Date();
|
public char[] dt_dfu_pwd_auto = new char[6];
|
private String dt_dfu_pwd_sn = "";
|
int dt_multy_comm_type = CommSerialPort.mutycomm_Type_Samd09;
|
|
private JTextField addr_TextField = null;
|
|
private boolean cmd_Null_En = false;
|
|
private page_debug_inf dt_debug_inf;
|
private int m_COMM_PORT_TYPE = 0;
|
|
private Logger m_Log = null;
|
|
public SPCommMon(int addr_t, int bitrate, int dev_type, int multy_com_type,
|
JTextArea show_dfu_inf, page_debug_inf debug, Logger log) {
|
dt_target_addr = addr_t & 0xFFFF;
|
comm_bautrate = bitrate;
|
dt_multy_comm_type = multy_com_type;
|
dt_show_dfu_inf = show_dfu_inf;
|
dt_debug_inf = debug;
|
//-------------------------------------------------------------//
|
m_DEV_TYPE = dev_type;
|
//-------------------------------------------------------------//
|
dt_dfu_pwd_sn = RegistCoade.getRegistSerialCoade("amtb_amtb_amtb", "37373737");
|
CRC32 crc = new CRC32();
|
crc.update((dt_dfu_pwd_sn + "ÄÏÎÞ°¢ÃÖÍÓ·ð").getBytes());
|
char[] tmp_char = String.format("%06d", Math.abs(crc.getValue())%1000000).toCharArray();
|
for(int n=0; n<dt_dfu_pwd_auto.length; n++) {
|
dt_dfu_pwd_auto[n] = tmp_char[n];
|
}
|
//-------------------------------------------------------------//
|
dt_show_dfu_inf.setText(dt_dfu_pwd_sn);
|
m_Log = log;
|
}
|
|
public SPCommMon(JTextField addr_t, int bitrate, int dev_type, int multy_com,
|
JTextArea show_area, page_debug_inf debug, Logger log) {
|
//dt_target_addr = addr_t & 0xFFFF;
|
addr_TextField = addr_t;
|
comm_bautrate = bitrate;
|
dt_multy_comm_type = multy_com;
|
dt_show_dfu_inf = show_area;
|
dt_debug_inf = debug;
|
//-------------------------------------------------------------//
|
m_DEV_TYPE = dev_type;
|
//-------------------------------------------------------------//
|
dt_dfu_pwd_sn = RegistCoade.getRegistSerialCoade("amtb_amtb_amtb", "37373737");
|
CRC32 crc = new CRC32();
|
crc.update((dt_dfu_pwd_sn + "ÄÏÎÞ°¢ÃÖÍÓ·ð").getBytes());
|
char[] tmp_char = String.format("%06d", Math.abs(crc.getValue())%1000000).toCharArray();
|
for(int n=0; n<dt_dfu_pwd_auto.length; n++) {
|
dt_dfu_pwd_auto[n] = tmp_char[n];
|
}
|
//-------------------------------------------------------------//
|
dt_show_dfu_inf.setText(dt_dfu_pwd_sn);
|
m_Log = log;
|
}
|
|
public void setCmdNullEn(boolean en_st) {
|
cmd_Null_En = en_st;
|
}
|
|
public void setCommAddr(int addr_t) {
|
dt_target_addr = addr_t & 0xFFFF;
|
}
|
|
public void setDfuCommAddr(int addr_start_t, int addr_end_t) {
|
dt_dfu_addr_start = (short) (addr_start_t & 0xFFFF);
|
setCommAddr(dt_dfu_addr_start);
|
dt_dfu_addr_end = (short) (addr_end_t & 0xFFFF);
|
}
|
|
public void setCommBautrate(int bt_rate) {
|
if(COMM_PORT_TYPE_Serial != m_COMM_PORT_TYPE) {
|
return;
|
}
|
|
//comm_bautrate = bt_rate;
|
//System.out.println("setCommBautrate:" + bt_rate);
|
m_COMM.m_SP_Comm.setCommBautrate(bt_rate);// .serialPort.setSerialPortParams(bt_rate, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
|
}
|
|
public String getBianHaoTest_Str() {
|
String str = "δ²âÊÔ";
|
|
if(1 == mBianHao_TestRes) {
|
str = "ÀµÍ¹ÊÕÏ";
|
} else if(2 == mBianHao_TestRes) {
|
str = "À¸ß¹ÊÕÏ";
|
} if(0 == mBianHao_TestRes) {
|
str = "²âÊÔÕý³£";
|
}
|
|
return str;
|
}
|
|
//³õʼ»¯´®¿Ú
|
public boolean OpenCommPort(int comm_port_type, String comm_name_or_ip, int bitrate_or_comm_port) {
|
m_COMM = new SP_COMM(comm_port_type, 12345, m_Log);
|
boolean res = m_COMM.openCommPort(comm_name_or_ip, bitrate_or_comm_port);
|
if(true == res) {
|
CommTxBuffer.order(ByteOrder.BIG_ENDIAN);
|
CommRxBuffer.order(ByteOrder.BIG_ENDIAN);
|
|
comm_tx_cnt = 0;
|
comm_rx_cnt = 0;
|
CommThreadRunning = true;
|
}
|
/*
|
boolean res = false;
|
m_COMM_PORT_TYPE = comm_port_type;
|
if(COMM_PORT_TYPE_Serial == m_COMM_PORT_TYPE) {
|
m_SP_Comm = new CommSerialPort(bitrate_or_comm_port, m_Log);
|
res = m_SP_Comm.OpenCommPort(comm_name_or_ip);
|
} else {
|
m_SocketComm = new Comm_Socket(comm_name_or_ip, bitrate_or_comm_port);
|
res = true;
|
}
|
*/
|
if(true == res) {
|
CommTxBuffer.order(ByteOrder.BIG_ENDIAN);
|
CommRxBuffer.order(ByteOrder.BIG_ENDIAN);
|
comm_tx_cnt = 0;
|
comm_rx_cnt = 0;
|
CommThreadRunning = true;
|
}
|
|
return res;
|
}
|
|
private void makeCommTxData() {
|
CommTxBuffer.clear();
|
|
if(null != addr_TextField) {
|
dt_target_addr = (short) Integer.parseInt(addr_TextField.getText()) & 0xFFFF;
|
}
|
|
if(CMD_TYPE_READ == dt_cmd) {
|
CommTxBuffer.put((byte) dt_target_addr);
|
CommTxBuffer.put((byte) 0x03);
|
CommTxBuffer.put((byte) 0x00);
|
CommTxBuffer.put((byte) 0x00);
|
CommTxBuffer.put((byte) 0x00);
|
CommTxBuffer.put((byte) 0x16);
|
} else {
|
byte addr_tmp = (byte) dt_target_addr;
|
if(true == dt_cmd_guangbo) {
|
addr_tmp = (byte) 255;
|
}
|
CommTxBuffer.put(addr_tmp);
|
CommTxBuffer.put((byte) 0x05);
|
CommTxBuffer.put((byte) (dt_cmd_regaddr>>8));
|
CommTxBuffer.put((byte) dt_cmd_regaddr);
|
CommTxBuffer.put((byte) (dt_cmd_regcnt>>8));
|
CommTxBuffer.put((byte) dt_cmd_regcnt);
|
CommTxBuffer.put((byte) (dt_cmd_data>>8));
|
CommTxBuffer.put((byte) dt_cmd_data);
|
CommTxBuffer.put((byte) (dt_cmd_data1>>8));
|
CommTxBuffer.put((byte) dt_cmd_data1);
|
dt_cmd = CMD_TYPE_READ;
|
dt_cmd_guangbo = false;
|
}
|
|
int crc = Crc16.CalCRC16(CommTxBuffer, CommTxBuffer.position()) & 0xFFFF;
|
CommTxBuffer.putShort((short) (crc>>8 | crc<<8));
|
CommTxBuffer.flip();
|
}
|
|
private void makeVolModule_CommTxData() {
|
CommTxBuffer.clear();
|
|
if(null != addr_TextField) {
|
dt_target_addr = (short) Integer.parseInt(addr_TextField.getText()) & 0xFFFF;
|
}
|
|
if(CMD_TYPE_READ == dt_cmd) {
|
CommTxBuffer.put((byte) dt_target_addr);
|
CommTxBuffer.put((byte) 0x03);
|
CommTxBuffer.put((byte) 0x00);
|
CommTxBuffer.put((byte) 0x00);
|
CommTxBuffer.put((byte) 0x00);
|
CommTxBuffer.put((byte) 0x09);
|
} else {
|
CommTxBuffer.put((byte) dt_target_addr);
|
CommTxBuffer.put((byte) 0x05);
|
CommTxBuffer.put((byte) (dt_cmd_regaddr>>8));
|
CommTxBuffer.put((byte) dt_cmd_regaddr);
|
CommTxBuffer.put((byte) (dt_cmd_regcnt>>8));
|
CommTxBuffer.put((byte) dt_cmd_regcnt);
|
CommTxBuffer.put((byte) (dt_cmd_data>>8));
|
CommTxBuffer.put((byte) dt_cmd_data);
|
dt_cmd = CMD_TYPE_READ;
|
}
|
|
int crc = Crc16.CalCRC16(CommTxBuffer, CommTxBuffer.position()) & 0xFFFF;
|
CommTxBuffer.putShort((short) (crc>>8 | crc<<8));
|
CommTxBuffer.flip();
|
}
|
|
private void makeCurrModule_CommTxData() {
|
CommTxBuffer.clear();
|
|
if(null != addr_TextField) {
|
dt_target_addr = (short) Integer.parseInt(addr_TextField.getText()) & 0xFFFF;
|
}
|
|
if(CMD_TYPE_READ == dt_cmd) {
|
CommTxBuffer.put((byte) dt_target_addr);
|
CommTxBuffer.put((byte) 0x03);
|
CommTxBuffer.put((byte) 0x10);
|
CommTxBuffer.put((byte) 0x00);
|
CommTxBuffer.put((byte) 0x00);
|
if(dt_version < 20) {
|
CommTxBuffer.put((byte) 8);
|
} else {
|
CommTxBuffer.put((byte) 11);
|
}
|
} else {
|
CommTxBuffer.put((byte) dt_target_addr);
|
CommTxBuffer.put((byte) 0x05);
|
CommTxBuffer.put((byte) (dt_cmd_regaddr>>8));
|
CommTxBuffer.put((byte) dt_cmd_regaddr);
|
CommTxBuffer.put((byte) (dt_cmd_regcnt>>8));
|
CommTxBuffer.put((byte) dt_cmd_regcnt);
|
CommTxBuffer.put((byte) (dt_cmd_data>>8));
|
CommTxBuffer.put((byte) dt_cmd_data);
|
dt_cmd = CMD_TYPE_READ;
|
}
|
|
int crc = Crc16.CalCRC16(CommTxBuffer, CommTxBuffer.position()) & 0xFFFF;
|
CommTxBuffer.putShort((short) (crc>>8 | crc<<8));
|
CommTxBuffer.flip();
|
}
|
|
private void makeCommTxDataNull() {
|
CommTxBuffer.clear();
|
CommTxBuffer.put((byte) 0xFF);
|
CommTxBuffer.put((byte) 0x00);
|
CommTxBuffer.put((byte) (0));
|
CommTxBuffer.put((byte) 0);
|
CommTxBuffer.put((byte) (0));
|
CommTxBuffer.put((byte) 0);
|
CommTxBuffer.put((byte) 0);
|
CommTxBuffer.put((byte) 0);
|
|
int crc = Crc16.CalCRC16(CommTxBuffer, CommTxBuffer.position()) & 0xFFFF;
|
CommTxBuffer.putShort((short) (crc>>8 | crc<<8));
|
CommTxBuffer.flip();
|
}
|
|
private boolean checkCommBuf(ByteBuffer buf_t) {
|
boolean res = false;
|
if(buf_t.limit() >= 5) {
|
buf_t.position(buf_t.limit()-2);
|
int crc = buf_t.getShort() & 0xFFFF;
|
crc = ((crc>>8) | (crc<<8)) & 0xFFFF;
|
int crc_cal = Crc16.CalCRC16(buf_t, buf_t.limit()-2) & 0xFFFF;
|
/*************************************************/
|
if(crc_cal == crc) {
|
res = true;
|
}
|
/*************************************************/
|
} else {
|
res = false;
|
}
|
|
return res;
|
}
|
|
public void tr_Msg(ByteBuffer bbf_tx, ByteBuffer bbf_rx, boolean showdat) {
|
if(++comm_tx_cnt > 32500) {
|
comm_tx_cnt = 0;
|
}
|
m_COMM.tr_Msg(bbf_tx, bbf_rx, dt_multy_comm_type, dt_debug_inf, showdat);
|
/*
|
if(COMM_PORT_TYPE_Serial == m_COMM_PORT_TYPE) {
|
m_COMM.m_SP_Comm.SP_Comm(bbf_tx, bbf_rx, dt_multy_comm, dt_debug_inf, showdat);
|
} else {
|
m_SocketComm.SocketComm(bbf_tx, bbf_rx, dt_debug_inf, showdat);
|
}
|
*/
|
}
|
|
private void closeCommPort() {
|
m_COMM.closeCommPort();
|
/*
|
if(COMM_PORT_TYPE_Serial == m_COMM_PORT_TYPE) {
|
m_SP_Comm.serialPort.close();
|
} else {
|
m_SocketComm.socketClose();
|
}
|
*/
|
}
|
|
public void exitCommPortThread() {
|
CommThreadRunning = false;
|
setUpdateCmd(false, false, "", comm_bautrate);
|
}
|
|
public void setCommCmd(short cmd, short cmd_reg_addr, short cmd_reg_cnt,
|
short cmd_data, short cmd_data1) {
|
dt_cmd = cmd;
|
dt_cmd_regaddr = cmd_reg_addr;
|
dt_cmd_regcnt = cmd_reg_cnt;
|
dt_cmd_data = cmd_data;
|
dt_cmd_data1 = cmd_data1;
|
|
if(UART_MonomerLowSign_RegAddr == dt_cmd_regaddr) {
|
mBianHao_TestRes = -1;
|
}
|
}
|
public void setCommCmd_gb(short cmd, short cmd_reg_addr, short cmd_reg_cnt,
|
short cmd_data, short cmd_data1, boolean guangbo_t) {
|
dt_cmd = cmd;
|
dt_cmd_regaddr = cmd_reg_addr;
|
dt_cmd_regcnt = cmd_reg_cnt;
|
dt_cmd_data = cmd_data;
|
dt_cmd_data1 = cmd_data1;
|
|
dt_cmd_guangbo = guangbo_t;
|
|
if(UART_MonomerLowSign_RegAddr == dt_cmd_regaddr) {
|
mBianHao_TestRes = -1;
|
}
|
}
|
|
public void clearResDataBuf() {
|
dt_res = -1;
|
dt_rescurr = -1;
|
dt_res_asyscode = -1;
|
}
|
|
public void setUpdateCmd(boolean update_en, boolean read_ckeck_en, String filepath, int dfu_bitrate) {
|
dt_update_en = update_en;
|
dt_dfu_read_check_en = read_ckeck_en;
|
dt_update_file = filepath;
|
dt_dfu_bitrate = dfu_bitrate;
|
|
if(false == dt_update_en) {
|
if(null != m_SPCommDFU) {
|
m_SPCommDFU.setDFUCommState(false, false);
|
}
|
}
|
}
|
|
public void setNormalCommState(boolean stat) {
|
dt_normal_comm_en = stat;
|
}
|
|
private void processRxData(ByteBuffer bbf_rx, boolean check_en) {
|
if(false == checkCommBuf(bbf_rx)) {
|
if(true == check_en) {
|
comm_OK_cnt = 0;
|
}
|
|
if((comm_OK_cnt<1) && (0==dt_res)) {
|
dt_new_tag = false;
|
}
|
|
return;
|
}
|
|
if(bbf_rx.limit() > 16) {
|
bbf_rx.position(0);
|
dt_addr = bbf_rx.get();
|
bbf_rx.get();
|
bbf_rx.get();
|
int tmp_val = bbf_rx.getShort()&0xFFFF;
|
if((tmp_val & 0x8000) > 0) {
|
dt_junhengcurr = (short) ((short)(tmp_val&(~0x8000)) * (-1));
|
} else {
|
dt_junhengcurr = (short)(tmp_val);
|
}
|
dt_vol = bbf_rx.getShort();
|
dt_tmp = bbf_rx.getShort();
|
dt_abn_curr = bbf_rx.getShort();
|
dt_res = (int) (bbf_rx.getShort()&0xFFFF);
|
dt_addr = bbf_rx.getShort();
|
dt_version = bbf_rx.getShort();
|
//dt_voltype = bbf_rx.getShort();
|
|
short vol_type = bbf_rx.getShort();
|
mBianHaoPIN_Low = ((vol_type&(1<<8)) > 0);
|
dt_voltype = (short) (vol_type & 0x7F);
|
|
dt_rescurr = (int)(bbf_rx.getShort()&0xFFFF);
|
if(bbf_rx.hasRemaining()) {
|
dt_res_asyscode = (int)(bbf_rx.getShort()&0xFFFF);
|
}
|
if(bbf_rx.hasRemaining()) {
|
if(dt_version > 1000) {
|
dt_louye = (short) (bbf_rx.getShort()&0xFFFF);
|
dt_res_conn = (int) (bbf_rx.getShort()&0xFFFF);
|
}
|
}
|
if(bbf_rx.hasRemaining()) {
|
if(DEV_TYPE_MON_SWM == m_DEV_TYPE) {
|
dt_lockpage_count = (int)(bbf_rx.getShort());
|
} else {
|
dt_lockpage_count = (int)(bbf_rx.getShort()&0xFFFF);
|
}
|
}
|
if(bbf_rx.hasRemaining()) {
|
dt_ssb = (int)(bbf_rx.getShort()&0xFFFF);
|
}
|
|
if(++comm_rx_cnt > 32500) {
|
comm_rx_cnt = 0;
|
}
|
if(comm_OK_cnt < 1000) {
|
comm_OK_cnt += 1;
|
}
|
|
if((comm_OK_cnt > 3) && (comm_OK_cnt < 5)) {
|
if(0 == dt_res) {
|
dt_new_tag = true;
|
mBianHao_TestRes = -1;
|
} else {
|
dt_new_tag = false;
|
}
|
}
|
}
|
}
|
|
private void processVolModule_RxData(ByteBuffer bbf_rx) {
|
if(false == checkCommBuf(bbf_rx)) {
|
return;
|
}
|
|
if(bbf_rx.limit() >= 17) {
|
bbf_rx.position(0);
|
dt_addr = bbf_rx.get();
|
bbf_rx.get();//cmd
|
bbf_rx.get();//bytes
|
dt_vol_1 = bbf_rx.getShort();
|
dt_tmp_1 = bbf_rx.getShort();
|
dt_vol_2 = bbf_rx.getShort();
|
dt_tmp_2 = bbf_rx.getShort();
|
|
bbf_rx.getShort();
|
dt_version = bbf_rx.getShort();
|
dt_voltype = bbf_rx.getShort();
|
dt_lockpage_count = bbf_rx.getShort();
|
dt_ssb = bbf_rx.getShort();
|
|
if(++comm_rx_cnt > 32500) {
|
comm_rx_cnt = 0;
|
}
|
if(comm_OK_cnt < 1000) {
|
comm_OK_cnt += 1;
|
}
|
}
|
}
|
|
private void processCurrModule_RxData(ByteBuffer bbf_rx) {
|
if(false == checkCommBuf(bbf_rx)) {
|
return;
|
}
|
|
if(bbf_rx.limit() >= 17) {
|
bbf_rx.position(0);
|
dt_addr = bbf_rx.get();
|
bbf_rx.get();//cmd
|
bbf_rx.get();//bytes
|
short ver = bbf_rx.getShort();
|
bbf_rx.getShort();
|
dt_curr = bbf_rx.getShort();
|
dt_curr_dir = bbf_rx.getShort();
|
dt_peakavg_curr = bbf_rx.getShort();
|
dt_peak_curr = bbf_rx.getShort();
|
dt_currrange = bbf_rx.getShort();
|
dt_curr_slope = bbf_rx.getShort();
|
if((dt_version >= 20) && (bbf_rx.remaining()>=6)) {
|
dt_curr_float = bbf_rx.getShort();
|
dt_curr_float_dir = bbf_rx.getShort();
|
dt_curr_float_slope = bbf_rx.getShort();
|
}
|
dt_version = ver;
|
|
if(++comm_rx_cnt > 32500) {
|
comm_rx_cnt = 0;
|
}
|
if(comm_OK_cnt < 1000) {
|
comm_OK_cnt += 1;
|
}
|
}
|
}
|
|
public void run() {
|
int null_comm_cmd_cnt = 0;
|
while(true == CommThreadRunning) {
|
|
if(false == dt_update_en) {
|
try {
|
if(false == dt_normal_comm_en) {
|
Thread.sleep(100);
|
continue;
|
}
|
|
boolean cmd_set_addr = ((CMD_TYPE_WRITE==dt_cmd) && (UART_MonomerSetAddr_RegAddr==dt_cmd_regaddr));
|
boolean cmd_Set_bianhao_Low = ((CMD_TYPE_WRITE==dt_cmd) && (UART_MonomerLowSign_RegAddr==dt_cmd_regaddr));
|
boolean cmd_Set_bianhao_High = ((CMD_TYPE_WRITE==dt_cmd) && (UART_MonomerClrTmpAddr_RegAddr==dt_cmd_regaddr));
|
|
if(true == dt_update_en) {
|
continue;
|
}
|
if(null_comm_cmd_cnt < 300) {
|
null_comm_cmd_cnt++;
|
} else {
|
null_comm_cmd_cnt = 0;
|
}
|
//---------------------- make tx data --------------------------//
|
if(SPCommMon.DEV_TYPE_Curr == m_DEV_TYPE) {
|
makeCurrModule_CommTxData();
|
} else if(SPCommMon.DEV_TYPE_GroupVol == m_DEV_TYPE) {
|
makeVolModule_CommTxData();
|
} else {
|
if((null_comm_cmd_cnt % 10) == 0) {
|
if(true == cmd_Null_En) {
|
makeCommTxDataNull();
|
} else {
|
makeCommTxData();
|
}
|
} else {
|
makeCommTxData();
|
}
|
}
|
//----------------------- tx rx data ---------------------------//
|
tr_Msg(CommTxBuffer, CommRxBuffer, true);
|
//----------------------- process data -------------------------//
|
if(SPCommMon.DEV_TYPE_Curr == m_DEV_TYPE) {
|
processCurrModule_RxData(CommRxBuffer);
|
} else if(SPCommMon.DEV_TYPE_GroupVol == m_DEV_TYPE) {
|
processVolModule_RxData(CommRxBuffer);
|
} else {
|
processRxData(CommRxBuffer, (false==cmd_Set_bianhao_Low)&&(false==cmd_Set_bianhao_High)&&(false==cmd_set_addr));
|
}
|
//-------------------------------------------------------------//
|
|
Thread.sleep(100);
|
|
if(true == cmd_set_addr) {
|
makeCommTxData();
|
tr_Msg(CommTxBuffer, CommRxBuffer, true);
|
processRxData(CommRxBuffer, true);
|
|
String wav_f = "6133.wav";
|
dt_set_addr_res_inf = "ÉèÖñàºÅΪ" + dt_addr + "³É¹¦ @ " + Com.get_DTF(new Date(), Com.DTF_YMDhms);
|
if(dt_addr != (mAddrSettedNow+1)) {
|
wav_f = "4577.wav";
|
dt_set_addr_res_inf = "ÉèÖñàºÅΪ" + (mAddrSettedNow+1) + "ʧ°Ü!!!!!!! @ "
|
+ Com.get_DTF(new Date(), Com.DTF_YMDhms);
|
}
|
mAddrSettedNow = dt_addr;
|
new PlaySound(wav_f);
|
}
|
|
if(true == cmd_Set_bianhao_Low) {
|
makeCommTxData();
|
tr_Msg(CommTxBuffer, CommRxBuffer, true);
|
processRxData(CommRxBuffer, true);
|
|
if((dt_ssb & (1<<8)) > 0) {
|
this.setCommCmd(CMD_TYPE_WRITE, UART_MonomerClrTmpAddr_RegAddr, (short)1, (short)0x00, (short)0x00);
|
} else {
|
mBianHao_TestRes = 1;
|
}
|
}
|
if(true == cmd_Set_bianhao_High) {
|
makeCommTxData();
|
tr_Msg(CommTxBuffer, CommRxBuffer,true);
|
processRxData(CommRxBuffer, true);
|
|
if((dt_ssb & (1<<8)) == 0) {
|
mBianHao_TestRes = 0;
|
} else {
|
mBianHao_TestRes = 2;
|
}
|
}
|
|
Thread.sleep(200);
|
} catch (InterruptedException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
exitCommPortThread();
|
JOptionPane.showMessageDialog(null, "Monomer CommPort ´®¿ÚÒì³£: " + e.getMessage());
|
}
|
} else {
|
try {
|
makeCommTxData();
|
tr_Msg(CommTxBuffer, CommRxBuffer, false);
|
Thread.sleep(100);
|
} catch (InterruptedException e2) {
|
// TODO Auto-generated catch block
|
e2.printStackTrace();
|
}
|
|
setCommBautrate(dt_dfu_bitrate);
|
String dfu_text_inf = "";
|
m_SPCommDFU = new SPCommMon_DFU(m_COMM,
|
m_DEV_TYPE,
|
dt_target_addr,
|
dt_dfu_read_check_en,
|
dt_show_dfu_inf,
|
dt_debug_inf);
|
boolean check_res = m_SPCommDFU.runDFU(dt_update_file, dfu_text_inf);
|
|
if((true == dt_update_en) && (true == CommThreadRunning)) {
|
if(false == check_res) {
|
Toolkit.getDefaultToolkit().beep();
|
try {
|
Thread.sleep(500);
|
} catch (InterruptedException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
Toolkit.getDefaultToolkit().beep();
|
dt_update_en = false;
|
} else {
|
if(dt_target_addr < dt_dfu_addr_end) {
|
dt_target_addr += 1;
|
this.setCommCmd(SPCommMon.CMD_TYPE_WRITE, SPCommMon.UART_MonomerDFU_RegAddr, (short)0x55AA, (short)0xAA55, (short) 0x7F7F);
|
} else {
|
dt_update_en = false;
|
}
|
}
|
}
|
//-----------------------------------------------------------------------------//
|
dfu_text_inf = dt_show_dfu_inf.getText();
|
dt_show_dfu_inf.setText(dfu_text_inf + "DFU Process Stopped!\n");
|
//-----------------------------------------------------------------------------//
|
setCommBautrate(comm_bautrate);
|
//-----------------------------------------------------------------------------//
|
//-----------------------------------------------------------------------------//
|
for(int n=0; n<2; n++) {
|
try {
|
Thread.sleep(200);
|
} catch (InterruptedException e1) {
|
// TODO Auto-generated catch block
|
e1.printStackTrace();
|
}
|
makeCommTxDataNull();
|
tr_Msg(CommTxBuffer, CommRxBuffer, true);
|
}
|
try {
|
Thread.sleep(200);
|
} catch (InterruptedException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
//-----------------------------------------------------------------------------//
|
//-----------------------------------------------------------------------------//
|
}
|
}
|
/******************************************************************************/
|
closeCommPort();
|
/******************************************************************************/
|
dt_debug_inf.addDebugInf(Com.get_DTF(new Date(), Com.DTF_YMDhms_S)
|
+ " CommPort is quit, Dev Id: " + m_DEV_TYPE
|
+ ", COMM_PORT_TYPE: " + m_COMM_PORT_TYPE + "\n");
|
/******************************************************************************/
|
}
|
}
|
