添加汇集器通讯逻辑

whyclj

2019-11-11 dd4d4e91cdfb9806155d7dedca8907ef4fb67ae7

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
package com.concentrator; 
 
import com.util.ComBase; 
import com.util.Crc16; 
 
import java.nio.ByteBuffer; 
import java.nio.ByteOrder; 
import java.util.Random; 
 
 
public class Concentrator_ComBuf { 
    public static Concentrator_Cmd m_CMD = new Concentrator_Cmd(); 
 
    public Concentrator_Cmd getTmpSensorCmd() 
    { 
        return this.m_CMD; 
    } 
 
    public boolean putByteBuffer(final ByteBuffer bf) 
    { 
        if(false == m_CMD.putByteBuffer(bf)) 
            return false; 
 
        return true; 
    } 
 
    /** 
     * 构造发送的数据包 
     * @param bf 
     * @return 
     */ 
    public static ByteBuffer makeTmpSensorCommBuf(Concentrator_Cmd m_CMD ,ByteBuffer bf) 
    { 
        ByteBuffer buffer = ByteBuffer.allocate(m_CMD.BYTE_LEN + bf.limit()+2);                        //数据总长度 
        buffer.order(ByteOrder.BIG_ENDIAN);            //设置ByteBuffer的字节序 
 
        //m_CMD.makeCmd(addr, cmd,reg_index,getByteCountByReg(reg_index)); 
 
        buffer.put(m_CMD.getByteBuffer()); 
        buffer.put(bf); 
 
        int CRC = Crc16.CalCRC16(buffer, buffer.position()); 
        buffer.putShort(ComBase.changeIntToShort(CRC)); 
        buffer.flip(); 
        return buffer; 
    } 
 
    /*************************************************************************************** 
     ****************************** end of file (FBS_ComBuf) ******************************** 
     ***************************************************************************************/ 
}