完善代码

liurunyu

2025-08-21 ceee4240e066c092aa0a2b5b96773fb9508a3613

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
52
53
54
55
56
57
58
59
60
package com.dy.simRtu.tcpClient.upData;
 
import com.dy.common.mw.protocol.p206V1.parse.global.GlCreate;
import com.dy.common.util.ByteUtil;
import com.dy.common.util.ByteUtilUnsigned;
import com.dy.simRtu.ServerProperties;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
 
/**
 * @Author: liurunyu
 * @Date: 2025/5/8 8:29
 * @Description
 */
public class UpCd66 extends UpData {
 
    private static final Logger log = LogManager.getLogger(UpCd66.class);
 
    public static void upData() {
        try {
            if (UpData.session != null && UpData.session.isConnected()) {
                byte[] bs = createData(ServerProperties.rtuAddr);
                UpData.upSend(bs);
            } else {
                log.error("未连接通信中间件，不能发送数据");
            }
        } catch (Exception e) {
            log.error("向通信中间件发送数据产生异常", e);
        }
    }
 
 
    /**
     * 构造数据
     *
     * @return 字节数组
     * @throws Exception 异常
     */
    private static byte[] createData(String rtuAddr) throws Exception {
        byte[] bytes = creatHead(rtuAddr, "66",(byte)0xB0);
 
        byte[] bs = new byte[6];
        bs[0] = (byte) 100;
        bs[1] = (byte) 101;
        bs[2] = (byte) 102;
        bs[3] = (byte) 103;
 
        ByteUtilUnsigned.short2Bytes_BE(bs,1234, 4);
 
        bytes = ByteUtil.bytesMerge(bytes, bs);
 
        GlCreate.createLen(bytes);//长度放字节数组中
 
        byte[] bsTail = GlCreate.createCrcTail4P206(bytes);//CRC和尾叠加字节数组中
 
        bytes = ByteUtil.bytesMerge(bytes, bsTail);
 
        return bytes;
    }
}