package com.dev_concentrator.data;
|
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.io.OutputStream;
|
import java.net.Socket;
|
import java.nio.ByteBuffer;
|
import java.nio.ByteOrder;
|
import java.util.Date;
|
|
import com.battmonitor.base.ComBase;
|
import com.battmonitor.data.BattData_RT;
|
import com.battmonitor.data.BattData_RT_Array;
|
import com.battmonitor.data.BattStatData;
|
import com.battmonitor.sql.Com;
|
import com.battmonitor.sql.MysqlConnPool;
|
import com.dev.btse.data.ComFn;
|
import com.dev.btse.data.Ecb_Aes;
|
import com.dev.btse.data.FBS9100_ComBase;
|
|
import main.main_MonitorServer_Concentrator;
|
|
public class Concentrator_SocketThread extends Thread{
|
private BattData_RT_Array GB_DataArray;
|
private MysqlConnPool pool;
|
private BattData_RT_Array dataArray;
|
private Socket socket;
|
private boolean S_thread_run_flag = true;
|
private int rx_errcount_for_live_of_thread = 0; //ÓÃÓÚͳ¼ÆsocketͨÐÅÖеÄÒì³£´ÎÊýͳ¼Æ
|
private ByteBuffer bytebuffer_for_socket_RX = ByteBuffer.allocate(1500);
|
private Concentrator_SysState sysState;
|
boolean reg_in_flag = false;
|
private Concentrator_SetParam param;
|
private Concentrator_Cmd m_CMD;
|
|
public Concentrator_SocketThread(MysqlConnPool pool, Socket socket,BattData_RT_Array GB_DataArray) {
|
this.pool = pool;
|
this.socket = socket;
|
|
m_CMD = new Concentrator_Cmd();
|
sysState = new Concentrator_SysState();
|
param = new Concentrator_SetParam();
|
this.GB_DataArray = GB_DataArray;
|
}
|
|
/**
|
* ¼ì²éÉ豸µÄidºÅÂë
|
*/
|
public void checkDeviceType() {
|
try {
|
for(int i = 0; i < 3 ;i++) {
|
|
Thread.sleep(500);
|
m_CMD.makeCmd(0x01, Concentrator_ComBase.CMD_MODEBUS_READCMD, Concentrator_ComBase.CMD_MODEBUS_DEVICEIDINFO_INDEX,1);
|
boolean flag = SocketComm(m_CMD, ByteBuffer.allocate(0), socket);
|
if(flag = true) {
|
dataArray = Concentrator_SocketThread_SQL.queryDeviceFromDataBase(pool,sysState.getDev_id());
|
// if(dataArray != null) {
|
//
|
//
|
// sysState.setDataArray(dataArray);
|
// reg_in_flag = true;
|
// break;
|
// }
|
dataArray = new BattData_RT_Array();
|
for(int k=0;k<GB_DataArray.getItemCount();k++) {
|
BattData_RT arr = GB_DataArray.getItem(k);
|
if(arr.FBSDeviceId == sysState.getDev_id()) {
|
dataArray.addItem(arr);
|
reg_in_flag = true;
|
}
|
}
|
|
if(reg_in_flag) {
|
sysState.setDataArray(dataArray);
|
break;
|
}
|
}
|
}
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
} finally {
|
if(reg_in_flag && sysState.getDev_id() > 0) {
|
System.out.println("É豸£º"+sysState.getDev_id()+"ʶ±ð³É¹¦ at "+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
}else {
|
reg_in_flag = false;
|
System.out.println("É豸£º"+sysState.getDev_id()+"ʶ±ðʧ°Ü at "+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
}
|
}
|
}
|
|
@Override
|
public void run() {
|
|
checkDeviceType();
|
if(reg_in_flag) {
|
param.dev_id = sysState.getDev_id();
|
|
sysState.setDev_ip(socket.getInetAddress().toString());
|
//ÒѾע²á³É¹¦µÄÉ豸
|
Concentrator_SocketThread_SQL.insertOrupdateFbs9100StateByDev_Id(pool,sysState);
|
|
Concentrator_SocketThread_SQL.insertFBS9100SetParam_Table(pool, param);
|
}
|
while(S_thread_run_flag && reg_in_flag) {
|
try {
|
for(int i= 0;i<dataArray.getItemCount() && i<12;i++) {
|
main_MonitorServer_Concentrator.isFlushData = true; //֪ͨ¸üÐÂÏß³Ì
|
|
Thread.sleep(100);
|
BattData_RT batt = dataArray.getItem(i);
|
m_CMD.makeCmd((i+1), Concentrator_ComBase.CMD_MODEBUS_READCMD, Concentrator_ComBase.CMD_MODEBUS_DEVICESTATE_INDEX, Concentrator_State.REG_LEN);
|
SocketComm(m_CMD, ByteBuffer.allocate(0), socket);
|
|
int reg_count = batt.MonCount;
|
if(batt.MonCount > 300) {
|
reg_count = 300;
|
}
|
|
Thread.sleep(100);
|
m_CMD.makeCmd((i+1), Concentrator_ComBase.CMD_MODEBUS_READCMD, Concentrator_ComBase.CMD_MODEBUS_BATTMONVOL_INDEX,reg_count);
|
SocketComm(m_CMD, ByteBuffer.allocate(0), socket);
|
|
Thread.sleep(100);
|
m_CMD.makeCmd((i+1), Concentrator_ComBase.CMD_MODEBUS_READCMD, Concentrator_ComBase.CMD_MODEBUS_BATTMONTMP_INDEX,reg_count);
|
SocketComm(m_CMD, ByteBuffer.allocate(0), socket);
|
|
Thread.sleep(100);
|
m_CMD.makeCmd((i+1), Concentrator_ComBase.CMD_MODEBUS_READCMD, Concentrator_ComBase.CMD_MODEBUS_BATTMONRES_INDEX,reg_count);
|
SocketComm(m_CMD, ByteBuffer.allocate(0), socket);
|
|
if(sysState != null) {
|
Concentrator_SocketThread_SQL.insertOrupdateFbs9100StateByDev_Id(pool, sysState);
|
}
|
|
Concentrator_SocketThread_SQL.queryFBS9100SetParam_Table(pool, param);
|
if(param.op_cmd == Concentrator_ComBase.CMD_Start) {
|
//if(param.TestCmd == Concentrator_ComBase.CMD_StartResDischarge) {
|
if(param.BattGroupNum < 1) {
|
param.BattGroupNum = 1;
|
}
|
System.out.println("DevId:"+sysState.getDev_id()+";µç³Ø×é:"+param.BattGroupNum+";Æô¶¯ÄÚ×è²âÊÔ at"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
|
//Æô¶¯ÄÚ×è²âÊÔ
|
//m_CMD.makeCmd(0xFF, Concentrator_ComBase.CMD_MODEBUS_WRITECMD, Concentrator_ComBase.CMD_MODEBUS_STARTRESTEST,1);
|
m_CMD.makeCmd(param.BattGroupNum, Concentrator_ComBase.CMD_MODEBUS_WRITECMD, Concentrator_ComBase.CMD_MODEBUS_STARTRESTEST,1);
|
if(SocketComm(m_CMD, m_CMD.getControlByteBuffer(), socket)) {
|
param.op_cmd = Concentrator_ComBase.CMD_StartAck;
|
}
|
|
Concentrator_SocketThread_SQL.updateFBS9100SetParam_Table(pool, param);
|
//}
|
}else if(param.op_cmd == Concentrator_ComBase.CMD_Stop) {
|
//Í£Ö¹ÄÚ×è²âÊÔ
|
if(param.BattGroupNum < 1) {
|
param.BattGroupNum = 1;
|
}
|
System.out.println("DevId:"+sysState.getDev_id()+";µç³Ø×é:"+param.BattGroupNum+";Í£Ö¹ÄÚ×è²âÊÔ at"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
//Í£Ö¹ÄÚ×è²âÊÔ
|
m_CMD.makeCmd(param.BattGroupNum, Concentrator_ComBase.CMD_MODEBUS_WRITECMD, Concentrator_ComBase.CMD_MODEBUS_STOPRESTEST,1);
|
//m_CMD.makeCmd(0xFF, Concentrator_ComBase.CMD_MODEBUS_WRITECMD, Concentrator_ComBase.CMD_MODEBUS_STOPRESTEST,1);
|
if(SocketComm(m_CMD, m_CMD.getControlByteBuffer(), socket)) {
|
param.op_cmd = Concentrator_ComBase.CMD_StopAck;
|
}
|
Concentrator_SocketThread_SQL.updateFBS9100SetParam_Table(pool, param);
|
}else if(param.op_cmd == Concentrator_ComBase.CMD_ResetSystem) {
|
if(param.BattGroupNum >3) {
|
param.BattGroupNum = 0;
|
}
|
//ϵͳÖØÆô
|
m_CMD.makeCmd(0xFF, Concentrator_ComBase.CMD_MODEBUS_WRITECMD, Concentrator_ComBase.CMD_MODEBUS_RESTARTSYS,1);
|
SocketComm(m_CMD, m_CMD.getControlByteBuffer(), socket);
|
param.op_cmd = Concentrator_ComBase.CMD_ResetSystemAck;
|
Concentrator_SocketThread_SQL.updateFBS9100SetParam_Table(pool, param);
|
}
|
|
|
}
|
Thread.sleep(50);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
if(null != this.socket) {
|
try {
|
this.socket.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
if(reg_in_flag) {
|
System.out.println("É豸£º"+sysState.getDev_id()+" ͨѶ³¬Ê±,¶Ï¿ªÍ¨ÐÅ at "+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
}
|
}
|
|
|
public boolean SocketComm(Concentrator_Cmd m_CMD, ByteBuffer bf, Socket socket)
|
{
|
boolean res_t = false;
|
try {
|
socket.setSoTimeout(3000);
|
if(S_thread_run_flag) {
|
InputStream in = socket.getInputStream();
|
OutputStream out = socket.getOutputStream();
|
//----------------- clear rx buff for tcp resend packet ----------------//
|
byte[] rx_buf_t = new byte[1024];
|
/*
|
int buf_clr_read_count = 0;
|
while(in.available() > 0) {
|
in.read(rx_buf_t);
|
if(buf_clr_read_count >= 10) {
|
S_thread_run_flag = false;
|
System.err.println(this.getName()
|
+ " dev_id: " + m_StatAndParam.dev_id
|
+ " socket rx_buff clear error......");
|
res_t = false;
|
return res_t;
|
}
|
}*/
|
//----------------------------------------------------------------------//
|
//--------------------- socket write -----------------------------------//
|
byte[] cipher_tx_t = null;
|
Ecb_Aes my_aes = new Ecb_Aes();
|
if(m_CMD.RES_Index == FBS9100_ComBase.CMD_ReadGPRSCSQ) {
|
cipher_tx_t = new byte[bf.limit()];
|
bf.get(cipher_tx_t);
|
} else {
|
cipher_tx_t = makeCommBuf(m_CMD, bf, false);
|
|
}
|
//System.err.println("·¢ËÍÊý¾Ý£º"+ComFn.bytesToHexString(cipher_tx_t, cipher_tx_t.length));
|
//=====================================================================//
|
Date d1 = new Date();
|
int rx_read_time_out = 0;
|
out.write(cipher_tx_t);
|
out.flush();
|
|
bytebuffer_for_socket_RX.order(ByteOrder.BIG_ENDIAN);
|
bytebuffer_for_socket_RX.clear();
|
while(true) {
|
if(in.available() > 0) {
|
rx_read_time_out = 0;
|
int rx_len_t = in.read(rx_buf_t);
|
if((bytebuffer_for_socket_RX.position()+rx_len_t)
|
< (bytebuffer_for_socket_RX.capacity()-1)) {
|
bytebuffer_for_socket_RX.put(rx_buf_t, 0, rx_len_t);
|
}
|
} else {
|
rx_read_time_out += 1;
|
if((bytebuffer_for_socket_RX.position()>=8) && (rx_read_time_out>50)){
|
res_t = true;
|
break;
|
}
|
|
if(rx_read_time_out > 220) {
|
break;
|
}
|
}
|
Thread.sleep(10);
|
}
|
|
bytebuffer_for_socket_RX.flip();
|
|
Date d2 = new Date();
|
long comm_tms = (d2.getTime() - d1.getTime());
|
if(comm_tms < 200) {
|
Thread.sleep(200 - comm_tms);
|
}
|
/*
|
System.out.println(this.getName()
|
+ " dev_id:" + m_StatAndParam.dev_id
|
+ " cmd:" + cmd
|
+ " d2-d1:" + (comm_tms)+"ms"
|
+ " rx_len:" + bytebuffer_for_socket_RX.limit()
|
//+ " tx_count:" + m_StatAndParam.m_FBS_VCData.m_SysState.CommCount
|
//+ " rx_err_sum:" + m_StatAndParam.m_FBS_VCData.m_SysState.ErrCommCount
|
//+ " rx_err_count:" + rx_errcount_for_live_of_thread
|
+ Com.getNowTimeWithAt());
|
*/
|
byte[] cipher_buf = new byte[bytebuffer_for_socket_RX.limit()];
|
byte[] plain_buf = new byte[bytebuffer_for_socket_RX.limit()];
|
bytebuffer_for_socket_RX.get(plain_buf);
|
//System.out.println("½ÓÊÕÊý¾Ý£º"+ComFn.bytesToHexString(plain_buf, plain_buf.length));
|
if(m_CMD.RES_Index == FBS9100_ComBase.CMD_ReadGPRSCSQ) {
|
if(bytebuffer_for_socket_RX.limit() > 2) {
|
rx_errcount_for_live_of_thread = 0;
|
res_t = true;
|
|
//m_StatAndParam.m_GPRS_inf = new String(cipher_buf);
|
//System.out.println("this.getName() + " + " DevId: " + m_StatAndParam.dev_id
|
// + " GPRS RF Level:" + m_StatAndParam.m_GPRS_CSQ);
|
}
|
} else {
|
if((cipher_buf.length >= 8) && (true == getDataFromCommBuf(plain_buf))) {
|
|
rx_errcount_for_live_of_thread = 0;
|
res_t = true;
|
sysState.setDev_commcount();
|
} else {
|
res_t = false;
|
|
rx_errcount_for_live_of_thread++;
|
//m_StatAndParam.m_SysState.setErrCommCountInc(bytebuffer_for_socket_RX.limit());
|
sysState.setDev_errcommcount();
|
}
|
}
|
} else {
|
S_thread_run_flag = false;
|
sysState.setDev_errcommcount();
|
}
|
} catch (IOException | InterruptedException e) {
|
//e.printStackTrace();
|
sysState.setDev_errcommcount();
|
S_thread_run_flag = false;
|
} finally {
|
//ÈôÔÚͨÐŵĹý³ÌÖгöÏÖÁ¬Ðø5´ÎͨÐÅÒì³£¹Ø±ÕÁ¬½Ó
|
if(rx_errcount_for_live_of_thread >= 5){
|
S_thread_run_flag = false;
|
}
|
}
|
return res_t;
|
}
|
|
private boolean getDataFromCommBuf(byte[] bytes) {
|
boolean isSuccess = false;
|
ByteBuffer bf = ByteBuffer.allocate(bytes.length);
|
bf.order(ByteOrder.BIG_ENDIAN);
|
bf.put(bytes);
|
bf.flip();
|
Concentrator_Cmd m_Con_Cmd = new Concentrator_Cmd();
|
if(true == m_Con_Cmd.putByteBuffer(bf)) {
|
if(Concentrator_ComBase.CMD_MODEBUS_READCMD == m_Con_Cmd.CMD) {
|
if(Concentrator_ComBase.CMD_MODEBUS_DEVICEIDINFO_INDEX == m_Con_Cmd.RES_Index) {
|
int dev_ID = ComBase.changeShortToInt(bf.getShort());
|
//System.out.println(dev_ID);
|
//¶ÁÈ¡É豸IDÐÅÏ¢
|
if(dev_ID >= 0) {
|
sysState.setDev_id(960500000 + dev_ID);
|
isSuccess = true;
|
}
|
|
}else if(Concentrator_ComBase.CMD_MODEBUS_DEVICESTATE_INDEX == m_Con_Cmd.RES_Index) {
|
Concentrator_State battstate = new Concentrator_State();
|
//¶ÁÈ¡É豸µÄ״̬ÐÅÏ¢
|
if(true == battstate.putByteBuffer(bf)) {
|
//¸üÐÂÖ¸¶¨µÄÉ豸µÄ×é¶ËÐÅÏ¢
|
BattData_RT batt = dataArray.getItem(m_Con_Cmd.ADDR-1);
|
//System.out.println(batt + "==="+(m_Con_Cmd.ADDR-1)+"=="+batt.BattGroupId);
|
if(null != batt) {
|
getConcentratorBattState(batt,battstate);
|
}
|
|
isSuccess = true;
|
}
|
|
}else if(Concentrator_ComBase.CMD_MODEBUS_BATTMONVOL_INDEX == m_Con_Cmd.RES_Index) {
|
//¶ÁÈ¡µ¥Ìåµçѹ
|
Concentrator_ResCapData mondata = new Concentrator_ResCapData();
|
if(true == mondata.putByteBuffer(bf, FBS9100_ComBase.DataType_MonVol)) {
|
//System.out.println("¶ÁÈ¡µçѹ³É¹¦");
|
BattData_RT batt = dataArray.getItem(m_Con_Cmd.ADDR-1);
|
if(null != batt) {
|
getConCentratorMonData(batt,mondata);
|
}
|
isSuccess = true;
|
}
|
|
|
}else if(Concentrator_ComBase.CMD_MODEBUS_BATTMONTMP_INDEX == m_Con_Cmd.RES_Index){
|
//¶ÁÈ¡µ¥ÌåζÈ
|
Concentrator_ResCapData mondata = new Concentrator_ResCapData();
|
if(true == mondata.putByteBuffer(bf, FBS9100_ComBase.CMD_GetMonomerTMP)) {
|
//System.out.println("¶Áȡζȳɹ¦"+"==="+mondata.m_DataType);
|
BattData_RT batt = dataArray.getItem(m_Con_Cmd.ADDR-1);
|
if(null != batt) {
|
getConCentratorMonData(batt,mondata);
|
}
|
//getConCentratorMonData(dataArray.getItem(0),mondata);
|
isSuccess = true;
|
}
|
|
}else if(Concentrator_ComBase.CMD_MODEBUS_BATTMONRES_INDEX == m_Con_Cmd.RES_Index) {
|
//¶ÁÈ¡µ¥ÌåÄÚ×è
|
Concentrator_ResCapData mondata = new Concentrator_ResCapData();
|
if(true == mondata.putByteBuffer(bf, FBS9100_ComBase.CMD_GetMonomerRES)) {
|
//System.out.println("¶ÁÈ¡ÄÚ×è³É¹¦");
|
BattData_RT batt = dataArray.getItem(m_Con_Cmd.ADDR-1);
|
if(null != batt) {
|
getConCentratorMonData(batt,mondata);
|
}
|
//getConCentratorMonData(dataArray.getItem(0),mondata);
|
isSuccess = true;
|
}
|
|
}
|
}else if(Concentrator_ComBase.CMD_MODEBUS_WRITECMD == m_Con_Cmd.CMD){
|
if(Concentrator_ComBase.CMD_Result_Success == m_Con_Cmd.Result_val) {
|
if(Concentrator_ComBase.CMD_MODEBUS_STARTRESTEST == m_Con_Cmd.RES_Index) {
|
System.out.println("DevId:"+sysState.getDev_id()+" Æô¶¯ÄÚ×è²âÊԳɹ¦ "+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
}
|
if(Concentrator_ComBase.CMD_MODEBUS_STOPRESTEST == m_Con_Cmd.RES_Index) {
|
System.out.println("DevId:"+sysState.getDev_id()+" Í£Ö¹ÄÚ×è²âÊԳɹ¦ "+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
}
|
if(Concentrator_ComBase.CMD_MODEBUS_RESTARTSYS == m_Con_Cmd.RES_Index) {
|
System.out.println("DevId:"+sysState.getDev_id()+" ÖØÆô³É¹¦ "+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
//System.out.println("ÖØÆô³É¹¦");
|
}
|
}
|
isSuccess = true;
|
}
|
}
|
return isSuccess;
|
}
|
|
|
/**
|
* ¸üеç³Ø×éµÄµ¥ÌåÐÅÏ¢
|
* @param battData
|
* @param mondata
|
*/
|
private void getConCentratorMonData(BattData_RT battData, Concentrator_ResCapData mondata) {
|
if(battData != null) {
|
try {
|
int mon_index = 0;
|
for(int index=0; index<battData.al_MonVol.size(); index++) {
|
if(mon_index >= FBS9100_ComBase.MonomerCountMax) {
|
break;
|
}
|
if(mondata.m_DataType == FBS9100_ComBase.DataType_MonVol) {
|
battData.al_MonVol.get(index).monVol = (float) mondata.m_DATA[mon_index];
|
}else if(mondata.m_DataType == FBS9100_ComBase.DataType_MonTmp){
|
battData.al_MonVol.get(index).monTmp = (float) mondata.m_DATA[mon_index];
|
//System.out.println(battData.al_MonVol.get(index).monTmp);
|
}else if(mondata.m_DataType == FBS9100_ComBase.DataType_MonRes){
|
battData.al_MonVol.get(index).monRes = (float) mondata.m_DATA[mon_index];
|
//System.out.println("index:"+battData.al_MonVol.get(index).monRes);
|
}
|
mon_index++;
|
}
|
//System.out.println();
|
battData.updata_BattRtData_To_RamDb();
|
} catch (Exception e) {
|
System.err.println("Concentrator_SocketThread.getConCentratorMonData: " + e.getMessage());
|
}
|
}
|
}
|
|
/**
|
* ¸üеç³Ø×é¶ËÐÅÏ¢
|
* @param battData
|
* @param battstate
|
*/
|
private void getConcentratorBattState(BattData_RT battData, Concentrator_State battstate) {
|
|
if(battData != null) {
|
//battState.mTestData.updateGroupTempFrom_FBSDev((float)(vc_data.batttemp[n]));
|
//battState.mTestData.updateOnlineVolFrom_FBSDev((float)(vc_data.onlinevol[n]));
|
|
if(battstate.getBattstate() == 0) {
|
battData.mTestData.battState = BattStatData.BATTDATA_FLOAT;
|
battData.mTestData.dev_FBS9100S_WorkState = FBS9100_ComBase.SYS_STATE_STOPPED;
|
}else if(battstate.getBattstate() == 1) {
|
battData.mTestData.battState = BattStatData.BATTSTATE_DISCHARGE;
|
battData.mTestData.dev_FBS9100S_WorkState = FBS9100_ComBase.SYS_STATE_DISCHARGING;
|
}else if(battstate.getBattstate() == 2) {
|
battData.mTestData.battState = BattStatData.BATTSTATE_CHARGE;
|
battData.mTestData.dev_FBS9100S_WorkState = FBS9100_ComBase.SYS_STATE_CHARGING;
|
}
|
battData.mTestData.updateGroupVolFrom_FBSDev((float)(battstate.getGroupvol()));
|
//---------------------------------------------------------------------------//
|
|
//--------------------- ½Ó×ŶÁÈ¡µçÁ÷ -----------------------------------------//
|
battData.mTestData.updateCurrFrom_FBSDev((float) battstate.getGroupcurr());
|
sysState.setSysstate(battData.mTestData.upDevWorkState((float) battstate.getGroupcurr()));
|
sysState.sysversion = battstate.getSysversion();
|
//sysState.dev_restest_count = battstate.getRestestcount();
|
//sysState.dev_res_test_state = battstate.getDev_Res_State(); //ÄÚ×è²âÊÔ
|
//---------------------------------------------------------------------------//
|
//--------------------- È»ºó¶ÁÈ¡ÄÚ×è²âÊÔ״̬ ---------------------------------//
|
battData.mTestData.batt_res_test_state = battstate.getDev_Res_State();
|
battData.mTestData.batt_res_test_cnt = battstate.getRestestcount();
|
battData.setmRecordTime(new Date());
|
battData.updata_BattRtSate_To_RamDb();
|
}
|
|
}
|
|
/*
|
* ¹¹Ôì·¢ËÍÊý¾Ý
|
*/
|
public byte[] makeCommBuf(Concentrator_Cmd m_CMD, ByteBuffer bf, boolean aes_en)
|
{
|
ByteBuffer bbf = Concentrator_ComBuf.makeTmpSensorCommBuf(m_CMD, bf, aes_en);
|
byte byte_rest[] = new byte[bbf.limit()];
|
bbf.get(byte_rest);
|
return byte_rest;
|
}
|
}
|
