package com.dev.btsm;
import gnu.io.SerialPort;
import gnu.io.UnsupportedCommOperationException;

import java.io.IOException;
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.Ecb_Aes;
import com.PlaySound;
import com.dev.bts.data.FBS9100_CapState;
import com.dev.bts.data.FBS9100_ChargeState;
import com.dev.bts.data.FBS9100_Cmd;
import com.dev.bts.data.FBS9100_ComBase;
import com.dev.bts.data.FBS9100_ComBuf;
import com.dev.bts.data.FBS9100_DeviceInf;
import com.dev.bts.data.FBS9100_ParamBatt;
import com.dev.bts.data.FBS9100_ParamCharge;
import com.dev.bts.data.FBS9100_ParamDischarge;
import com.dev.bts.data.FBS9100_ParamSystem;
import com.dev.bts.data.FBS9100_ResCapData;
import com.dev.bts.data.FBS9100_ResState;
import com.dev.bts.data.FBS9100_VCData;
import com.dev.fbs9600_mon.SPCommMon;

public class CommBTS implements Runnable/*, SerialPortEventListener*/ {
	
	public static final short CMD_TYPE_READ = 0x03;
	public static final short CMD_TYPE_WRITE = 0x05;
	public static final short CMD_TYPE_WRITE_MULTY = 0x10;
	
	public static final int DEV_PARAM_DATA_STATE_NULL = 0;
	public static final int DEV_PARAM_DATA_STATE_QUERY = 1;
	public static final int DEV_PARAM_DATA_STATE_UPDATE = 2;
	/*********************************************************************/
	final public static String[] ZDHJ_OP_REST_INF_TEXT = new String[] {
			"ÎÞ²Ù×÷",
	};
	
	// ÊäÈëÊä³öÁ÷
	public static InputStream inputStream;
	public static OutputStream outputStream;
	// RS-232µÄ´®ÐпÚ
	public static SerialPort serialPort;
	
	private boolean CommThreadRunning = false;
	private boolean dt_dfu_en = false;
	Ecb_Aes my_aes = new Ecb_Aes();
	private ByteBuffer CommRxBuffer = ByteBuffer.allocate(1500); 
	private ByteBuffer CommTxBuffer = ByteBuffer.allocate(1048);
	
	private ByteBuffer DFUCommRxBuffer = ByteBuffer.allocate(1048); 
	private ByteBuffer DFUCommTxBuffer = ByteBuffer.allocate(1048);
	
	private ByteBuffer FBS9100TxBuffer = ByteBuffer.allocate(1048);
	private ByteBuffer FBS9100RxBuffer = ByteBuffer.allocate(1500);
	
	public int comm_tx_cnt = 0;
	public int comm_rx_cnt = 0;
	
	private int comm_bautrate = 9600;
	public int dt_target_addr = 0;
	//--------------------------------------------------------//
	public int dev_param_data_state = 0;
	public int dev_param_addr = 0;
	public int[] dev_param_ch_mon_cnt = new int[5];
	public int dev_param_curr_range = 0;
	public double dev_param_wenbo_curr_lev = 0;
	public int dev_param_auto_restest_interval = 0;
	public int dev_param_res_test_type = 0;
	//--------------------------------------------------------//
	public String dev_stat_version_Str = "";
	public int dev_stat_version = 0;
	public int dev_stat_state = 0;
	public double GroupVol = 0;
	public double BattCurr = 0;
	public int BattCurrDir = 0;
	public double AvgWenBoCurr = 0;
	public double PeakWenBoCurr = 0;
	//--------------------------------------------------------//
	@SuppressWarnings("unused")
	private JTextField dt_show_msg = new JTextField();
	private int dt_cmd = FBS9100_ComBase.CMD_GetVIData;
	private int dt_usr_cmd = FBS9100_ComBase.CMD_NULL;
	private ByteBuffer dt_datatofbs9100 = ByteBuffer.allocate(0);
	public int dt_cmd_ack = 0;
	public Date dt_cmd_ack_time = new Date();
	private int dt_cmd_cnt = 0;
	public int m_BTSDevSoftType = 0;
	//--------------------------------------------------------//
	//--------------------------------------------------------//
	public FBS9100_Cmd m_FBS_Cmd = new FBS9100_Cmd();
	public FBS9100_VCData m_FBS_VCData = new FBS9100_VCData();
	public FBS9100_ParamBatt m_FBS_BattParam = new FBS9100_ParamBatt();
	public FBS9100_ParamSystem m_FBS_SystemParam = new FBS9100_ParamSystem();
	public FBS9100_ParamDischarge m_FBS_DiscParam = null;
	public FBS9100_ParamDischarge m_FBS_DiscParamFromDev = null;
	public FBS9100_ParamCharge m_FBS_ChargeParam = new FBS9100_ParamCharge();
	public FBS9100_ResState m_ResTestState = new FBS9100_ResState();
	public FBS9100_CapState m_CapTestState = new FBS9100_CapState();
	public FBS9100_ChargeState m_ChrTestState = new FBS9100_ChargeState();
	public FBS9100_ResCapData m_FBS_ResCapData = new FBS9100_ResCapData();
	public ByteBuffer m_TaskList = ByteBuffer.allocate(1024); 
	//--------------------------------------------------------//
	private page_debug_inf dt_debug_inf;
	private int m_COMM_PORT_TYPE = 0;
	private CommSerialPort m_SP_Comm = null;
	private Comm_Socket m_SocketComm = null;
	private Logger m_Log = null;
	//--------------------------------------------------------//
	
	public CommBTS(int addr_t, int bitrate, page_debug_inf debug, Logger log) {
		dt_target_addr = addr_t & 0x00FF;
		comm_bautrate = bitrate;
		dt_debug_inf = debug;
		m_Log = log;
	}
	
	public void setCommBautrate(int bt_rate) {
		if(SPCommMon.COMM_PORT_TYPE_Serial != m_COMM_PORT_TYPE) {
			return;
		}
		
		try {
			comm_bautrate = bt_rate;
			serialPort.setSerialPortParams(comm_bautrate, 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(SPCommMon.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);
			DFUCommTxBuffer.order(ByteOrder.LITTLE_ENDIAN);
			DFUCommRxBuffer.order(ByteOrder.LITTLE_ENDIAN);
			FBS9100TxBuffer.order(ByteOrder.LITTLE_ENDIAN);
			FBS9100RxBuffer.order(ByteOrder.LITTLE_ENDIAN);
			comm_tx_cnt = 0;
			comm_rx_cnt = 0;
			CommThreadRunning = true;
		}
		
		return res;
	}
	
	private byte[] makeCommTxData() {
		dt_cmd = FBS9100_ComBase.CMD_GetDeviceInf;
		
		if(0 == dev_stat_version) {
			dt_cmd = FBS9100_ComBase.CMD_GetDeviceInf;
		} else {
			if(FBS9100_ComBase.CMD_NULL == dt_usr_cmd) {
				if(++dt_cmd_cnt  > 1000) {
					dt_cmd_cnt = 0;
				}
				dt_cmd = FBS9100_ComBase.CMD_GetVIData;
				if(0 == dt_cmd_cnt%3) {
					dt_cmd = FBS9100_ComBase.CMD_GetMonomerRES;
				}
				if(0 == dt_cmd_cnt%5) {
					dt_cmd = FBS9100_ComBase.CMD_GetMonomerTMP;
				}
				dt_datatofbs9100 = ByteBuffer.allocate(0);
			} else {
				dt_cmd = dt_usr_cmd;
				dt_usr_cmd = FBS9100_ComBase.CMD_NULL;
			}
		}
		
		ByteBuffer buf_t = FBS9100_ComBuf.makeFbs9100CommBuf(255, dt_cmd, dt_datatofbs9100, true);
		
		//byte[] plain_tx_t = new byte[buf_t.limit()];
		byte[] cipher_tx_t = new byte[buf_t.limit()];
		buf_t.get(cipher_tx_t);
		
		//my_aes.ecb_encrypt(plain_tx_t, cipher_tx_t, plain_tx_t.length);
		
		//System.out.println(ComFn.bytesToHexString(plain_tx_t, plain_tx_t.length));
		//System.out.println("TX:" + ComFn.bytesToHexString(cipher_tx_t, cipher_tx_t.length));
		
		return cipher_tx_t;
	}
	
	public void tr_Msg(ByteBuffer bbf_tx, ByteBuffer bbf_rx, boolean showdat) {
		if(++comm_tx_cnt > 32500) {
	    	comm_tx_cnt = 0;
	    }
		if(SPCommMon.COMM_PORT_TYPE_Serial == m_COMM_PORT_TYPE) {
			m_SP_Comm.SP_Comm(bbf_tx, bbf_rx, CommSerialPort.mutycomm_Type_Samd09, dt_debug_inf, showdat);
		} else {
			m_SocketComm.SocketComm(bbf_tx, bbf_rx, dt_debug_inf, showdat);
		}
	}
	
	public void exitCommPortThread() {
		CommThreadRunning = false;
	}
	
	private void closeCommPort() {
		if(SPCommMon.COMM_PORT_TYPE_Serial == m_COMM_PORT_TYPE) {
			m_SP_Comm.serialPort.close();
		} else {
			m_SocketComm.socketClose();
		}
	}
	
	public void setCommCmd(int cmd, ByteBuffer data_buf) {
		dt_usr_cmd = cmd;
		dt_datatofbs9100 = data_buf;
	}
	
	public void setCommCmd_DFU(boolean dfu_en, String dfu_file, JTextField show_area) {
		dt_dfu_en = dfu_en;
		dt_show_msg = show_area;
	}
	
	public void setCommCmdAck(int ack_t) {
		dt_cmd_ack = ack_t;
		dt_cmd_ack_time = new Date();
		String wav_f = "6133.wav";
		if(ack_t%2 == 0) {
			wav_f = "4577.wav";
		}
		if(ack_t > 0) {
			new PlaySound(wav_f);
		}
	}
	
	public void sendFBS9100Data(int cmd, ByteBuffer bbf_tx) throws IOException {
		ByteBuffer bf_t = FBS9100_ComBuf.makeFbs9100CommBuf(255, cmd, bbf_tx, true);
		byte[] cipher_tx_t = new byte[bf_t.limit()];
		bf_t.get(cipher_tx_t);
		//byte[] bt_t = FBS9100_ComBuf.makeFbs9100CommBuf(21, 0x15, ByteBuffer.allocate(0)).array();
		
		//byte[] cipher_tx_t = new byte[bf_t.limit()];
		//my_aes.ecb_encrypt(plain_tx_t, cipher_tx_t, plain_tx_t.length);
		
		//System.out.println(ComFn.bytesToHexString(plain_tx_t, plain_tx_t.length));
		outputStream.write(cipher_tx_t);
	    if(++comm_tx_cnt > 1000000) {
	    	comm_tx_cnt = 0;
	    }
	}
	
	public void run() {
		while(true == CommThreadRunning) {
			try {
				if(false == dt_dfu_en) {
					//sendMsg(makeCommTxData());
					//readMsg(CommRxBuffer);
					CommTxBuffer.clear();
					CommTxBuffer.put(makeCommTxData());
					CommTxBuffer.flip();
					tr_Msg(CommTxBuffer, CommRxBuffer, true);
					byte[] cipher_buf = new byte[CommRxBuffer.limit()];
					//byte[] plain_buf = new byte[CommRxBuffer.limit()];
					CommRxBuffer.get(cipher_buf);
					//my_aes.ecb_decrypt(cipher_buf, plain_buf, cipher_buf.length);
					//System.out.println("RX:" + ComFn.bytesToHexString(cipher_buf, cipher_buf.length));
					//System.out.println(ComFn.bytesToHexString(plain_buf, plain_buf.length));
					getDataFromCommBuf(cipher_buf);
					
					Thread.sleep(500);
				} 
				/*else {
					//--------------------------- BOOTLOADER_CMD_WRITE-----------------------------//
					String dfu_text_inf = "FBS9100S DFU Start.";
					dt_show_msg.setText(dfu_text_inf);
					boolean prog_ok = false;
					FileInputStream fis = null;
					try {
						File f = new File(dt_dfuFileName);
						long file_len = f.length();
						byte[] buf_to_flash = new byte[FBS9100_DFU.DFU_BUF_LEN];
						
						Thread.sleep(100);
						fis = new FileInputStream(f);
						int dfu_datablock_num = 1;
						int percent = 0;
						while(true)
						{
							//====================================//
							if((false == dt_dfu_en) || (false == CommThreadRunning)) {
								dfu_text_inf = "DFU Manual Stop . . .";
								dt_show_msg.setText(dfu_text_inf);
								break;
							}
							//====================================//
							for(int n=0; n<buf_to_flash.length; n++) {
								buf_to_flash[n] = (byte) 0xFF;
							}
							//====================================//
							int data_len_towrite = fis.read(buf_to_flash);
							if(data_len_towrite > 0) {
								Thread.sleep(1);
								for(int cnt_t=0; cnt_t<3; cnt_t++) {
									sendFBS9100Data(FBS9100_ComBase.CMD_FBS9100_WriteDFU, 
													m_FBS9100_DFU.getWriteByteBuffer(dfu_datablock_num, buf_to_flash, data_len_towrite));
									readMsg(FBS9100RxBuffer);
									byte[] cipher_buf = new byte[FBS9100RxBuffer.limit()];
									byte[] plain_buf = new byte[FBS9100RxBuffer.limit()];
									FBS9100RxBuffer.get(cipher_buf);
									my_aes.ecb_decrypt(cipher_buf, plain_buf, cipher_buf.length);
									//System.out.println(ComFn.bytesToHexString(plain_buf, plain_buf.length));
									FBS9100RxBuffer.position(0);
									FBS9100RxBuffer.put(plain_buf);
									FBS9100RxBuffer.flip();
									if(true == m_FBS9100_DFU.checkDfuWriteAckBuf(FBS9100RxBuffer)) {
										if(m_FBS9100_DFU.DataBlockIndex == dfu_datablock_num) {
											prog_ok = true;
											break;
										}
									} else {
										prog_ok = false;
										Thread.sleep(500);
									}
								}
								if(false == prog_ok) {
									dfu_text_inf = "DFU Write Error!";
									dt_show_msg.setText(dfu_text_inf);
									break;
								} else {
									dfu_datablock_num += 1;
								}
								
								int tran_len_t = dfu_datablock_num*FBS9100_DFU.DFU_BUF_LEN;
								if(percent < (tran_len_t*100)/file_len) {
									percent = (int) ((tran_len_t*100)/file_len);
									if(percent > 100) {
										percent = 100;
									}
									dt_show_msg.setText(String.format("DFU Write: %d%% Done.\n", percent));
								}
							} else {
								dfu_text_inf = "DFU Write: 100% Done!\n";
								dt_show_msg.setText(dfu_text_inf);
								System.out.println(dfu_text_inf);
								break;
							}
						}
					} catch (IOException | InterruptedException e1) {
						// TODO Auto-generated catch block
						e1.printStackTrace();
					} finally {
						try {
							fis.close();
						} catch (IOException e1) {
							// TODO Auto-generated catch block
							e1.printStackTrace();
						}
					}
					
					if((true == prog_ok) && (true == dt_dfu_en) && (true == CommThreadRunning)) {
						boolean check_ok = false;
						FileInputStream fis_ck = null;
						try {
							File f_ck = new File(dt_dfuFileName);
							long file_len_ck = f_ck.length();
							byte[] buf_check = new byte[FBS9100_DFU.DFU_BUF_LEN];
							
							Thread.sleep(100);
							fis_ck = new FileInputStream(f_ck);
							int check_datablock_num = 1;
							int percent = 0;
							while(true)
							{
								//====================================//
								if((false == dt_dfu_en) || (false == CommThreadRunning)) {
									dfu_text_inf = "DFU Check Manual Stop . . .";
									dt_show_msg.setText(dfu_text_inf);
									break;
								}
								//====================================//
								for(int n=0; n<buf_check.length; n++) {
									buf_check[n] = (byte) 0xFF;
								}
								//====================================//
								int len_buf_check = fis_ck.read(buf_check);
								if(len_buf_check > 0) {
									Thread.sleep(1);
									for(int cnt_t=0; cnt_t<3; cnt_t++) {
										sendFBS9100Data(FBS9100_ComBase.CMD_FBS9100_ReadDFU, 
														m_FBS9100_DFU.getReadByteBuffer(check_datablock_num, len_buf_check));
										readMsg(FBS9100RxBuffer);
										
										byte[] cipher_buf = new byte[FBS9100RxBuffer.limit()];
										byte[] plain_buf = new byte[FBS9100RxBuffer.limit()];
										FBS9100RxBuffer.get(cipher_buf);
										my_aes.ecb_decrypt(cipher_buf, plain_buf, cipher_buf.length);
										
										FBS9100RxBuffer.position(0);
										FBS9100RxBuffer.put(plain_buf);
										FBS9100RxBuffer.flip();
										if(true == m_FBS9100_DFU.checkDfuReadAckBuf(FBS9100RxBuffer)) {
											if(m_FBS9100_DFU.DataBlockIndex == check_datablock_num) {
												byte[] s_buf = new byte[len_buf_check];
												FBS9100RxBuffer.get(s_buf);
												check_ok = true;
												for(int cn=0; cn<len_buf_check; cn++) {
													if(buf_check[cn] != s_buf[cn]) {
														check_ok = false;
														break;
													}
												}
											}
										} else {
											check_ok = false;
											Thread.sleep(500);
										}
										if(true == check_ok) {
											break;
										}
									}
									if(false == check_ok) {
										dfu_text_inf = "DFU File Check Error!";
										dt_show_msg.setText(dfu_text_inf);
										break;
									} else {
										check_datablock_num += 1;
									}
									
									int tran_len_t = check_datablock_num*FBS9100_DFU.DFU_BUF_LEN;
									if(percent < (tran_len_t*100)/file_len_ck) {
										percent = (int) ((tran_len_t*100)/file_len_ck);
										if(percent > 100) {
											percent = 100;
										}
										dt_show_msg.setText(String.format("DFU File Check: %d%% Done.\n", percent));
									}
								} else {
									dfu_text_inf = "DFU File Check: 100% Done!\n";
									dt_show_msg.setText(dfu_text_inf);
									break;
								}
							}
						} catch (IOException | InterruptedException e1) {
							// TODO Auto-generated catch block
							e1.printStackTrace();
						} finally {
							try {
								fis_ck.close();
							} catch (IOException e1) {
								// TODO Auto-generated catch block
								e1.printStackTrace();
							}
						}
					}
					//---------------------------------------------------------------------------------//
					dt_dfu_en = false;
					//---------------------------------------------------------------------------------//
				}*/
	    	} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
				exitCommPortThread();
				JOptionPane.showMessageDialog(null, "BTS ÉÏλ»ú´®¿ÚÒì³£: " + e.getMessage());
			}
		}
		/******************************************/
		closeCommPort();
		/******************************************/
		System.out.println("BTS CommPort is quit!");
    }
	/*********************************************************************************************/
	/*********************************************************************************************/
	/*********************************************************************************************/
	/*********************************************************************************************/
	public String getDataFromCommBuf(final byte[] bytes)
  	{
		boolean comm_res = false;
		ByteBuffer bf = ByteBuffer.allocate(bytes.length);
        bf.order(ByteOrder.LITTLE_ENDIAN);
        bf.put(bytes);
        bf.flip();
		
		String msg = "";
		if(true == m_FBS_Cmd.putByteBuffer(bf))
        {
			//------------------- ¶ÁÈ¡FBS9100µçѹµçÁ÷Êý¾Ý --------------------
	        if(FBS9100_ComBase.CMD_GetVIData == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_FBS_VCData.m_SysState.putByteBuffer(bf))
		        {
		        	if(true == m_FBS_VCData.putByteBuffer(bf, 0x08, this.dev_stat_version)) {
		        		comm_res = true;
		        	}
		        }
	        }
	        //------------------- ¶ÁÈ¡FBS9100ÄÚ×è²âÊÔ״̬ -----------------------
	        if(FBS9100_ComBase.CMD_GetResTestState == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_ResTestState.putByteBuffer(bf)) {
	        		comm_res = true;
		        	msg = "Get ResTest State from FBS9100 OK!!!";
	        	}
	        }
	        //------------------- ¶ÁÈ¡FBS9100ÈÝÁ¿²âÊÔ״̬ -----------------------
	        if(FBS9100_ComBase.CMD_GetDischargeState == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_CapTestState.putByteBuffer(bf)) {
	        		comm_res = true;
		        	msg = "Get CapTest State from FBS9100 OK!!!";
	        	}
	        }
	        //------------------- ¶ÁÈ¡FBS9100³äµç²âÊÔ״̬ -----------------------
	        if(FBS9100_ComBase.CMD_GetChargeState == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_ChrTestState.putByteBuffer(bf)) {
	        		comm_res = true;
		        	msg = "Get ChrTest State from FBS9100 OK!!!";
	        	}
	        }
	        //------------------- ¶ÁÈ¡FBS9100µç³Ø²ÎÊý -------------------------
	        else if(FBS9100_ComBase.CMD_GetBattParam == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_FBS_BattParam.putByteBuffer(bf)) {
	        		comm_res = true;
	        		msg = "Get battparam from FBS9100 OK!!!";
	        	}
	        }
	        //------------------- ÉèÖÃFBS9100µç³Ø²ÎÊý -------------------------
	        else if(FBS9100_ComBase.CMD_SetBattParam == m_FBS_Cmd.CMD) {
	        	if(true == m_FBS_BattParam.putByteBuffer(bf)) {
	        		comm_res = true;
	        		msg = "Set battparam to FBS9100 OK!!!";
	        	}
	        }
	        //------------------- ¶ÁÈ¡FBS9100ϵͳ²ÎÊý -------------------------
	        else if(FBS9100_ComBase.CMD_GetSYSSetParam == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_FBS_SystemParam.putByteBuffer(bf)) {
	        		comm_res = true;
	        		msg = "Get sysparam from FBS9100 OK!!!";
	        	}
	        }
	        //------------------- ÉèÖÃFBS9100ϵͳ²ÎÊý -------------------------
	        else if(FBS9100_ComBase.CMD_SetSYSSetParam == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_FBS_SystemParam.putByteBuffer(bf)) {
	        		comm_res = true;
	        		msg = "Set sysparam to FBS9100 OK!!!";
	        	}
	        }
	        //------------------- ¶ÁÈ¡FBS9100·Åµç²ÎÊý -------------------------
	        else if(FBS9100_ComBase.CMD_GetDischargeParm == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_FBS_DiscParamFromDev.putByteBuffer(bf)) {
	        		comm_res = true;
	        		msg = "Get DischargeParm from FBS9100 OK!!!";
	        	}
	        }
	        //------------------- ÉèÖÃFBS9100·Åµç²ÎÊý -------------------------
	        else if(FBS9100_ComBase.CMD_SetDischargeParm == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_FBS_DiscParam.putByteBuffer(bf)) {
	        		comm_res = true;
	        		msg = "Set DischargeParam to FBS9100 OK!!!";
	        	}
	        }
	        //------------------- ¶ÁÈ¡FBS9100³äµç²ÎÊý -------------------------
	        else if(FBS9100_ComBase.CMD_GetChargeParm == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_FBS_ChargeParam.putByteBuffer(bf)) {
	        		comm_res = true;
	        		msg = "Get ChargeParam from FBS9100 OK!!!";
	        	}
	        }
	        //------------------- ÉèÖÃFBS9100³äµç²ÎÊý -------------------------
	        else if(FBS9100_ComBase.CMD_SetChargeParm == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_FBS_ChargeParam.putByteBuffer(bf)) {
	        		comm_res = true;
	        		msg = "Set ChargeParam to FBS9100 OK!!!";
	        	}
	        }
	        //------------------- ¶ÁÈ¡FBS9100ÈÝÁ¿ÄÚ×è²âÊÔÊý¾Ý ------------------
	        else if((FBS9100_ComBase.CMD_GetMonomerRES == m_FBS_Cmd.CMD)
	        		||(FBS9100_ComBase.CMD_GetMonomerTMP == m_FBS_Cmd.CMD))
	        {
	        	if(true == m_FBS_ResCapData.putByteBuffer(bf, m_FBS_Cmd.CMD)) {
	        		comm_res = true;
	        		msg = "Get MonomerCAP or MonomerRES from FBS9100 OK!!!";
	        	}
	        }
	        else if(FBS9100_ComBase.CMD_GetDeviceInf == m_FBS_Cmd.CMD) {
	        	FBS9100_DeviceInf deviceinf = new FBS9100_DeviceInf();
	        	if(true == deviceinf.putByteBuffer(bf)) {
	        		comm_res = true;
	        		m_BTSDevSoftType = deviceinf.DeviceType;
	        		dev_stat_version = deviceinf.SoftwareVersion;
	        		dev_stat_version_Str = String.format("V%d.%02d.%02d", 
	        										deviceinf.DeviceVersion,
	        										deviceinf.HardwareVersion,
	        										deviceinf.SoftwareVersion);
	        		//System.out.println(dev_stat_version_Str);
	        		msg = "Get CMD_GetDeviceInf From FBS9100 OK: " + dev_stat_version_Str;
	        	}
	        } 
	        //------------------- ¶ÁÈ¡FBS9100ÈÎÎñÁбí -------------------------
	        else if(FBS9100_ComBase.CMD_GetDeviceTaskInf == m_FBS_Cmd.CMD)
	        {
	        	comm_res = true;
	        	m_TaskList = (bf);
	        	msg = "Get CMD_GetDeviceTaskInf From FBS9100 OK!!!";
	        }
        }
		
		if(true == comm_res) {
			if(++comm_rx_cnt > 1000000) {
		    	comm_rx_cnt = 0;
		    }
		}
		
		return msg;
	}
	/*********************************************************************************************/
}