From c2976b80e8850be2d28dc2132c6659856b871f3c Mon Sep 17 00:00:00 2001 From: zhubaomin <zhubaomin> Date: 星期四, 08 五月 2025 21:10:42 +0800 Subject: [PATCH] Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV --- pipIrr-platform/pipIrr-mw/pipIrr-mw-simulate-rtu202404/src/main/java/com/dy/simRtu202404/tcpClient/upData/UpData.java | 52 ++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 52 insertions(+), 0 deletions(-) diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-simulate-rtu202404/src/main/java/com/dy/simRtu202404/tcpClient/upData/UpData.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-simulate-rtu202404/src/main/java/com/dy/simRtu202404/tcpClient/upData/UpData.java new file mode 100644 index 0000000..940e79f --- /dev/null +++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-simulate-rtu202404/src/main/java/com/dy/simRtu202404/tcpClient/upData/UpData.java @@ -0,0 +1,52 @@ +package com.dy.simRtu202404.tcpClient.upData; + +import com.dy.common.mw.protocol.p206V202404.ProtocolConstantV206V202404; +import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; +import com.dy.common.util.ByteUtil; +import org.apache.mina.core.session.IoSession; + +/** + * @Author: liurunyu + * @Date: 2025/02/26 11:10 + * @Description + */ +public class UpData { + + protected static IoSession session ; + + private static Object synObj = new Object() ; + + public static void setSession(IoSession session){ + UpData.session = session ; + } + + protected static void upSend(byte[] bs) throws Exception{ + synchronized (synObj){ + session.write(bs) ; + } + } + + protected static byte[] creatHead(String rtuAddr, String code, byte ctrl)throws Exception { + byte[] bsHead = new byte[ProtocolConstantV206V202404.lenHead2Code] ; + byte index = 0 ; + bsHead[index] = ProtocolConstantV206V202404.P_Head_Byte ; + + index++ ; + bsHead[index] = 0 ;//甯ч暱搴� + + index++ ; + bsHead[index] = ProtocolConstantV206V202404.P_Head_Byte ; + + index++ ; + bsHead[index] = ctrl; //鎺у埗鍩熷姛鑳界爜 + + index++ ; + GlCreate.createRtuAddr(rtuAddr, bsHead, index); + index += 8 ; + + ByteUtil.hex2Bytes(code, bsHead, index) ; + + return bsHead ; + } + +} -- Gitblit v1.8.0