Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

zhubaomin

2024-08-21 c0a1e58617d69fa78cceebb27376e57e324a562e

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_C0_Up.java

@@ -1,9 +1,9 @@
package com.dy.common.mw.protocol.p206V1_0_0.parse;


import com.dy.common.mw.protocol.*;
import com.dy.common.mw.protocol.p206V1_0_0.*;
import com.dy.common.mw.protocol.p206V1_0_0.parse.global.GlParse;
import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCdC0Vo;
import com.dy.common.util.ByteUtil;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
@@ -41,9 +41,10 @@

        midRs.reportOrResponse_trueOrFalse = true ;//主动上报

        String confirmComCode = CodeV1_0_1.cd_C0 ;
        String confirmComCode = para.upCode ;
        ParseParamsForDownV1_0_1 downCpParams  = new ParseParamsForDownV1_0_1() ;
        downCpParams.setValue(
                null,
                ProtocolConstantV206V1_0_0.protocolName,
                para.rtuAddr,
                Command.defaultId,
@@ -51,7 +52,7 @@
                null,
                null);
        //构造应答
        byte[] data = new Cd_02_Down().doParse(downCpParams) ;
        byte[] data = new Cd_C0_Down().doParse(downCpParams) ;

        MidResultToRtu confirmCommand = new MidResultToRtu() ;
        confirmCommand.protocolName = para.protocolName ;//协议名称
@@ -62,8 +63,13 @@
        confirmCommand.downBufHex = ByteUtil.bytes2Hex(data, true) ;//下行命令数据十六进制形式
        confirmCommand.hasResponse = false ;//是否有应答
        confirmCommand.maxSendTimes = 1 ;//命令最大发送次数(当收不到应答时，将重发2次)，如果不设置，命令缓存器进行补充设置
        confirmCommand.isSendFirst = true ;//确认命令，优先发送
        confirmCommand.isCachForOffLine = false ;//RTU不在线，命令是否缓存

        confirmCommand.isSendFirst = true ;//确认命令，优先发送
        if(isLowPower != null && isLowPower.booleanValue()){
            //低功耗时，尽快发送
            confirmCommand.isQuickSend = true ;
        }

        callback.callback(midRs.reportOrResponse_trueOrFalse);
        return new MidResult[]{midRs, confirmCommand} ;
@@ -79,24 +85,26 @@
    protected void doParse(byte[] bs, int bsLen, String dataCode, Data data) throws Exception {
        DataV1_0_1 dV1 = (DataV1_0_1)data.getSubData() ;
        DataCdC0Vo cdData = new DataCdC0Vo() ;
        dV1.dataCdC0Vo = cdData ;
        dV1.subData = cdData ;

        boolean hasWaterAmount = false ;//是否有流量数据
        boolean hasWaterPress = false ;//是否有水压数据
        boolean hasEleVolt = false ;//是否有电压数据
        boolean hasSignal = false ;//是否有信号强度数据
        boolean hasAlarmStatus = false ;//是否有数据
        boolean hasWaterAmount = true ;//是否有流量数据
        boolean hasWaterPress = true ;//是否有水压数据
        boolean hasEleVolt = true ;//是否有电压数据
        boolean hasSignal = true ;//是否有信号强度数据
        boolean hasAlarmStatus = true ;//是否有数据

        short index = ProtocolConstantV206V1_0_0.dataIndex ;

        byte tmpBt1 = bs[index] ;
        index++ ;
        /* RTU实现一定有流量数据
        if(((tmpBt1 & 4) >> 2) == 1){
            hasWaterAmount = true ;
        }

        */
        byte tmpBt2 = bs[index] ;
        index++ ;
        /*RTU实现一定有下面各项数据
        if(((tmpBt2 & 0x10) >> 4) == 1){
            hasAlarmStatus = true ;
        }
@@ -109,102 +117,42 @@
        if(((tmpBt2 & 0x80) >> 7) == 1){
            hasSignal = true ;
        }

        */
        if(hasWaterAmount){
            //瞬时流量：5字节BCD码，取值范围0~9999999.999，单位为m3/h。
            cdData.instantAmount = 0.0D ;
            int tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.instantAmount += tpInt/1000.0 ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.instantAmount += tpInt/10.0 ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.instantAmount += tpInt * 10.0 ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.instantAmount += tpInt * 1000.0 ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.instantAmount += tpInt * 100000.0 ;
            int tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 4) ;
            cdData.instantAmount = tpInt/1000.0 ;

            //累计流量：5字节BCD码，取值范围0~9999999999，单位为m3。
            cdData.totalAmount = 0.0D ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.totalAmount += tpInt;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.totalAmount += tpInt * 100.0 ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.totalAmount += tpInt * 10000.0 ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.totalAmount += tpInt * 1000000.0 ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.totalAmount += tpInt * 100000000.0 ;
            index += 5 ;
            //累计流量：5字节BCD码，取值范围0~99999999.99，单位为m3。
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 4) ;
            cdData.totalAmount = tpInt/100.0;

            index += 5 ;
            //损失流量：5字节BCD码，取值范围0~9999999999，单位为m3。
            cdData.lossAmount = 0.0D ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.lossAmount += tpInt;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.lossAmount += tpInt * 100.0 ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.lossAmount += tpInt * 10000.0 ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.lossAmount += tpInt * 1000000.0 ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.lossAmount += tpInt * 100000000.0 ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 4) ;
            cdData.lossAmount = tpInt/100.0;

            index += 5 ;
        }
        if(hasWaterPress){
            //水压：4字节BCD码，取值范围0~999999.99，单位为KPa。
            cdData.waterPress = 0.0D ;
            int tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.waterPress += tpInt/100.0 ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.waterPress += tpInt;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.waterPress += tpInt * 100.0 ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.waterPress += tpInt * 10000.0 ;
            int tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 3) ;
            cdData.waterPress = tpInt/100.0 ;
            index += 4 ;
        }
        if(hasEleVolt){
            //电池电压：4字节BCD码，取值范围0~99.99，单位为V。
            cdData.batteryVolt = 0.0D ;//蓄电池电压
            cdData.sunVolt = 0.0D ;//太阳能电压
            int tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.batteryVolt += tpInt/100.0 ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.batteryVolt += tpInt;
            //太阳能电压：4字节BCD码，取值范围0~99.99，单位为V。
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.sunVolt += tpInt/100.0 ;
            tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            index++ ;
            cdData.sunVolt += tpInt;
            //电池电压：2字节BCD码，取值范围0~99.99，单位为V。
            //蓄电池电压
            int tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 1) ;
            cdData.batteryVolt = tpInt/100.0 ;
            index += 2 ;
        }
        if(hasSignal){
            //信号强度：1字节BCD码，取值范围0~99。
            cdData.signal = 0 ;
            int tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
            cdData.signalValue = tpInt  ;
            index++ ;
            cdData.signal += tpInt  ;
        }
        if(hasAlarmStatus){
            //报警数据
@@ -214,6 +162,12 @@
            cdData.stateVo = GlParse.parseState(bs, index) ;
            index += 2 ;
        }

        //水价：2字节BCD码，取值范围0~99.99，单位为元。
        int tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 1) ;
        cdData.waterPrice = tpInt/100.0 ;

        index += 2 ;
        cdData.rtuDt = GlParse.parseTp(bs, index) ;

    }