From 427d87e5572d72d0e3aaa4364e4f53569222e321 Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期二, 25 三月 2025 21:40:05 +0800
Subject: [PATCH] Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

---
 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V2/parse/Cd_83_Up.java |   47 +++++++++++++++++++++++++++++------------------
 1 files changed, 29 insertions(+), 18 deletions(-)

diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V2/parse/Cd_83_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V2/parse/Cd_83_Up.java
index 955e52f..1ea1bc0 100644
--- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V2/parse/Cd_83_Up.java
+++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V2/parse/Cd_83_Up.java
@@ -24,7 +24,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,
@@ -77,16 +77,16 @@
             confirmCommand.isQuickSend = true ;
         }
 
-        callback.callback(midRs.reportOrResponse_trueOrFalse);
+        callback.callback(midRs.reportOrResponse_trueOrFalse, para.data.subData==null?null:((DataV2)(para.data.subData)).subData);
         if(para.data != null && para.data.getSubData() != null){
-            Object subData = para.data.getSubData() ;
+            Object subData = ((DataV2)para.data.getSubData()).subData ;
             if(subData instanceof DataCd83OpenVo){
                 callback.notify(new ValveStateInfo(true));
             }else if(subData instanceof DataCd83CloseVo){
                 callback.notify(new ValveStateInfo(false));
             }
         }
-        return new MidResult[]{midRs, confirmCommand} ;
+        return new MidResult[]{confirmCommand, midRs} ;
     }
     /**
      * 鎵ц鍒嗘瀽
@@ -116,20 +116,25 @@
 
         short index = ProtocolConstantV206V2.dataIndex + 1 ;
         //绱娴侀噺锛�5瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0~99999999.99锛屽崟浣嶄负m3銆�
-        int tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 4) ;
-        cdData.totalAmount = tpInt/100.0 ;
+        long tpLong = ByteUtil.BCD2Long_LE(bs, index, index + 4) ;
+        cdData.totalAmount = tpLong/100.0 ;
 
         index += 5 ;
         //鐢ㄦ按鎴峰彿鏁版嵁鏍煎紡锛�8瀛楄妭浣庝綅鍦ㄥ墠楂樹綅鍦ㄥ悗銆�
-        cdData.icCardNo = GlParse.parseIcCardNo(bs, index) ;
+        if(ByteUtil.bytesIsAll0xFF(bs, index, 8)){
+            throw new Exception("IC鍗″彿鏁版嵁鏍煎紡閿欒锛�8瀛楄妭鍏ㄩ儴涓�0xFF锛岃垗寮冩暟鎹�") ;
+        }cdData.icCardNo = GlParse.parseIcCardNo(bs, index) ;
 
         index += 8 ;
         //IC鍗″彿鏍煎紡锛�4瀛楄妭HEX鐮佷綆浣嶅湪鍓嶉珮浣嶅湪鍚庛��
+        if(ByteUtil.bytesIsAll0xFF(bs, index, 4)){
+            throw new Exception("IC鍦板潃鏁版嵁鏍煎紡閿欒锛�4瀛楄妭鍏ㄩ儴涓�0xFF锛岃垗寮冩暟鎹�") ;
+        }
         cdData.icCardAddr = ByteUtil.bytes2Hex_LE(bs, false,  index, 4) ;
 
         index += 4 ;
         //鐢ㄦ按鎴蜂綑棰濓細鐢ㄦ埛浣欓4瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0.00~999999.99锛屽崟浣嶄负鍏冦��
-        tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 3) ;
+        int tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 3) ;
         cdData.remainMoney = tpInt/100.0 ;
 
         index += 4 ;
@@ -154,21 +159,27 @@
 
         short index = ProtocolConstantV206V2.dataIndex + 1 ;
         //绱娴侀噺锛�5瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0~9999999999锛屽崟浣嶄负m3銆�
-        int tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 4) ;
-        cdData.totalAmount = tpInt/100.0 ;
+        long tpLong = ByteUtil.BCD2Long_LE(bs, index, index + 4) ;
+        cdData.totalAmount = tpLong/100.0 ;
 
         index += 5 ;
         //鐢ㄦ按鎴峰彿鏁版嵁鏍煎紡锛�8瀛楄妭浣庝綅鍦ㄥ墠楂樹綅鍦ㄥ悗銆�
+        if(ByteUtil.bytesIsAll0xFF(bs, index, 8)){
+            throw new Exception("IC鍗″彿鏁版嵁鏍煎紡閿欒锛�8瀛楄妭鍏ㄩ儴涓�0xFF锛岃垗寮冩暟鎹�") ;
+        }
         cdData.icCardNo = GlParse.parseIcCardNo(bs, index) ;
 
         index += 8 ;
         //IC鍗″彿鏍煎紡锛�4瀛楄妭HEX鐮佷綆浣嶅湪鍓嶉珮浣嶅湪鍚庛��
+        if(ByteUtil.bytesIsAll0xFF(bs, index, 4)){
+            throw new Exception("IC鍦板潃鏁版嵁鏍煎紡閿欒锛�4瀛楄妭鍏ㄩ儴涓�0xFF锛岃垗寮冩暟鎹�") ;
+        }
         cdData.icCardAddr = ByteUtil.bytes2Hex_LE(bs, false,  index, 4) ;
 
         index += 4 ;
         //鐢ㄦ按鎴蜂綑棰濓細鐢ㄦ埛浣欓4瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0.00~999999.99锛屽崟浣嶄负鍏冦��
-        tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 3) ;
-        cdData.remainMoney = tpInt/100.0 ;
+        tpLong = ByteUtil.BCD2Long_LE(bs, index, index + 3) ;
+        cdData.remainMoney = tpLong/100.0 ;
 
         index += 4 ;
         //鐢ㄦ按鎴风敤姘村紑濮嬫椂闂达細6瀛楄妭BCD鐮侊紝椤哄簭鏄勾鏈堟棩鏃跺垎绉掞紝鍏朵腑鍏厓骞�=2000+骞淬��
@@ -180,17 +191,17 @@
 
         index += 6 ;
         //鐢ㄦ按鎴锋湰娆$敤姘撮噺锛氱疮璁℃祦閲�5瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0~9999999999锛屽崟浣嶄负m3銆�
-        tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 4) ;
-        cdData.thisAmount = tpInt/100.0 ;
+        tpLong = ByteUtil.BCD2Long_LE(bs, index, index + 4) ;
+        cdData.thisAmount = tpLong/100.0 ;
 
         index += 5 ;
         //鐢ㄦ按鎴锋湰娆℃秷璐归噾棰濓細鐢ㄦ埛浣欓4瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0.00~999999.99锛屽崟浣嶄负鍏冦��
-        tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 3) ;
-        cdData.thisMoney = tpInt/100.0 ;
+        tpLong = ByteUtil.BCD2Long_LE(bs, index, index + 3) ;
+        cdData.thisMoney = tpLong/100.0 ;
 
         index += 4 ;
         //鐢ㄦ按鎴锋湰娆$敤姘存椂闀匡細鐢ㄦ按鏃堕暱2瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0~9999锛屽崟浣嶄负鍒嗛挓銆�
-        tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 1) ;
+        int tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 1) ;
         cdData.thisTime = tpInt;
 
         index += 2 ;
@@ -222,7 +233,7 @@
         Data data = new Data() ;
         data.setSubData(new DataV2()) ;
 
-        int bsLen = new CommonV2().parseDataLen(bs) ;
+        int bsLen = new CommonV2().parseDataLen4P206(bs) ;
         if(bsLen > 0){
             try {
             obj.doParse(bs,

--
Gitblit v1.8.0