From b421b28125bff8f39675e3f5ce29b3f58f13b5ae Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期三, 15 五月 2024 14:13:35 +0800
Subject: [PATCH] 1、增加了单数据源的Configuration; 2、RestTemplateConfiguration.java更换包路径; 3、完善王江海制定协议的实现代码。

---
 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_15_Down.java |   15 ++++++++++-----
 1 files changed, 10 insertions(+), 5 deletions(-)

diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_15_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_15_Down.java
index 51818e1..767e569 100644
--- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_15_Down.java
+++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_15_Down.java
@@ -1,6 +1,7 @@
 package com.dy.common.mw.protocol.p206V202404.parse;
 
 import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.JSONObject;
 import com.dy.common.mw.protocol.*;
 import com.dy.common.mw.protocol.p206V202404.CodeV202404;
 import com.dy.common.mw.protocol.p206V202404.ParseParamsForDownV202404;
@@ -48,7 +49,8 @@
     public byte[] doParse(ParseParamsForDownV202404 para) throws Exception {
         byte[] bytes = GlCreate.createStart2Cd(para.rtuAddr, para.commandCode);
         if(para.param != null){
-            String json = (String)para.param;
+            JSONObject obj = (JSONObject)para.param;
+            String json = obj.toJSONString();
             ComCd15Vo cvo = JSON.parseObject(json, ComCd15Vo.class) ;
             if(cvo == null){
                 throw new Exception("json杞珻omCd15Vo涓簄ull") ;
@@ -62,7 +64,7 @@
             if(cvo.flowNo.length() != 12){
                 throw new Exception("娴佹按鍙峰繀椤绘槸12浣嶆暟瀛�") ;
             }
-            byte[] bs = new byte[34] ;
+            byte[] bs = new byte[40] ;
             int index = 0 ;
             bs[index] = (byte)(Integer.parseInt(cvo.controllerType, 16));
 
@@ -96,9 +98,9 @@
                     bs[index++] = 0 ;
                 }
             }
-            if(cvo.chargeMoney != null){
-                String chargeMoney = "" + (Double.valueOf(cvo.chargeWater * 100)).longValue() ;
-                byte[] bTemp = ByteUtil.string2BCD_LE(chargeMoney) ;
+            if(cvo.chargeWater != null){
+                String chargeWater = "" + (Double.valueOf(cvo.chargeWater * 100)).longValue() ;
+                byte[] bTemp = ByteUtil.string2BCD_LE(chargeWater) ;
                 int bTempLen = bTemp.length ;
                 int count = 0 ;
                 for(int i = 0 ; i < bTempLen; i++){
@@ -120,6 +122,9 @@
             ByteUtil.string2BCD_BE(bs, cvo.flowNo, index) ;
 
             index += 6 ;
+            GlCreate.createDt(bs, index);
+
+            index += 6 ;
             GlCreate.createPw(bs, index);
 
             index += 2 ;

--
Gitblit v1.8.0