package com.dy.pipIrrMwTestRtu.tcpClient.upData;
|
|
import com.dy.common.mw.protocol.p206V1.parse.global.GlCreate;
|
import com.dy.common.util.ByteUtil;
|
import com.dy.pipIrrMwTestRtu.ServerProperties;
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
|
/**
|
* @Author: liurunyu
|
* @Date: 2024/7/15 14:58
|
* @Description
|
*/
|
public class UpCd83Open extends UpData {
|
|
private static final Logger log = LogManager.getLogger(UpCd83Open.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, "83", (byte)0xB0);
|
|
byte[] bs = new byte[1] ;
|
bs[0] = (byte)0x01 ;//刷卡开阀
|
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[5] ;//累计流量
|
ByteUtil.int2BCD_LE(UpConstant.totalAmount, bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[8] ;//IC卡编号
|
GlCreate.createIcCardNo(ServerProperties.icCardNo, bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[4] ;//IC卡地址
|
ByteUtil.hex2Bytes_LE(ServerProperties.icCardAddr, bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[4] ;//用水户余额
|
ByteUtil.int2BCD_LE(UpConstant.remainMoney, bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[6] ;//开阀时间
|
GlCreate.createTp(UpConstant.openValveDt(), bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[6] ;//控制器时钟
|
GlCreate.createTp(bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
GlCreate.createLen(bytes);//长度放字节数组中
|
|
byte[] bsTail = GlCreate.createCrcTail4P206(bytes) ;//CRC和尾叠加字节数组中
|
|
bytes = ByteUtil.bytesMerge(bytes, bsTail) ;
|
|
return bytes ;
|
}
|
}
|
