修改bug

liurunyu

2025-08-20 9a7978c3a82ce66c87be2a42ca15beeb4617a096

 pipIrr-platform/pipIrr-mw/pipIrr-mw-simulate-rtu202404/src/main/java/com/dy/simRtu202404/tcpClient/upData/UpOpenCloseValve.java

New file
@@ -0,0 +1,214 @@
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 ;
    }

}