package com.dev_concentrator.data;
|
|
import java.nio.ByteBuffer;
|
import java.nio.ByteOrder;
|
import java.util.Arrays;
|
|
import com.battmonitor.base.ComBase;
|
import com.battmonitor.base.Crc16;
|
import com.dev.btse.data.ComFn;
|
import com.dev.btse.data.FBS9100_ComBase;
|
|
public class Concentrator_Cmd
|
{
|
public final int BYTE_LEN = 6;
|
|
public int ADDR; //ͨѶµØÖ·
|
public int ByteCount; //¼Ä´æÆ÷ÊýÄ¿
|
public int CMD; //¹¦ÄÜÂë
|
public int RES_Index; //¼Ä´æÆ÷Æ«ÒÆÎ»ÖÃ
|
public int Result_val; //·µ»Ø½á¹û
|
private int CRC;
|
|
public void makeCmd(int addr, int cmd,int RES_Index, int bytecount)
|
{
|
this.ADDR = addr;
|
this.ByteCount = bytecount;
|
this.CMD = cmd;
|
this.RES_Index = RES_Index;
|
}
|
|
public boolean putByteBuffer(final ByteBuffer bf)
|
{
|
if(bf.limit() < BYTE_LEN)
|
return false;
|
|
ByteBuffer tmpbuf = bf;
|
int crc0 = tmpbuf.getShort(bf.limit()-2) & 0xFFFF;
|
int crc1 = Crc16.CalCRC16(tmpbuf, bf.limit()-2) & 0xFFFF;
|
if(crc0 != crc1) {
|
System.err.println("CRC error "+crc0+"==="+crc1);
|
return false;
|
}
|
tmpbuf.position(0);
|
//System.out.println(ComFn.bytesToHexString(tmpbuf.array(), tmpbuf.array().length));
|
this.ADDR = FBS9100_ComBase.changeByteToInt(tmpbuf.get());
|
this.CMD = FBS9100_ComBase.changeByteToInt(tmpbuf.get());
|
if(this.ADDR >= Concentrator_SocketThread.GroupVolModel_Addr) {
|
RES_Index = 0x0010;
|
//¶ÁÈ¡µÄ×éѹģ¿éµÄÐÅÏ¢
|
if(CMD == Concentrator_ComBase.CMD_MODEBUS_READCMD) {
|
ByteCount = FBS9100_ComBase.changeByteToInt(tmpbuf.get());
|
Result_val = FBS9100_ComBase.changeShortToInt(tmpbuf.getShort());
|
}
|
}else {
|
RES_Index = FBS9100_ComBase.changeShortToInt(tmpbuf.getShort());
|
if(CMD == Concentrator_ComBase.CMD_MODEBUS_READCMD) {
|
ByteCount = FBS9100_ComBase.changeByteToInt(tmpbuf.get());
|
}else {
|
Result_val = FBS9100_ComBase.changeShortToInt(tmpbuf.getShort());
|
}
|
}
|
//ByteCount = FBS9100_ComBase.changeShortToInt(tmpbuf.getShort());
|
tmpbuf.compact();
|
tmpbuf.flip();
|
|
return true;
|
}
|
|
public ByteBuffer getByteBuffer()
|
{
|
ByteBuffer bytebuffer = ByteBuffer.allocate(BYTE_LEN);
|
bytebuffer.order(ByteOrder.BIG_ENDIAN);
|
bytebuffer.put(ComBase.changeIntToByte(ADDR));
|
bytebuffer.put(ComBase.changeIntToByte(CMD));
|
bytebuffer.putShort(ComBase.changeIntToShort(RES_Index));
|
bytebuffer.putShort(ComBase.changeIntToShort(ByteCount));
|
|
bytebuffer.flip();
|
return bytebuffer;
|
}
|
|
public ByteBuffer getControlByteBuffer()
|
{
|
ByteBuffer bytebuffer = ByteBuffer.allocate(2);
|
bytebuffer.order(ByteOrder.BIG_ENDIAN);
|
bytebuffer.putShort(ComBase.changeIntToShort(1));
|
bytebuffer.flip();
|
return bytebuffer;
|
}
|
|
@Override
|
public String toString() {
|
return "TmpSensor_Cmd [BYTE_LEN=" + BYTE_LEN + ", ADDR=" + ADDR + ", ByteCount=" + ByteCount + ", CMD=" + CMD
|
+ ", RES_Index=" + RES_Index + ", CRC=" + CRC + "]";
|
}
|
}
|
/***************************************************************************************
|
******************************** end of file (FBS_Cmd) *********************************
|
***************************************************************************************/
|