package com.dev.fbs9600_groupvol;
|
import gnu.io.SerialPort;
|
import gnu.io.UnsupportedCommOperationException;
|
|
import java.io.InputStream;
|
import java.io.OutputStream;
|
import java.nio.ByteBuffer;
|
import java.nio.ByteOrder;
|
import java.util.Date;
|
|
import javax.swing.JOptionPane;
|
import javax.swing.JTextField;
|
|
import org.apache.logging.log4j.Logger;
|
|
import sp_comm.CommSerialPort;
|
import sp_comm.Comm_Socket;
|
import main.page_debug_inf;
|
|
import com.Com;
|
import com.Crc16;
|
|
public class SPCommGroupVol implements Runnable/*, SerialPortEventListener*/ {
|
public static final int COMM_PORT_TYPE_Serial = 0;
|
public static final int COMM_PORT_TYPE_Socket = 1;
|
|
public static final byte CMD_TYPE_READ = 0x03;
|
public static final byte CMD_TYPE_WRITE_Multy = 0x10;
|
public static final short UART_MonomerSetAddr_RegAddr = 0001;
|
public static final short UART_MonomerAdjOffSet_RegAddr = 0002; //Æ«ÒÆÁ¿
|
public static final short UART_MonomerAdjSlope_RegAddr = 0003; //бÂÊ
|
|
public static final short UART_MonomerVer_RegAddr = 1001;
|
|
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_KW8 = 120;
|
public static final int DEV_TYPE_BYBB = 130;
|
|
public int m_DEV_TYPE = DEV_TYPE_FCF651GroupVol;
|
|
private CommSerialPort m_SP_Comm = null;
|
private Comm_Socket m_SocketComm = 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 short comm_tx_cnt = 0;
|
public short comm_rx_cnt = 0;
|
|
public short comm_OK_cnt = 0;
|
public short comm_Err_cnt = 0;
|
public boolean dt_new_tag = false;
|
|
public int dt_target_addr = 0;
|
public short dt_addr = 0;
|
public int dt_vol = 0;
|
public int dt_version = 0;
|
public int dt_volcal_offset = 0;
|
public int dt_volcal_slope = 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;
|
int dt_multy_comm = CommSerialPort.mutycomm_Type_Samd09;
|
private short dt_auto_read_regaddr = UART_MonomerVer_RegAddr;
|
|
private JTextField addr_TextField = null;
|
|
|
private page_debug_inf dt_debug_inf;
|
private int m_COMM_PORT_TYPE = 0;
|
|
private Logger m_Log = null;
|
|
public SPCommGroupVol(int addr_t, int bitrate, int dev_type,
|
int multy_com_type, page_debug_inf debug, Logger log) {
|
dt_target_addr = addr_t & 0xFFFF;
|
dt_multy_comm = multy_com_type;
|
dt_debug_inf = debug;
|
//-------------------------------------------------------------//
|
m_DEV_TYPE = dev_type;
|
//-------------------------------------------------------------//
|
m_Log = log;
|
}
|
|
public SPCommGroupVol(JTextField addr_t, int bitrate, int dev_type,
|
int multy_com_type, page_debug_inf debug) {
|
//dt_target_addr = addr_t & 0xFFFF;
|
addr_TextField = addr_t;
|
dt_multy_comm = multy_com_type;
|
dt_debug_inf = debug;
|
//-------------------------------------------------------------//
|
m_DEV_TYPE = dev_type;
|
//-------------------------------------------------------------//
|
}
|
|
public void setCommAddr(int addr_t) {
|
dt_target_addr = addr_t & 0xFFFF;
|
}
|
|
public void setCommBautrate(int bt_rate) {
|
if(COMM_PORT_TYPE_Serial != m_COMM_PORT_TYPE) {
|
return;
|
}
|
|
try {
|
m_SP_Comm.serialPort.setSerialPortParams(bt_rate, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
|
} catch (UnsupportedCommOperationException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
}
|
|
//³õʼ»¯´®¿Ú
|
public boolean OpenCommPort(int comm_port_type, String comm_name_or_ip, int bitrate_or_comm_port) {
|
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 makeVolModule_CommTxData() {
|
CommTxBuffer.clear();
|
|
if(null != addr_TextField) {
|
dt_target_addr = (short) Integer.parseInt(addr_TextField.getText()) & 0xFFFF;
|
}
|
|
if(CMD_TYPE_READ == dt_cmd) {
|
if(UART_MonomerVer_RegAddr == dt_auto_read_regaddr) {
|
dt_auto_read_regaddr = UART_MonomerSetAddr_RegAddr;
|
} else {
|
dt_auto_read_regaddr = UART_MonomerVer_RegAddr;
|
}
|
|
CommTxBuffer.put((byte) dt_target_addr);
|
CommTxBuffer.put((byte) CMD_TYPE_READ);
|
CommTxBuffer.put((byte) (dt_auto_read_regaddr>>8));
|
CommTxBuffer.put((byte) dt_auto_read_regaddr);
|
CommTxBuffer.put((byte) 0x00);
|
CommTxBuffer.put((byte) 0x03);
|
} else {
|
byte datlen = (byte) (dt_cmd_regcnt*2);
|
CommTxBuffer.put((byte) dt_target_addr);
|
CommTxBuffer.put((byte) CMD_TYPE_WRITE_Multy);
|
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) datlen);
|
CommTxBuffer.put((byte) (dt_cmd_data>>8));
|
CommTxBuffer.put((byte) dt_cmd_data);
|
if(dt_cmd_regcnt > 1) {
|
CommTxBuffer.put((byte) (dt_cmd_data1>>8));
|
CommTxBuffer.put((byte) dt_cmd_data1);
|
}
|
dt_cmd_regcnt = 0;
|
dt_cmd = CMD_TYPE_READ;
|
}
|
|
int crc = Crc16.CalCRC16(CommTxBuffer, CommTxBuffer.position()) & 0xFFFF;
|
CommTxBuffer.putShort((short) crc);
|
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;
|
}
|
if(COMM_PORT_TYPE_Serial == m_COMM_PORT_TYPE) {
|
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() {
|
if(COMM_PORT_TYPE_Serial == m_COMM_PORT_TYPE) {
|
m_SP_Comm.serialPort.close();
|
} else {
|
m_SocketComm.socketClose();
|
}
|
}
|
|
public void exitCommPortThread() {
|
CommThreadRunning = false;
|
}
|
|
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;
|
}
|
|
private void processVolModule_RxData(ByteBuffer bbf_rx, short addr_reg) {
|
if(false == checkCommBuf(bbf_rx)) {
|
return;
|
}
|
|
if(bbf_rx.limit() >= 7) {
|
bbf_rx.position(0);
|
dt_addr = (short) (bbf_rx.get() & 0xFF);
|
byte cmd_t = bbf_rx.get();//cmd
|
bbf_rx.get();//bytes
|
if(CMD_TYPE_READ == cmd_t) {
|
if(UART_MonomerVer_RegAddr == addr_reg) {
|
dt_version = bbf_rx.getShort() & 0xFFFF;
|
dt_vol = bbf_rx.getShort() & 0xFFFF;
|
dt_vol = (dt_vol) | (((int)(bbf_rx.getShort() & 0xFFFF))<<16);
|
} else {
|
bbf_rx.getShort();
|
dt_volcal_offset = bbf_rx.getShort();
|
dt_volcal_slope = bbf_rx.getShort() & 0xFFFF;
|
}
|
}
|
|
if(++comm_rx_cnt > 32500) {
|
comm_rx_cnt = 0;
|
}
|
if(comm_OK_cnt < 1000) {
|
comm_OK_cnt += 1;
|
}
|
}
|
}
|
|
public void run() {
|
while(true == CommThreadRunning) {
|
try {
|
//---------------------- make tx data --------------------------//
|
makeVolModule_CommTxData();
|
//----------------------- tx rx data ---------------------------//
|
tr_Msg(CommTxBuffer, CommRxBuffer, true);
|
//----------------------- process data -------------------------//
|
processVolModule_RxData(CommRxBuffer, dt_auto_read_regaddr);
|
//-------------------------------------------------------------//
|
|
Thread.sleep(500);
|
} catch (InterruptedException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
exitCommPortThread();
|
JOptionPane.showMessageDialog(null, "FCF651 GroupVol Module CommPort ´®¿ÚÒì³£: " + e.getMessage());
|
}
|
}
|
/******************************************************************************/
|
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");
|
/******************************************************************************/
|
}
|
}
|
