| New file |
| | |
|---|
| | | package com.dy.pipIrrMwTestRtu.tcpClient.upData; |
|---|
| | | |
|---|
| | | import com.dy.common.mw.protocol.p206V1.parse.global.GlCreate; |
|---|
| | | import com.dy.common.util.ByteUtil; |
|---|
| | | import org.apache.logging.log4j.LogManager; |
|---|
| | | import org.apache.logging.log4j.Logger; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @Author: liurunyu |
|---|
| | | * @Date: 2024/7/15 14:18 |
|---|
| | | * @Description |
|---|
| | | */ |
|---|
| | | public class UpHeartBeat extends UpData { |
|---|
| | | |
|---|
| | | private static final Logger log = LogManager.getLogger(UpHeartBeat.class) ; |
|---|
| | | |
|---|
| | | public static void upCd02Data(String rtuAddr){ |
|---|
| | | try{ |
|---|
| | | if(UpData.session != null && UpData.session.isConnected()){ |
|---|
| | | byte[] bs = createData(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, "02", (byte)0xB0); |
|---|
| | | |
|---|
| | | byte[] bs = new byte[1] ; |
|---|
| | | bs[0] = (byte)0xF2 ;//数据域： 1 个字节，F0 登录， F1 退出登录，F2 在线保持。 |
|---|
| | | |
|---|
| | | bytes = ByteUtil.bytesMerge(bytes, bs) ; |
|---|
| | | |
|---|
| | | GlCreate.createLen(bytes);//长度放字节数组中 |
|---|
| | | |
|---|
| | | byte[] bsTail = GlCreate.createCrcTail4P206(bytes) ;//CRC和尾叠加字节数组中 |
|---|
| | | |
|---|
| | | bytes = ByteUtil.bytesMerge(bytes, bsTail) ; |
|---|
| | | |
|---|
| | | return bytes ; |
|---|
| | | } |
|---|
| | | } |
|---|
