修改bug

liurunyu

2025-08-06 cc28bd9c4787bad65ec66635e3d9c60861a5f225

 pipIrr-platform/pipIrr-mw/pipIrr-mw-simulate-rtu/src/main/java/com/dy/simRtu/tcpClient/upData/UpData.java

New file
@@ -0,0 +1,76 @@
package com.dy.simRtu.tcpClient.upData;

import com.dy.common.mw.protocol.p206V1.ProtocolConstantV206V1;
import com.dy.common.mw.protocol.p206V1.parse.global.GlCreate;
import com.dy.common.util.ByteUtil;
import org.apache.mina.core.session.IoSession;

/**
 * @Author: liurunyu
 * @Date: 2024/7/15 14:20
 * @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[ProtocolConstantV206V1.lenHead2Code] ;
        byte index = 0 ;
        bsHead[index] = ProtocolConstantV206V1.P_Head_Byte ;

        index++ ;
        bsHead[index] = 0 ;//帧长度

        index++ ;
        bsHead[index] = ProtocolConstantV206V1.P_Head_Byte ;

        index++ ;
        bsHead[index] = ctrl; //控制域功能码

        index++ ;
        GlCreate.createRtuAddr4P206(rtuAddr, bsHead, index);
        index += 5 ;

        ByteUtil.hex2Bytes(code, bsHead, index) ;

        return bsHead ;
    }

    protected static byte[] creatHead4Upgrade(String rtuAddr, String preCode, String sufCode)throws Exception {
        byte[] bsHead = new byte[12] ;
        byte index = 0 ;
        bsHead[index] = ProtocolConstantV206V1.UG_P_Head_Byte ;

        index++ ;
        bsHead[index] = 0 ;//帧长度
        index++ ;
        bsHead[index] = 0 ;//帧长度

        index++ ;
        bsHead[index] = ProtocolConstantV206V1.UG_P_Head_Byte ;

        index++ ;
        bsHead[index] = ByteUtil.hex2Bytes(preCode)[0]; //功能码域

        index++ ;
        bsHead[index] = ByteUtil.hex2Bytes(sufCode)[0]; //功能码域

        index++ ;
        GlCreate.createRtuAddr4P206(rtuAddr, bsHead, index);

        return bsHead ;
    }
}