From d9765e031e100e1d8eea34e086cb9c81766e1a00 Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期五, 21 二月 2025 09:52:14 +0800 Subject: [PATCH] 针对王江海制定的协议: 1、优化相关注释; 2、优化代码; 3、协议中报警信息有变化:外门报警改为电池电压报警、增加阀门开关状态、增加阀门堵转报警等。 --- pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V2/parse/Cd_C0_Up.java | 17 ++++++++++++++--- 1 files changed, 14 insertions(+), 3 deletions(-) diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V2/parse/Cd_C0_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V2/parse/Cd_C0_Up.java index cbfc332..b5bf2a2 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V2/parse/Cd_C0_Up.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V2/parse/Cd_C0_Up.java @@ -4,6 +4,7 @@ import com.dy.common.mw.protocol.p206V2.*; import com.dy.common.mw.protocol.p206V2.parse.global.GlParse; import com.dy.common.mw.protocol.p206V2.upVos.DataCdC0Vo; +import com.dy.common.mw.protocol.rtuState.ValveStateInfo; import com.dy.common.util.ByteUtil; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; @@ -22,7 +23,7 @@ @Override public MidResult[] parse(Boolean isLowPower, CodeParseParams params, CodeParseCallback callback)throws Exception { ParseParamsForUpV2 para = (ParseParamsForUpV2)params ; - int bsLen = new CommonV2().parseDataLen(para.upBuffer) ; + int bsLen = new CommonV2().parseDataLen4P206(para.upBuffer) ; if(bsLen > 0){ this.doParse(para.upBuffer, bsLen, @@ -33,6 +34,7 @@ MidResultFromRtu midRs = new MidResultFromRtu() ; midRs.protocolName = para.protocolName ;//鍗忚鍚嶇О + midRs.protocolVersion = para.protocolVersion ;//鍗忚鐗堟湰鍙� midRs.rtuAddr = para.rtuAddr ;//Rtu鍦板潃 midRs.upCode = para.upCode ;//涓婅鏁版嵁涓殑鍔熻兘鐮� midRs.upHex = para.upHex ;//涓婅鏁版嵁鍗佸叚杩涘埗褰㈠紡 @@ -46,6 +48,7 @@ downCpParams.setValue( null, ProtocolConstantV206V2.protocolName, + para.protocolVersion, para.rtuAddr, Command.defaultId, confirmComCode, @@ -56,6 +59,7 @@ MidResultToRtu confirmCommand = new MidResultToRtu() ; confirmCommand.protocolName = para.protocolName ;//鍗忚鍚嶇О + confirmCommand.protocolVersion = para.protocolVersion ;//鍗忚鐗堟湰鍙� confirmCommand.rtuAddr = para.rtuAddr ;//Rtu鍦板潃 confirmCommand.commandId = Command.defaultId ;//鍛戒护ID锛屽彂璧峰懡浠ょ殑瀹㈡埛绔�(web绔�)鐢熸垚锛屼互鍖归厤鍛戒护缁撴灉 confirmCommand.downCode = confirmComCode ;//涓嬭鍛戒护鍔熻兘鐮�; @@ -72,8 +76,15 @@ confirmCommand.isQuickSend = true ; } - callback.callback(midRs.reportOrResponse_trueOrFalse); - return new MidResult[]{midRs, confirmCommand} ; + callback.callback(midRs.reportOrResponse_trueOrFalse, para.data.subData==null?null:((DataV2)(para.data.subData)).subData); + if(para.data != null && para.data.getSubData() != null){ + DataCdC0Vo cdData = (DataCdC0Vo)((DataV2)para.data.getSubData()).subData ; + if(cdData.stateVo != null && cdData.stateVo.valveState != null){ + callback.notify(new ValveStateInfo(cdData.stateVo.valveState.byteValue()== 1?false:true)); + } + } + + return new MidResult[]{confirmCommand, midRs} ; } /** * 鎵ц鍒嗘瀽 -- Gitblit v1.8.0