From d736d220008f3ddaed44ac6bfa8a19eb8ca61e96 Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期六, 12 十月 2024 14:09:39 +0800 Subject: [PATCH] 1、江海协议功能C2增加订单号数据项; 2、下行命令构造时标TP当月份大于等于10时有错,进行修改。 --- pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_99_Down.java | 28 ++++++++++++++++++---------- 1 files changed, 18 insertions(+), 10 deletions(-) diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_99_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_99_Down.java index f017296..3aff9b9 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_99_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_99_Down.java @@ -32,6 +32,7 @@ midRs.rtuAddr = para.rtuAddr ;//Rtu鍦板潃 midRs.commandId = para.commandId ;//鍛戒护ID锛屽彂璧峰懡浠ょ殑瀹㈡埛绔�(web绔�)鐢熸垚锛屼互鍖归厤鍛戒护缁撴灉 midRs.downCode = para.commandCode ;//涓嬭鍛戒护鍔熻兘鐮�; + midRs.downCodeName = CodeV1_0_1.getCodeName(para.commandCode) ;//涓嬭鍛戒护鍔熻兘鐮佸悕绉�; midRs.downBuffer = bs ;//涓嬭鍛戒护鏁版嵁 midRs.downBufHex = ByteUtil.bytes2Hex(bs, true) ;//涓嬭鍛戒护鏁版嵁鍗佸叚杩涘埗褰㈠紡 midRs.hasResponse = true ;//鏄惁鏈夊簲绛� @@ -79,19 +80,19 @@ String json = obj.toJSONString(); Com99Vo cvo = JSON.parseObject(json, Com99Vo.class) ; if(cvo == null){ - throw new Exception("json杞珻om97Vo涓簄ull") ; + throw new Exception("json杞珻om99Vo涓簄ull") ; } if(cvo.icCardNo == null){ throw new Exception("铏氭嫙IC鍗$紪鍙蜂笉鑳戒负绌�") ; } - if(cvo.moneyRemain == null){ - throw new Exception("鍓╀綑閲戦涓嶈兘涓虹┖") ; + if(cvo.moneyRemain == null || cvo.moneyRemain == 0.0){ + throw new Exception("鍓╀綑閲戦涓嶈兘涓虹┖鎴栦负0") ; } - if(cvo.waterPrice == null){ - throw new Exception("姘翠环涓嶈兘涓虹┖") ; + if(cvo.waterPrice == null || cvo.waterPrice == 0.0){ + throw new Exception("姘翠环涓嶈兘涓虹┖鎴栦负0") ; } - if(cvo.minutes == null){ - throw new Exception("鐢ㄦ按鏃堕暱涓嶈兘涓虹┖") ; + if(cvo.minutes == null || cvo.minutes == 0.0){ + throw new Exception("鐢ㄦ按鏃堕暱涓嶈兘涓虹┖鎴栦负0") ; } if(cvo.minutes < 0 || cvo.minutes > 9999){ throw new Exception("鐢ㄦ按鏃堕暱鍙栧�艰寖鍥存槸0~9999鍒嗛挓") ; @@ -106,9 +107,11 @@ //ByteUtil.string2BCD_LE(bs, icCardNoGrp[1], index) ; byte[] bs = new byte[8] ; GlCreate.createIcCardNo(cvo.icCardNo, bs, 0); + bytes = ByteUtil.bytesMerge(bsHead, bs) ; - index += 5 ; + bs = new byte[4] ; + index = 0 ; Integer money = Double.valueOf(cvo.moneyRemain * 100.0D).intValue() ; byte[] bTemp = ByteUtil.int2BCD_LE(money) ; int bTempLen = bTemp.length ; @@ -123,7 +126,10 @@ for(; count < 4; count++){ bs[index++] = 0 ; } + bytes = ByteUtil.bytesMerge(bytes, bs) ; + bs = new byte[2] ; + index = 0 ; Integer price = Double.valueOf(cvo.waterPrice * 100.0D).intValue() ; bTemp = ByteUtil.int2BCD_LE(price) ; bTempLen = bTemp.length ; @@ -138,8 +144,11 @@ for(; count < 2; count++){ bs[index++] = 0 ; } + bytes = ByteUtil.bytesMerge(bytes, bs) ; + bs = new byte[2] ; + index = 0 ; bTemp = ByteUtil.int2BCD_LE(cvo.minutes) ; bTempLen = bTemp.length ; count = 0 ; @@ -153,8 +162,7 @@ for(; count < 2; count++){ bs[index++] = 0 ; } - - bytes = ByteUtil.bytesMerge(bsHead, bs) ; + bytes = ByteUtil.bytesMerge(bytes, bs) ; GlCreate.createLen(bytes);//闀垮害鏀惧瓧鑺傛暟缁勪腑 -- Gitblit v1.8.0