package com.dy.simRtu202404.tcpClient.upData;
|
|
import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate;
|
import com.dy.common.util.ByteUtil;
|
import com.dy.common.util.DateTime;
|
import com.dy.simRtu202404.ServerProperties;
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
|
/**
|
* @Author: liurunyu
|
* @Date: 2025/2/26 11:42
|
* @Description
|
*/
|
public class UpOpenCloseValve extends UpData {
|
|
private static final Logger log = LogManager.getLogger(UpOpenCloseValve.class) ;
|
|
private static String orderNo = null ;
|
private static String openValveDt = null ;
|
|
private static Double totalWaterAmount = 12345.67 ;//累计流量
|
private static Double remainMoney = 8765.4321 ;//剩余金额
|
|
private static Double thisWaterAmount = 100.00 ;//本次使用水量
|
private static Double thisMoney = 10.00 ;//本次使用金额
|
|
public static void upCd84Data(String rtuAddr){
|
try{
|
if(UpData.session != null && UpData.session.isConnected()){
|
byte[] bs = createCd84Data(rtuAddr) ;
|
UpData.upSend(bs) ;
|
}else{
|
log.error("未连接通信中间件，不能发送数据");
|
}
|
}catch (Exception e){
|
log.error("向通信中间件发送数据产生异常", e);
|
}
|
}
|
|
public static void upCd85Data(String rtuAddr){
|
try{
|
if(UpData.session != null && UpData.session.isConnected()){
|
byte[] bs = createCd85Data(rtuAddr) ;
|
UpData.upSend(bs) ;
|
}else{
|
log.error("未连接通信中间件，不能发送数据");
|
}
|
}catch (Exception e){
|
log.error("向通信中间件发送数据产生异常", e);
|
}
|
}
|
|
|
/**
|
* 构造开阀数据
|
* @return 字节数组
|
* @throws Exception 异常
|
*/
|
private static byte[] createCd84Data(String rtuAddr) throws Exception {
|
orderNo = DateTime.yyyyMMddHHmmss() + "00" ;
|
openValveDt = DateTime.yyMMddhhmmss() ;
|
|
byte[] bytes = creatHead(rtuAddr, "84", (byte)0x81);
|
|
byte[] bs = new byte[]{(byte)0x02} ;//0x02:表阀一体机
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[]{(byte)0x0A} ;//项目编号
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[]{(byte)0xF0} ;//0xf0:阀门 0x00:水泵
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[]{(byte)0x00} ;//0x00:正常刷卡开泵/阀用水
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[4] ;//用户IC卡号 4字节HEX码(远程开泵/阀时此数据为0)
|
GlCreate.createIcCardAddr(ServerProperties.icCardAddr, bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[8] ;//用户序列号 8字节 6字节BCD:行政编号 2字节HEX:用户编号
|
GlCreate.createIcCardNo(ServerProperties.icCardNo, bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[8] ;//本次订单号 8字节 BCD码
|
ByteUtil.string2BCD_BE( bs, orderNo,0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[6] ;//开泵/阀时间 6字节的BCD码(秒分时日月年)
|
ByteUtil.string2BCD_LE( bs, openValveDt,0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[5] ;//水表累计水量 5字节BCD码，单位0.01立方米
|
ByteUtil.int2BCD_LE(Double.valueOf(totalWaterAmount * 100).intValue(), bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[5] ;//电表累计电量 5字节BCD码，单位0.01度
|
ByteUtil.int2BCD_LE(0, bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[5] ;//用户剩余金额 5字节BCD码， 单位0.0001元
|
ByteUtil.int2BCD_LE(Double.valueOf(remainMoney * 10000).intValue(), bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[5] ;//用户剩余水量 5字节BCD码， 单位0.01m3
|
ByteUtil.int2BCD_LE(0, bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[4] ;//机井/阀状态及报警信息 4字节HEX码 定义见表41
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
|
GlCreate.createLen(bytes);//长度放字节数组中
|
|
byte[] bsTail = GlCreate.createCrcTail(bytes) ;//CRC和尾叠加字节数组中
|
|
bytes = ByteUtil.bytesMerge(bytes, bsTail) ;
|
|
return bytes ;
|
}
|
|
/**
|
* 构造关阀数据
|
* @return 字节数组
|
* @throws Exception 异常
|
*/
|
private static byte[] createCd85Data(String rtuAddr) throws Exception {
|
if(orderNo == null){
|
orderNo = DateTime.yyyyMMddHHmmss() + "00" ;
|
}
|
if(openValveDt == null){
|
openValveDt = DateTime.yyMMddhhmmss() ;
|
}
|
|
totalWaterAmount += thisWaterAmount ;
|
remainMoney -= thisMoney ;
|
|
byte[] bytes = creatHead(rtuAddr, "85", (byte)0x81);
|
|
byte[] bs = new byte[]{(byte)0x02} ;//0x02:表阀一体机
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[]{(byte)0x0A} ;//项目编号
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[]{(byte)0x01} ;//关泵/阀方式 0x00:刷卡闭 0x01:平台关 0x02:APP关 0x03:非法卡关 0x04:水表通讯异常关 0x05:电表异常关 0x06:剩余水量不足关 0x07:剩余金额为0关 0x08:开泵/阀后管道没有流量关 0x09:掉电再上电关，0x0a:水表瞬时流量为0关，0x0b:刷卡开泵，远程关。0x0c:电池低电压关。
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[4] ;//用户IC卡号 4字节HEX码(远程开泵/阀时此数据为0)
|
GlCreate.createIcCardAddr(ServerProperties.icCardAddr, bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[8] ;//用户序列号 8字节 6字节BCD:行政编号 2字节HEX:用户编号
|
GlCreate.createIcCardNo(ServerProperties.icCardNo, bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[8] ;//本次订单号 8字节 BCD码
|
ByteUtil.string2BCD_BE( bs, orderNo,0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[6] ;//开始时间 6字节的BCD码(秒分时日月年)
|
ByteUtil.string2BCD_LE( bs, openValveDt,0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[6] ;//结束时间 6字节的BCD码(秒分时日月年)
|
ByteUtil.string2BCD_LE( bs, DateTime.yyMMddhhmmss(),0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[5] ;//水表累计水量 5字节BCD码，单位0.01立方米
|
ByteUtil.int2BCD_LE(Double.valueOf(totalWaterAmount * 100).intValue(), bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[5] ;//电表累计电量 5字节BCD码，单位0.01度
|
ByteUtil.int2BCD_LE(0, bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[5] ;//用户剩余金额 5字节BCD码， 单位0.0001元
|
ByteUtil.int2BCD_LE(Double.valueOf(remainMoney * 10000).intValue(), bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[5] ;//用户剩余水量 5字节BCD码， 单位0.01m3
|
ByteUtil.int2BCD_LE(0, bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[4] ;//本次使用电量 4字节BCD码 单位0.01度
|
ByteUtil.int2BCD_LE(0, bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[4] ;//本次使用水量 4字节BCD码 单位0.01立方米
|
ByteUtil.int2BCD_LE(Double.valueOf(thisWaterAmount * 100).intValue(), bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[4] ;//本次使用金额 4字节BCD码 单位0.0001元
|
ByteUtil.int2BCD_LE(Double.valueOf(thisMoney * 10000).intValue(), bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[2] ;//本次使用时间长 2字节BCD码 单位：分钟
|
ByteUtil.int2BCD_LE(10, bs, 0);
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
bs = new byte[4] ;//机井/阀状态及报警信息 4字节HEX码 定义见表41
|
bytes = ByteUtil.bytesMerge(bytes, bs) ;
|
|
GlCreate.createLen(bytes);//长度放字节数组中
|
|
byte[] bsTail = GlCreate.createCrcTail(bytes) ;//CRC和尾叠加字节数组中
|
|
bytes = ByteUtil.bytesMerge(bytes, bsTail) ;
|
|
return bytes ;
|
}
|
|
}
|
