package com.dy.pipIrrMwTestRtu.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 ;
|
}
|
}
|
