From 2ef075d66cf5bc95562f2e584ed6283776062f24 Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期五, 24 十一月 2023 10:25:38 +0800
Subject: [PATCH] 1、优化通信中间件代码; 2、实现功能码71协议(查询阀门状态)

---
 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_83_Up.java |   17 +++++++++++------
 1 files changed, 11 insertions(+), 6 deletions(-)

diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_83_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_83_Up.java
index 296dc3c..15ff9f1 100644
--- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_83_Up.java
+++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_83_Up.java
@@ -40,7 +40,7 @@
 
         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(
                 ProtocolConstantV206V1_0_0.protocolName,
@@ -61,8 +61,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} ;
@@ -203,7 +208,10 @@
         cdData.thisAmount = 0.0D ;
         tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
         index++ ;
-        cdData.thisAmount += tpInt;
+        cdData.thisAmount += tpInt/100.0 ;
+        tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
+        index++ ;
+        cdData.thisAmount += tpInt ;
         tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
         index++ ;
         cdData.thisAmount += tpInt * 100.0 ;
@@ -213,9 +221,6 @@
         tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
         index++ ;
         cdData.thisAmount += tpInt * 1000000.0 ;
-        tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ;
-        index++ ;
-        cdData.thisAmount += tpInt * 100000000.0 ;
 
         //鐢ㄦ按鎴锋湰娆℃秷璐归噾棰濓細鐢ㄦ埛浣欓4瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0.00~999999.99锛屽崟浣嶄负鍏冦��
         cdData.thisMoney = 0.0D ;

--
Gitblit v1.8.0