From 4fe7ea4fbdc0c45f14d1d8de77e3424f826ba909 Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期五, 28 六月 2024 21:39:12 +0800 Subject: [PATCH] 1、靳总协议上行数据处理修改完善; 2、上行数据处理任务修改完善. --- pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Down.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_99_Down.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_86_Down.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/global/GlParse.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_97_Down.java | 2 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealCloseValveReport.java | 8 pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmWorkReportLastMapper.xml | 7 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_84_Up.java | 21 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataAlarmVo.java | 4 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmOpenCloseValveLast.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_6D_Down.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_68_Up.java | 1 pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmAlarmStateLastMapper.xml | 18 + pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_26_Down.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_55_Down.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_85_Up.java | 1 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmWorkReportHistory.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_15_Down.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_91_Down.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_85_Down.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_68_Down.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_98_Down.java | 2 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealLoss.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9A_Down.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataStateVo.java | 12 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_98_Down.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/MD5.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/CodeV1_0_1.java | 10 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_88_Up.java | 1 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealAlarmStatus.java | 79 ----- pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataCd84Vo.java | 24 pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmAlarmStateHistoryMapper.xml | 18 + pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_30_Down.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_93_A3_Down.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_83_Up.java | 109 ++------ pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_56_Down.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_88_Down.java | 3 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_81_Up.java | 8 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_16_Down.java | 2 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V202404/TkDealAlarmStatusV202404.java | 6 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_99_Down.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_97_Down.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_24_Down.java | 5 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_5B_Down.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_5C_Up.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_84_Down.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Up.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_A0_Down.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_50_Down.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Down.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_23_Down.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_84_Up.java | 1 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmAlarmStateHistory.java | 32 ++ pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmWorkReportLast.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_87_Up.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_56_Up.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Up.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9C_Down.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_25_Down.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/ByteUtil.java | 281 ++++++++++++++------- pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmAlarmStateLast.java | 60 ++++ pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_83_Down.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9A_Up.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_22_Down.java | 2 64 files changed, 407 insertions(+), 364 deletions(-) diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/CodeV1_0_1.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/CodeV1_0_1.java index 4f8929b..02b993f 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/CodeV1_0_1.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/CodeV1_0_1.java @@ -29,10 +29,10 @@ public static final String cd_69 = "69" ;//鏌ヨ鐢垫睜鐢靛帇鎶ヨ鍊� public static final String cd_6A = "6A" ;//鏌ヨ闃�闂ㄥ牭杞數娴佸�� public static final String cd_6B = "6B" ;//鏌ヨ闃�闂ㄨ秴鏃舵椂闂� - public static final String cd_6D = "6D" ;//鏌ヨ闃舵姘翠环锛堟湭瀹炵幇锛� - public static final String cd_81 = "81" ;//闅忔満鑷姤鎶� - public static final String cd_83 = "83" ;//閬ユ祴绔欏紑鍏抽榾鑷姤 - public static final String cd_84 = "84" ;//寮�闃�宸ヤ綔鎶� + public static final String cd_6D = "6D" ;//鏌ヨ闃舵姘翠环 + public static final String cd_81 = "81" ;//闅忔満鑷姤鎶� ok + public static final String cd_83 = "83" ;//閬ユ祴绔欏紑鍏抽榾鑷姤 ok + public static final String cd_84 = "84" ;//寮�闃�宸ヤ綔鎶� ok public static final String cd_91 = "91" ;//娓呯┖鍘嗗彶璁板綍 public static final String cd_92 = "92" ;//閬ユ帶鍚姩闃�闂� public static final String cd_93 = "93" ;//閬ユ帶鍏抽棴闃�闂� @@ -42,7 +42,7 @@ public static final String cd_99 = "99" ;//瀹氭椂鍏抽榾寮�闃� public static final String cd_A0 = "A0" ;//瀹氶噺鍏抽榾寮�闃� public static final String cd_B0 = "B0" ;//鏌ヨ瀹炴椂鏁版嵁锛堟湭瀹炵幇锛� - public static final String cd_C0 = "C0" ;//閬ユ祴绔欐暣鐐逛笂鎶ュ疄鏃舵暟鎹� + public static final String cd_C0 = "C0" ;//閬ユ祴绔欐暣鐐逛笂鎶ュ疄鏃舵暟鎹� ok public static String getCodeName(String code) { String name = (code.equals(cd_02) ? "閾捐矾妫�娴�" : diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_6D_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_6D_Down.java index c77a657..3b314ed 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_6D_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_6D_Down.java @@ -7,7 +7,6 @@ import com.dy.common.mw.protocol.p206V1_0_0.ProtocolConstantV206V1_0_0; import com.dy.common.mw.protocol.p206V1_0_0.parse.global.GlCreate; import com.dy.common.util.ByteUtil; -import com.dy.common.util.ByteUtilUnsigned; /** * @Author liurunyu diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_81_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_81_Up.java index 029c4e3..56857a7 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_81_Up.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_81_Up.java @@ -92,10 +92,16 @@ //鎶ヨ鏁版嵁 cdData.alarmVo = GlParse.parseAlarm(bs, index) ; index += 2 ; + + if(bs.length == 28){ + //甯︾灛鏃舵祦閲� + index += 5 ;//鐬椂娴侀噺 + } + //鐘舵�佹暟鎹� cdData.stateVo = GlParse.parseState(bs, index) ; - index += 2 ; + index += 2 ; //鎺у埗鍣ㄦ椂閽� cdData.rtuDt = GlParse.parseTp(bs, index) ; 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 7f09c37..2efc729 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 @@ -101,9 +101,8 @@ short index = ProtocolConstantV206V1_0_0.dataIndex + 1 ; //绱娴侀噺锛�5瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0~99999999.99锛屽崟浣嶄负m3銆� - cdData.totalAmount = 0.0D ; int tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 4) ; - cdData.totalAmount += tpInt/100.0 ; + cdData.totalAmount = tpInt/100.0 ; index += 5 ; //鐢ㄦ按鎴峰彿鏁版嵁鏍煎紡锛�5瀛楄妭BCD鐮佷綆浣嶅湪鍓嶉珮浣嶅湪鍚庛�� @@ -111,13 +110,12 @@ index += 5 ; //IC鍗″彿鏍煎紡锛�4瀛楄妭HEX鐮佷綆浣嶅湪鍓嶉珮浣嶅湪鍚庛�� - cdData.icCardAddr = ByteUtil.bytesToHex(bs, index, index + 3) ; + cdData.icCardAddr = ByteUtil.bytes2Hex_LE(bs, false, index, 4) ; index += 4 ; //鐢ㄦ按鎴蜂綑棰濓細鐢ㄦ埛浣欓4瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0.00~999999.99锛屽崟浣嶄负鍏冦�� - cdData.remainMoney = 0.0D ; tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 3) ; - cdData.remainMoney += tpInt/100.0 ; + cdData.remainMoney = tpInt/100.0 ; index += 4 ; //鐢ㄦ按鎴风敤姘村紑濮嬫椂闂达細6瀛楄妭BCD鐮侊紝椤哄簭鏄勾鏈堟棩鏃跺垎绉掞紝鍏朵腑鍏厓骞�=2000+骞淬�� @@ -154,108 +152,53 @@ short index = ProtocolConstantV206V1_0_0.dataIndex + 1 ; //绱娴侀噺锛�5瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0~9999999999锛屽崟浣嶄负m3銆� - cdData.totalAmount = 0.0D ; - int tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.totalAmount += tpInt; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.totalAmount += tpInt * 100.0 ; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.totalAmount += tpInt * 10000.0 ; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.totalAmount += tpInt * 1000000.0 ; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.totalAmount += tpInt * 100000000.0 ; + int tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 4) ; + cdData.totalAmount = tpInt/100.0 ; + index += 5 ; //鐢ㄦ按鎴峰彿鏁版嵁鏍煎紡锛�5瀛楄妭BCD鐮佷綆浣嶅湪鍓嶉珮浣嶅湪鍚庛�� cdData.icCardNo = ByteUtil.BCD2String_LE(bs, index, index + 4) ; + index += 5 ; - //IC鍗″彿鏍煎紡锛�4瀛楄妭HEX鐮佷綆浣嶅湪鍓嶉珮浣嶅湪鍚庛�� - cdData.closeDt = ByteUtil.bytesToHex(bs, index, index + 3) ; + cdData.icCardAddr = ByteUtil.bytes2Hex_LE(bs, false, index, 4) ; + index += 4 ; - //鐢ㄦ按鎴蜂綑棰濓細鐢ㄦ埛浣欓4瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0.00~999999.99锛屽崟浣嶄负鍏冦�� - cdData.remainMoney = 0.0D ; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.remainMoney += tpInt/100.0 ; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.remainMoney += tpInt; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.remainMoney += tpInt * 100.0 ; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.remainMoney += tpInt * 10000.0 ; + tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 3) ; + cdData.remainMoney = tpInt/100.0 ; + index += 4 ; //鐢ㄦ按鎴风敤姘村紑濮嬫椂闂达細6瀛楄妭BCD鐮侊紝椤哄簭鏄勾鏈堟棩鏃跺垎绉掞紝鍏朵腑鍏厓骞�=2000+骞淬�� cdData.openDt = GlParse.parseTp(bs, index) ; - index += 6 ; + index += 6 ; //鐢ㄦ按鎴风敤姘寸粨鏉熸椂闂达細6瀛楄妭BCD鐮侊紝椤哄簭鏄勾鏈堟棩鏃跺垎绉掞紝鍏朵腑鍏厓骞�=2000+骞淬�� cdData.closeDt = GlParse.parseTp(bs, index) ; + index += 6 ; - //鐢ㄦ按鎴锋湰娆$敤姘撮噺锛氱疮璁℃祦閲�5瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0~9999999999锛屽崟浣嶄负m3銆� - cdData.thisAmount = 0.0D ; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - 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 ; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.thisAmount += tpInt * 10000.0 ; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.thisAmount += tpInt * 1000000.0 ; + tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 4) ; + cdData.thisAmount = tpInt/100.0 ; + index += 5 ; //鐢ㄦ按鎴锋湰娆℃秷璐归噾棰濓細鐢ㄦ埛浣欓4瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0.00~999999.99锛屽崟浣嶄负鍏冦�� - cdData.thisMoney = 0.0D ; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.thisMoney += tpInt/100.0 ; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.thisMoney += tpInt; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.thisMoney += tpInt * 100.0 ; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.thisMoney += tpInt * 10000.0 ; + tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 3) ; + cdData.thisMoney = tpInt/100.0 ; + index += 4 ; //鐢ㄦ按鎴锋湰娆$敤姘存椂闀匡細鐢ㄦ按鏃堕暱2瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0~9999锛屽崟浣嶄负鍒嗛挓銆� - cdData.thisTime = 0 ; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.thisTime += tpInt; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.thisTime += tpInt * 100 ; + tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 1) ; + cdData.thisTime = tpInt; - + index += 2 ; cdData.priceType = bs[index] ; index++ ; - cdData.price = 0.0D ; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.price += tpInt/100.0 ; - tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; - index++ ; - cdData.price += tpInt; + tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 1) ; + cdData.price = tpInt/100.0 ; + index += 2 ; cdData.cardType = bs[index] ; index++ ; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_84_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_84_Up.java index fe33156..0deb3cb 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_84_Up.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_84_Up.java @@ -88,35 +88,32 @@ dV1.subData = cdData ; short index = ProtocolConstantV206V1_0_0.dataIndex ; - //cdData.opType = bs[index] ; + cdData.opType = bs[index] ; - //index++ ; - //cdData.cardType = bs[index] ; + index++ ; + cdData.cardType = bs[index] ; - //index++ ; - //cdData.cardAddr = ByteUtil.bytes2Hex(bs, false, index, 4) ; + index++ ; + cdData.cardAddr = ByteUtil.bytes2Hex_LE(bs, false, index, 4) ; - //index += 4 ; + index += 4 ; //鐢ㄦ按鎴峰彿鏁版嵁鏍煎紡锛�5瀛楄妭BCD鐮佷綆浣嶅湪鍓嶉珮浣嶅湪鍚庛�� cdData.cardNo = ByteUtil.BCD2String_LE(bs, index, index + 4) ; index += 5 ; //鐢ㄦ按鎴蜂綑棰濓細鐢ㄦ埛浣欓4瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0.00~999999.99锛屽崟浣嶄负鍏冦�� - cdData.remainMoney = 0.0D ; int tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 3) ; - cdData.remainMoney += tpInt/100.0 ; + cdData.remainMoney = tpInt/100.0 ; index += 4 ; //绱娴侀噺锛�5瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0~9999999999锛屽崟浣嶄负m3銆� - cdData.totalAmount = 0.0D ; tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 4) ; - cdData.totalAmount += tpInt; + cdData.totalAmount = tpInt/100.0; index += 5 ; //鐬椂娴侀噺锛�5瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0~9999999.999锛屽崟浣嶄负m3/h銆� - cdData.instantAmount = 0.0D ; tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 4) ; - cdData.instantAmount += tpInt/1000.0 ; + cdData.instantAmount = tpInt/1000.0 ; index += 5 ; cdData.alarmVo = GlParse.parseAlarm(bs, index) ; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_91_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_91_Down.java index d8be3a8..110b9bd 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_91_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_91_Down.java @@ -7,7 +7,6 @@ import com.dy.common.mw.protocol.p206V1_0_0.ProtocolConstantV206V1_0_0; import com.dy.common.mw.protocol.p206V1_0_0.parse.global.GlCreate; import com.dy.common.util.ByteUtil; -import com.dy.common.util.ByteUtilUnsigned; /** * @Author liurunyu diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_97_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_97_Down.java index 61c9ef9..33787cd 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_97_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_97_Down.java @@ -10,7 +10,6 @@ import com.dy.common.mw.protocol.p206V1_0_0.downVos.Com97Vo; import com.dy.common.mw.protocol.p206V1_0_0.parse.global.GlCreate; import com.dy.common.util.ByteUtil; -import com.dy.common.util.ByteUtilUnsigned; /** * @Author liurunyu diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_98_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_98_Down.java index 5a1aaf2..ae52d59 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_98_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_98_Down.java @@ -7,11 +7,9 @@ import com.dy.common.mw.protocol.p206V1_0_0.CommonV1_0_1; import com.dy.common.mw.protocol.p206V1_0_0.ParseParamsForDownV1_0_1; import com.dy.common.mw.protocol.p206V1_0_0.ProtocolConstantV206V1_0_0; -import com.dy.common.mw.protocol.p206V1_0_0.downVos.Com97Vo; import com.dy.common.mw.protocol.p206V1_0_0.downVos.Com98Vo; import com.dy.common.mw.protocol.p206V1_0_0.parse.global.GlCreate; import com.dy.common.util.ByteUtil; -import com.dy.common.util.ByteUtilUnsigned; /** * @Author liurunyu 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 9e84e6b..d7ff9b7 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 @@ -7,7 +7,6 @@ import com.dy.common.mw.protocol.p206V1_0_0.CommonV1_0_1; import com.dy.common.mw.protocol.p206V1_0_0.ParseParamsForDownV1_0_1; import com.dy.common.mw.protocol.p206V1_0_0.ProtocolConstantV206V1_0_0; -import com.dy.common.mw.protocol.p206V1_0_0.downVos.Com97Vo; import com.dy.common.mw.protocol.p206V1_0_0.downVos.Com99Vo; import com.dy.common.mw.protocol.p206V1_0_0.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_A0_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_A0_Down.java index 919df26..3c8baa4 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_A0_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_A0_Down.java @@ -7,7 +7,6 @@ import com.dy.common.mw.protocol.p206V1_0_0.CommonV1_0_1; import com.dy.common.mw.protocol.p206V1_0_0.ParseParamsForDownV1_0_1; import com.dy.common.mw.protocol.p206V1_0_0.ProtocolConstantV206V1_0_0; -import com.dy.common.mw.protocol.p206V1_0_0.downVos.Com99Vo; import com.dy.common.mw.protocol.p206V1_0_0.downVos.ComA0Vo; import com.dy.common.mw.protocol.p206V1_0_0.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/global/GlParse.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/global/GlParse.java index 5336505..6e5a7a9 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/global/GlParse.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/global/GlParse.java @@ -34,7 +34,7 @@ DataStateVo avo = new DataStateVo() ; byte b = bs[index] ; avo.icCard = (byte)((b & 0x4) >> 2) ; - avo.working = (byte)((b & 0x10) >> 4) ; + avo.valveState = (byte)((b & 0x10) >> 4) ; avo.powerType = (byte)((b & 0x40) >> 6) ; return avo ; } diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataAlarmVo.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataAlarmVo.java index 983a152..fcae238 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataAlarmVo.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataAlarmVo.java @@ -15,13 +15,13 @@ str.append(" 钃勭數姹犵數鍘嬶細"); str.append(batteryVolt==null?"":(batteryVolt==1?"鎶ヨ":"姝e父")); str.append("\n"); - str.append(" 婕忔崯锛�"); + str.append(" 婕忔崯锛� "); str.append(loss==null?"":(loss==1?"鎶ヨ":"姝e父")); str.append("\n"); str.append(" 娴侀噺璁℃晠闅滐細"); str.append(meter==null?"":(meter==1?"鎶ヨ":"姝e父")); str.append("\n"); - str.append(" 闃�闂細"); + str.append(" 闃�闂細 "); str.append(valve==null?"":(valve==1?"鎶ヨ":"姝e父")); return str.toString() ; } diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataCd84Vo.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataCd84Vo.java index 1553cd5..0dc5904 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataCd84Vo.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataCd84Vo.java @@ -9,9 +9,9 @@ @Data public class DataCd84Vo { - //public Byte opType;//寮�鍏抽榾绫诲瀷(1:鍒峰崱寮�闃�锛�2:鍒峰崱鍏抽榾锛�3:涓績绔欏紑闃�锛�4:涓績绔欏叧闃�锛�5:娆犺垂鍏抽榾锛�6:娴侀噺璁℃晠闅滃叧闃�锛�7:绱ф�ュ叧闂紱8:鐢ㄦ埛杩滅▼寮�闃�锛�9:鐢ㄦ埛杩滅▼鍏抽榾锛�10:寮�鍏抽榾鍗″叧闃�锛�11:寮�鍏抽榾鍗″埛鍗″崱寮�闃�锛�) - //public Byte cardType ;//鍗$被鍨�(1:鐢ㄦ埛鍗★紱2锛氱鐞嗗憳鍗★紱3锛氳皟璇曞崱锛�4锛氬紑鍏抽榾鍗★紱5锛氭竻绌哄崱) - //public String cardAddr ;//IC鍗″湴鍧�锛�8浣嶅瓧绗︼級 + public Byte opType;//寮�鍏抽榾绫诲瀷(1:鍒峰崱寮�闃�锛�2:鍒峰崱鍏抽榾锛�3:涓績绔欏紑闃�锛�4:涓績绔欏叧闃�锛�5:娆犺垂鍏抽榾锛�6:娴侀噺璁℃晠闅滃叧闃�锛�7:绱ф�ュ叧闂紱8:鐢ㄦ埛杩滅▼寮�闃�锛�9:鐢ㄦ埛杩滅▼鍏抽榾锛�10:寮�鍏抽榾鍗″叧闃�锛�11:寮�鍏抽榾鍗″埛鍗″崱寮�闃�锛�) + public Byte cardType ;//鍗$被鍨�(1:鐢ㄦ埛鍗★紱2锛氱鐞嗗憳鍗★紱3锛氳皟璇曞崱锛�4锛氬紑鍏抽榾鍗★紱5锛氭竻绌哄崱) + public String cardAddr ;//IC鍗″湴鍧�锛�8浣嶅瓧绗︼級 public String cardNo ;//IC鍗$紪鍙� public Double remainMoney ;//鍓╀綑閲戦锛氱敤鎴蜂綑棰�4瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0.00~999999.99锛屽崟浣嶄负鍏� public Double totalAmount; //绱娴侀噺锛堟按琛ㄤ笂鐨勭疮璁℃祦閲忥級锛�5瀛楄妭BCD鐮侊紝鍙栧�艰寖鍥�0~9999999999锛屽崟浣嶄负m3銆� @@ -24,15 +24,15 @@ public String toString(){ StringBuilder sb = new StringBuilder() ; sb.append(" 缁堢寮�闃�宸ヤ綔鎶�:\n"); -// sb.append(" 寮�闃�绫诲瀷锛�"); -// sb.append(opType==null?"鏈煡": CommonV1_0_1.openCloseValveType(opType)); -// sb.append("\n"); -// sb.append(" IC鍗$被鍨嬶細"); -// sb.append(cardType==null?"鏈煡":CommonV1_0_1.icCardType(cardType)) ; -// sb.append("\n"); -// sb.append(" IC鍗″湴鍧�锛�"); -// sb.append(cardAddr); -// sb.append("\n"); + sb.append(" 寮�闃�绫诲瀷锛�"); + sb.append(opType==null?"鏈煡": CommonV1_0_1.openCloseValveType(opType)); + sb.append("\n"); + sb.append(" IC鍗$被鍨嬶細"); + sb.append(cardType==null?"鏈煡":CommonV1_0_1.icCardType(cardType)) ; + sb.append("\n"); + sb.append(" IC鍗″湴鍧�锛�"); + sb.append(cardAddr); + sb.append("\n"); sb.append(" IC鍗$紪鍙凤細"); sb.append(cardNo); sb.append("\n"); diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataStateVo.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataStateVo.java index 1e12bd4..096404e 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataStateVo.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataStateVo.java @@ -5,20 +5,20 @@ @Data public class DataStateVo { public Byte icCard;// IC鍗″姛鑳� - public Byte working;//宸ヤ綔鐘舵�� + public Byte valveState;//闃�闂ㄧ姸鎬� public Byte powerType ;//鐢垫簮鐘舵�侊紙0锛�220V渚涚數锛�1锛氱暅鐢垫睜渚涚數锛� public String toString(){ StringBuilder str = new StringBuilder() ; str.append(" 鐘舵��:\n"); - str.append(" IC 鍗″姛鑳斤細"); - str.append(icCard ==null?"":(icCard ==1?"鏈夋晥":"鏃犳晥")); + str.append(" IC鍗″姛鑳斤細"); + str.append(icCard ==null?"":(icCard ==1?"鏈夋晥(1)":"鏃犳晥(0)")); str.append("\n"); - str.append(" 宸ヤ綔鐘舵�侊細"); - str.append(working ==null?"":(working ==1?"鍚姩":"鍋滄")); + str.append(" 闃�闂ㄧ姸鎬侊細"); + str.append(valveState ==null?"":(valveState ==1?"鍏抽棴(1)":"鎵撳紑(0)")); str.append("\n"); str.append(" 鐢垫簮鐘舵�侊細"); - str.append(powerType==null?"":(powerType==1?"鐣滅數姹犱緵鐢�":"220V渚涚數")); + str.append(powerType==null?"":(powerType==1?"鐣滅數姹犱緵鐢�(1)":"220V渚涚數(0)")); return str.toString() ; } } 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 e8c91f0..bd267ec 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 @@ -5,7 +5,6 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.CodeV202404; import com.dy.common.mw.protocol.p206V202404.ParseParamsForDownV202404; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCd10Vo; import com.dy.common.mw.protocol.p206V202404.downVos.ComCd15Vo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_16_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_16_Down.java index 9a6cfb3..7110c17 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_16_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_16_Down.java @@ -8,8 +8,6 @@ import com.dy.common.mw.protocol.p206V202404.downVos.ComCd16Vo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; -import com.dy.common.util.ByteUtilUnsigned; -import com.dy.common.util.NumUtil; @AnnotationCodeDown(ifAny={ CodeV202404.cd_16 diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_22_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_22_Down.java index def9fdb..ac723e9 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_22_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_22_Down.java @@ -5,11 +5,9 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.CodeV202404; import com.dy.common.mw.protocol.p206V202404.ParseParamsForDownV202404; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCd16Vo; import com.dy.common.mw.protocol.p206V202404.downVos.ComCd22Vo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; -import com.dy.common.util.ByteUtilUnsigned; @AnnotationCodeDown(ifAny={ CodeV202404.cd_22 diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_23_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_23_Down.java index 7ccb336..bc76a1c 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_23_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_23_Down.java @@ -5,7 +5,6 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.CodeV202404; import com.dy.common.mw.protocol.p206V202404.ParseParamsForDownV202404; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCd21Vo; import com.dy.common.mw.protocol.p206V202404.downVos.ComCd23Vo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_24_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_24_Down.java index 5f46b3d..d0a2096 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_24_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_24_Down.java @@ -5,13 +5,10 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.CodeV202404; import com.dy.common.mw.protocol.p206V202404.ParseParamsForDownV202404; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCd23Vo; import com.dy.common.mw.protocol.p206V202404.downVos.ComCd24Vo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; import com.dy.common.util.NumUtil; - -import java.nio.charset.StandardCharsets; @AnnotationCodeDown(ifAny={ CodeV202404.cd_24 @@ -84,7 +81,7 @@ bytes = ByteUtil.bytesMerge(bytes, bs) ; - byte[] bsRg = ByteUtil.hexToBytes(cvo.registerNo) ; + byte[] bsRg = ByteUtil.hex2Bytes(cvo.registerNo) ; bytes = ByteUtil.bytesMerge(bytes, bsRg) ; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_25_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_25_Down.java index 6b457b5..4b2b23e 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_25_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_25_Down.java @@ -1,11 +1,9 @@ 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; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCdXyVo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_26_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_26_Down.java index 41e76da..6157183 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_26_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_26_Down.java @@ -5,7 +5,6 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.CodeV202404; import com.dy.common.mw.protocol.p206V202404.ParseParamsForDownV202404; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCd22Vo; import com.dy.common.mw.protocol.p206V202404.downVos.ComCd26Vo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_30_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_30_Down.java index c0e00ca..c762ac9 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_30_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_30_Down.java @@ -1,11 +1,9 @@ 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; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCdXyVo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_50_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_50_Down.java index a7c732d..c731c25 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_50_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_50_Down.java @@ -1,11 +1,9 @@ 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; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCdXyVo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_55_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_55_Down.java index 12ccd88..4c53b38 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_55_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_55_Down.java @@ -6,7 +6,6 @@ import com.dy.common.mw.protocol.p206V202404.CodeV202404; import com.dy.common.mw.protocol.p206V202404.ParseParamsForDownV202404; import com.dy.common.mw.protocol.p206V202404.downVos.ComCd55Vo; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCd65Vo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_56_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_56_Down.java index 16c34ba..8be3208 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_56_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_56_Down.java @@ -1,11 +1,9 @@ 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; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCdXyVo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_56_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_56_Up.java index 87c4ddc..10a4c96 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_56_Up.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_56_Up.java @@ -3,10 +3,8 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.*; -import com.dy.common.mw.protocol.p206V202404.upVos.DataCd50Vo; import com.dy.common.mw.protocol.p206V202404.upVos.DataCd56Vo; import com.dy.common.util.ByteUtil; -import com.dy.common.util.ByteUtilUnsigned; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_5B_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_5B_Down.java index 7c3cd86..2d67b6e 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_5B_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_5B_Down.java @@ -1,11 +1,9 @@ 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; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCdXyVo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_5C_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_5C_Up.java index 9acc765..71111b7 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_5C_Up.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_5C_Up.java @@ -3,7 +3,6 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.*; -import com.dy.common.mw.protocol.p206V202404.parse.global.GlParse; import com.dy.common.mw.protocol.p206V202404.upVos.DataCd5CVo; import com.dy.common.util.ByteUtil; import org.apache.logging.log4j.LogManager; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_68_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_68_Down.java index 60bf2d8..16650d5 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_68_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_68_Down.java @@ -1,11 +1,9 @@ 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; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCdXyVo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_68_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_68_Up.java index 2ff1fda..90cf437 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_68_Up.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_68_Up.java @@ -5,7 +5,6 @@ import com.dy.common.mw.protocol.p206V202404.*; import com.dy.common.mw.protocol.p206V202404.upVos.DataCd68Vo; import com.dy.common.util.ByteUtil; -import com.dy.common.util.ByteUtilUnsigned; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_83_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_83_Down.java index d69cd5e..6e3e57f 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_83_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_83_Down.java @@ -4,7 +4,6 @@ import com.dy.common.mw.protocol.p206V202404.CodeV202404; import com.dy.common.mw.protocol.p206V202404.ParseParamsForDownV202404; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; -import com.dy.common.mw.protocol.p206V202404.upVos.DataCd02Vo; import com.dy.common.mw.protocol.p206V202404.upVos.DataCd83Vo; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_84_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_84_Down.java index 16d691d..3bcc634 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_84_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_84_Down.java @@ -4,7 +4,6 @@ import com.dy.common.mw.protocol.p206V202404.CodeV202404; import com.dy.common.mw.protocol.p206V202404.ParseParamsForDownV202404; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; -import com.dy.common.mw.protocol.p206V202404.upVos.DataCd83Vo; import com.dy.common.mw.protocol.p206V202404.upVos.DataCd84Vo; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_84_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_84_Up.java index 3f98625..db78c79 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_84_Up.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_84_Up.java @@ -4,7 +4,6 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.*; import com.dy.common.mw.protocol.p206V202404.parse.global.GlParse; -import com.dy.common.mw.protocol.p206V202404.upVos.DataCd83Vo; import com.dy.common.mw.protocol.p206V202404.upVos.DataCd84Vo; import com.dy.common.util.ByteUtil; import org.apache.logging.log4j.LogManager; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_85_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_85_Down.java index f8e6718..3033d14 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_85_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_85_Down.java @@ -5,7 +5,6 @@ import com.dy.common.mw.protocol.p206V202404.ParseParamsForDownV202404; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.mw.protocol.p206V202404.upVos.DataCd85Vo; -import com.dy.common.mw.protocol.p206V202404.upVos.DataCd93_A3Vo; import com.dy.common.util.ByteUtil; @AnnotationCodeDown(ifAny={ diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_85_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_85_Up.java index 30e75e8..b1dcd51 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_85_Up.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_85_Up.java @@ -5,7 +5,6 @@ import com.dy.common.mw.protocol.p206V202404.*; import com.dy.common.mw.protocol.p206V202404.parse.global.GlParse; import com.dy.common.mw.protocol.p206V202404.upVos.DataCd85Vo; -import com.dy.common.mw.protocol.p206V202404.upVos.DataCd93_A3Vo; import com.dy.common.util.ByteUtil; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_86_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_86_Down.java index 8ae70ae..ed022cf 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_86_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_86_Down.java @@ -5,7 +5,6 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.CodeV202404; import com.dy.common.mw.protocol.p206V202404.ParseParamsForDownV202404; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCd21Vo; import com.dy.common.mw.protocol.p206V202404.downVos.ComCd86Vo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_87_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_87_Up.java index c5c4369..64de90a 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_87_Up.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_87_Up.java @@ -2,7 +2,6 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.*; -import com.dy.common.mw.protocol.p206V202404.upVos.DataCd86Vo; import com.dy.common.mw.protocol.p206V202404.upVos.DataCd87Vo; import com.dy.common.util.ByteUtil; import com.dy.common.util.ByteUtilUnsigned; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_88_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_88_Down.java index 7e8bdde..d7eff16 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_88_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_88_Down.java @@ -1,12 +1,9 @@ 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; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCd87Vo; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCdXyVo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_88_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_88_Up.java index 2e2474a..79459c6 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_88_Up.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_88_Up.java @@ -2,7 +2,6 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.*; -import com.dy.common.mw.protocol.p206V202404.upVos.DataCd87Vo; import com.dy.common.mw.protocol.p206V202404.upVos.DataCd88Vo; import com.dy.common.util.ByteUtil; import com.dy.common.util.ByteUtilUnsigned; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Down.java index 00cebd7..b4be867 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Down.java @@ -5,7 +5,6 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.CodeV202404; import com.dy.common.mw.protocol.p206V202404.ParseParamsForDownV202404; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCd22Vo; import com.dy.common.mw.protocol.p206V202404.downVos.ComCd92_A2Vo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Up.java index 0fbd96e..c83a4ee 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Up.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Up.java @@ -3,7 +3,6 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.*; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCd92_A2Vo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlParse; import com.dy.common.mw.protocol.p206V202404.upVos.DataCd92_A2Vo; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_93_A3_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_93_A3_Down.java index 1588e7a..ed4ab15 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_93_A3_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_93_A3_Down.java @@ -5,7 +5,6 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.CodeV202404; import com.dy.common.mw.protocol.p206V202404.ParseParamsForDownV202404; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCd92_A2Vo; import com.dy.common.mw.protocol.p206V202404.downVos.ComCd93_A3Vo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_97_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_97_Down.java index a3fcdeb..8767d4b 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_97_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_97_Down.java @@ -1,11 +1,9 @@ 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; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCdXyVo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_98_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_98_Down.java index 33edc52..9ea23cd 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_98_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_98_Down.java @@ -1,11 +1,9 @@ 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; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCdXyVo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_99_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_99_Down.java index 339656a..22cc064 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_99_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_99_Down.java @@ -1,11 +1,9 @@ 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; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCdXyVo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9A_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9A_Down.java index 85312c8..2d110f5 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9A_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9A_Down.java @@ -1,11 +1,9 @@ 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; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCdXyVo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9A_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9A_Up.java index 5bb4d97..9d48d49 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9A_Up.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9A_Up.java @@ -3,7 +3,6 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.*; import com.dy.common.mw.protocol.p206V202404.upVos.DataCd9AVo; -import com.dy.common.mw.protocol.p206V202404.upVos.DataCdXyVo; import com.dy.common.util.ByteUtil; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9C_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9C_Down.java index 5192cdf..df147cf 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9C_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9C_Down.java @@ -5,11 +5,9 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.CodeV202404; import com.dy.common.mw.protocol.p206V202404.ParseParamsForDownV202404; -import com.dy.common.mw.protocol.p206V202404.downVos.ComCd15Vo; import com.dy.common.mw.protocol.p206V202404.downVos.ComCd9CVo; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; import com.dy.common.util.ByteUtil; -import com.dy.common.util.NumUtil; @AnnotationCodeDown(ifAny={ CodeV202404.cd_9C diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Down.java index 3550556..b497f26 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Down.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Down.java @@ -4,7 +4,6 @@ import com.dy.common.mw.protocol.p206V202404.CodeV202404; import com.dy.common.mw.protocol.p206V202404.ParseParamsForDownV202404; import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; -import com.dy.common.mw.protocol.p206V202404.upVos.DataCd02Vo; import com.dy.common.mw.protocol.p206V202404.upVos.DataCdC2Vo; import com.dy.common.util.ByteUtil; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Up.java index d5f5326..3c6af4c 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Up.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Up.java @@ -4,7 +4,6 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.*; import com.dy.common.mw.protocol.p206V202404.parse.global.GlParse; -import com.dy.common.mw.protocol.p206V202404.upVos.DataCd02Vo; import com.dy.common.mw.protocol.p206V202404.upVos.DataCdC2Vo; import com.dy.common.util.ByteUtil; import org.apache.logging.log4j.LogManager; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/ByteUtil.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/ByteUtil.java index d981669..f3f8dfc 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/ByteUtil.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/ByteUtil.java @@ -892,47 +892,107 @@ * @return 杩斿洖 String */ public static String bytes2Hex(byte[] src, boolean hasBlank){ - StringBuilder stringBuilder = new StringBuilder(""); - if (src == null || src.length <= 0) { - return null; - } - for (int i = 0; i < src.length; i++) { - int v = src[i] & 0xFF; - String str = Integer.toHexString(v); - if (str.length() < 2) { - str = "0" + str; - } - if (hasBlank) { - if (i == 0) { - stringBuilder.append(str); - } else { - stringBuilder.append(" " + str); - } - } else { - stringBuilder.append(str); - } - } - return stringBuilder.toString().toUpperCase(Locale.US); + return bytes2Hex_BE(src, hasBlank) ; } + + /** + * 瀛楄妭鏁扮粍杞崲鎴愬崄鍏繘鍒剁殑瀛楃涓� + * + * @param src byte[] + * @param hasBlank 16杩涘埗鏄惁鐢ㄧ┖鏍煎垎闅� + * @return 杩斿洖 String + */ + public static String bytes2Hex_BE(byte[] src, boolean hasBlank){ + StringBuilder stringBuilder = new StringBuilder(""); + if (src == null || src.length <= 0) { + return null; + } + for (int i = 0; i < src.length; i++) { + int v = src[i] & 0xFF; + String str = Integer.toHexString(v); + if (str.length() < 2) { + str = "0" + str; + } + if (hasBlank) { + if (i == 0) { + stringBuilder.append(str); + } else { + stringBuilder.append(" " + str); + } + } else { + stringBuilder.append(str); + } + } + return stringBuilder.toString().toUpperCase(Locale.US); + } + /** + * 瀛楄妭鏁扮粍杞崲鎴愬崄鍏繘鍒剁殑瀛楃涓� + * + * @param src byte[] + * @param hasBlank 16杩涘埗鏄惁鐢ㄧ┖鏍煎垎闅� + * @return 杩斿洖 String + */ + public static String bytes2Hex_LE(byte[] src, boolean hasBlank){ + StringBuilder stringBuilder = new StringBuilder(""); + if (src == null || src.length <= 0) { + return null; + } + for (int i = src.length - 1 ; i >= 0; i--) { + int v = src[i] & 0xFF; + String str = Integer.toHexString(v); + if (str.length() < 2) { + str = "0" + str; + } + if (hasBlank) { + if (i == 0) { + stringBuilder.append(str); + } else { + stringBuilder.append(" " + str); + } + } else { + stringBuilder.append(str); + } + } + return stringBuilder.toString().toUpperCase(Locale.US); + } /** * 瀛楄妭鏁扮粍杞崲鎴愬崄鍏繘鍒剁殑瀛楃涓� * - * @param src byte[] + * @param bs byte[] * @param hasBlank 16杩涘埗鏄惁鐢ㄧ┖鏍煎垎闅� * @param from 寮�濮嬩綅 * @param len 闀垮害 * @return 杩斿洖 String */ - public static String bytes2Hex(byte[] src, boolean hasBlank, int from, int len){ - if (src == null || src.length <= 0 || src.length < from + len) { + public static String bytes2Hex(byte[] bs, boolean hasBlank, int from, int len){ + if (bs == null || bs.length <= 0 || bs.length < from + len) { return null; } byte[] bb = new byte[len]; for (int i = 0 ; i < len; i++) { - bb[i] = src[from + i]; + bb[i] = bs[from + i]; } return bytes2Hex(bb, hasBlank) ; } + /** + * 瀛楄妭鏁扮粍杞崲鎴愬崄鍏繘鍒剁殑瀛楃涓� + * + * @param bs byte[] + * @param hasBlank 16杩涘埗鏄惁鐢ㄧ┖鏍煎垎闅� + * @param from 寮�濮嬩綅 + * @param len 闀垮害 + * @return 杩斿洖 String + */ + public static String bytes2Hex_LE(byte[] bs, boolean hasBlank, int from, int len){ + if (bs == null || bs.length <= 0 || bs.length < from + len) { + return null; + } + byte[] bb = new byte[len]; + for (int i = 0 ; i < len; i++) { + bb[i] = bs[from + i]; + } + return bytes2Hex_LE(bb, hasBlank) ; + } /** * 鍗佸叚杩涘埗杞瓧鑺傛暟缁� * @param hex the hex string @@ -976,77 +1036,106 @@ } private static final char[] HEX_CHAR = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'}; - /** - * 灏哹yte[]杞崲涓�16杩涘埗瀛楃涓� - * - * @param bytes 寰呰浆鎹yte[] - * @return 杩斿洖 杞崲鍚庣殑瀛楃涓� - */ - public static String bytesToHex(byte[] bytes) { - //涓�涓猙yte涓�8浣嶏紝鍙敤涓や釜鍗佸叚杩涘埗浣嶆爣璇� - char[] buf = new char[bytes.length * 2]; - int a = 0; - int index = 0; - for (byte b : bytes) { // 浣跨敤闄や笌鍙栦綑杩涜杞崲 - if (b < 0) { - a = 256 + b; - } else { - a = b; - } - - buf[index++] = HEX_CHAR[a / 16]; - buf[index++] = HEX_CHAR[a % 16]; - } - return new String(buf); - } - /** - * 灏哹yte[]杞崲涓�16杩涘埗瀛楃涓� - * - * @param bytes 寰呰浆鎹yte[] - * @return 杩斿洖 杞崲鍚庣殑瀛楃涓� - */ - public static String bytesToHex(byte[] bytes, int startIndex, int endIndex) { - byte[] bs = new byte[endIndex - startIndex + 1] ; - byte j = 0 ; - for(int i = startIndex; i <= endIndex; i++){ - bs[j++] = bytes[i] ; - } - //涓�涓猙yte涓�8浣嶏紝鍙敤涓や釜鍗佸叚杩涘埗浣嶆爣璇� - char[] buf = new char[bs.length * 2]; - int a = 0; - int index = 0; - for (byte b : bs) { // 浣跨敤闄や笌鍙栦綑杩涜杞崲 - if (b < 0) { - a = 256 + b; - } else { - a = b; - } - - buf[index++] = HEX_CHAR[a / 16]; - buf[index++] = HEX_CHAR[a % 16]; - } - return new String(buf); - } - - /** - * 灏�16杩涘埗瀛楃涓茶浆鎹负byte[] - * - * @param str 寰呰浆鎹㈠瓧绗︿覆 - * @return 杩斿洖 杞崲鍚庣殑byte[] - */ - public static byte[] hexToBytes(String str) { - if (str == null || "".equals(str.trim())) { - return new byte[0]; - } - - byte[] bytes = new byte[str.length() / 2]; - for (int i = 0; i < str.length() / 2; i++) { - String subStr = str.substring(i * 2, i * 2 + 2); - bytes[i] = (byte) Integer.parseInt(subStr, 16); - } - - return bytes; - } +// /** +// * 灏哹yte[]杞崲涓�16杩涘埗瀛楃涓� +// * +// * @param bytes 寰呰浆鎹yte[] +// * @return 杩斿洖 杞崲鍚庣殑瀛楃涓� +// */ +// public static String bytesToHex(byte[] bytes) { +// //涓�涓猙yte涓�8浣嶏紝鍙敤涓や釜鍗佸叚杩涘埗浣嶆爣璇� +// char[] buf = new char[bytes.length * 2]; +// int a = 0; +// int index = 0; +// for (byte b : bytes) { // 浣跨敤闄や笌鍙栦綑杩涜杞崲 +// if (b < 0) { +// a = 256 + b; +// } else { +// a = b; +// } +// +// buf[index++] = HEX_CHAR[a / 16]; +// buf[index++] = HEX_CHAR[a % 16]; +// } +// return new String(buf); +// } +// /** +// * 灏哹yte[]杞崲涓�16杩涘埗瀛楃涓� +// * +// * @param bytes 寰呰浆鎹yte[] +// * @return 杩斿洖 杞崲鍚庣殑瀛楃涓� +// */ +// public static String bytesToHex_BE(byte[] bytes, int startIndex, int endIndex) { +// byte[] bs = new byte[endIndex - startIndex + 1] ; +// byte j = 0 ; +// for(int i = startIndex; i <= endIndex; i++){ +// bs[j++] = bytes[i] ; +// } +// //涓�涓猙yte涓�8浣嶏紝鍙敤涓や釜鍗佸叚杩涘埗浣嶆爣璇� +// char[] buf = new char[bs.length * 2]; +// int a = 0; +// int index = 0; +// for (byte b : bs) { // 浣跨敤闄や笌鍙栦綑杩涜杞崲 +// if (b < 0) { +// a = 256 + b; +// } else { +// a = b; +// } +// +// buf[index++] = HEX_CHAR[a / 16]; +// buf[index++] = HEX_CHAR[a % 16]; +// } +// return new String(buf); +// } +// +// /** +// * 灏哹yte[]杞崲涓�16杩涘埗瀛楃涓� +// * +// * @param bytes 寰呰浆鎹yte[] +// * @return 杩斿洖 杞崲鍚庣殑瀛楃涓� +// */ +// public static String bytesToHex_LE(byte[] bytes, int startIndex, int endIndex) { +// byte[] bs = new byte[endIndex - startIndex + 1] ; +// byte j = 0 ; +// for(int i = endIndex; i >= startIndex; i--){ +// bs[j++] = bytes[i] ; +// } +// //涓�涓猙yte涓�8浣嶏紝鍙敤涓や釜鍗佸叚杩涘埗浣嶆爣璇� +// char[] buf = new char[bs.length * 2]; +// int a = 0; +// int index = 0; +// for (byte b : bs) { // 浣跨敤闄や笌鍙栦綑杩涜杞崲 +// if (b < 0) { +// a = 256 + b; +// } else { +// a = b; +// } +// +// buf[index++] = HEX_CHAR[a / 16]; +// buf[index++] = HEX_CHAR[a % 16]; +// } +// return new String(buf); +// } +// +// /** +// * 灏�16杩涘埗瀛楃涓茶浆鎹负byte[] +// * +// * @param str 寰呰浆鎹㈠瓧绗︿覆 +// * @return 杩斿洖 杞崲鍚庣殑byte[] +// */ +// public static byte[] hexToBytes(String str) { +// if (str == null || "".equals(str.trim())) { +// return new byte[0]; +// } +// +// byte[] bytes = new byte[str.length() / 2]; +// for (int i = 0; i < str.length() / 2; i++) { +// String subStr = str.substring(i * 2, i * 2 + 2); +// bytes[i] = (byte) Integer.parseInt(subStr, 16); +// } +// +// return bytes; +// } /** * Convert char to byte diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/MD5.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/MD5.java index 96b6ba2..63630f6 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/MD5.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/MD5.java @@ -1,7 +1,6 @@ package com.dy.common.util; import java.security.MessageDigest; -import java.security.NoSuchAlgorithmException; public class MD5 { /** diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmAlarmStateHistory.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmAlarmStateHistory.java index e15bc35..474690b 100644 --- a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmAlarmStateHistory.java +++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmAlarmStateHistory.java @@ -5,7 +5,11 @@ import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; +import com.dy.common.mw.protocol.p206V1_0_0.DataV1_0_1; +import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataAlarmVo; +import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataStateVo; import com.dy.common.po.BaseEntity; +import com.dy.common.util.DateTime; import com.fasterxml.jackson.annotation.JsonFormat; import io.swagger.v3.oas.annotations.media.Schema; import lombok.*; @@ -151,4 +155,32 @@ */ public Byte alarmValve; + /** + * 渚涚數鏂瑰紡锛�0: 220V锛�1锛氳搫鐢垫睜锛� + */ + public Byte powerType; + + + public void valueFrom(DataV1_0_1 dV1_0_1, String rtuDt, DataAlarmVo alarmVo, DataStateVo stateVo) throws Exception{ + this.dt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt) ; + this.rtuDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(rtuDt) ; + this.valveState = stateVo==null?null:stateVo.valveState; //鐘舵��-闃�闂�/娉碉紙1鎵撳紑銆�0鍏抽棴 + this.alarmRemainWater = (byte)0; //鍓╀綑姘撮噺鎶ヨ (1锛氬皬浜庢姤璀︿笂闄愭姤璀� 0锛氭甯�) + this.alarm0WaterRemain = (byte)0; //鍓╀綑姘撮噺涓�0鍏虫车/闃� (1锛氬墿浣欐按閲忎负0鍏虫车 0锛氭甯�) + this.alarmExceedYear = (byte)0; //骞寸敤姘撮噺澶т簬闄愬埗姘撮噺鎶ヨ(1锛氭姤璀� 0锛氭甯�) + this.alarmWaterMeterFault = alarmVo==null?null:alarmVo.meter; // 娴侀噺璁℃晠闅�(1锛氭姤璀︼紝0锛氭甯�) + this.alarmLoss = alarmVo==null?null:alarmVo.loss; // 婕忔崯(鍋锋按)鎶ヨ(1锛氭姤璀︼紝 0锛氭甯�) + this.alarmWaterMeterBreak = (byte)0; //娴侀噺璁℃崯鍧�(姝e父閫氳浣嗙灛鏃朵负0)鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) + this.alarmEleMeterFault = (byte)0; //鐢佃〃鏁呴殰鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) + this.alarm0MoneyRemain = (byte)0; //鍓╀綑閲戦涓�0(1锛氭姤璀︼紝0锛氭甯�) + this.alarmInnerDoor = (byte)0; //鎺у埗鍣ㄥ唴闂ㄦ姤璀�(1锛氭姤璀︼紝0锛氭甯�) + this.alarmOuterDoor = (byte)0; //鎺у埗鍣ㄥ闂ㄦ墦寮�鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) + this.alarmEleMiss = (byte)0; //浜ゆ祦缂洪」鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) + this.alarmEleExceed = (byte)0; //浜ゆ祦杩囨祦鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) + this.alarmEleLowVolt = (byte)0; //涓夌浉鐢垫瑺鍘嬫姤璀�(1锛氭姤璀︼紝0锛氭甯�) + this.stateIcEnable = stateVo==null?null:stateVo.icCard; //IC鍗$姸鎬�(1銆佹湁鏁堬紝0锛氭棤鏁�) + this.alarmBatteryVolt = alarmVo==null?null:alarmVo.batteryVolt; //鐢垫睜鐢靛帇(1锛氭姤璀︼紝0锛氭甯�) + this.alarmValve = alarmVo==null?null:alarmVo.valve; //闃�闂ㄦ姤璀�(1锛氭姤璀︼紝0锛氭甯�) + this.powerType = stateVo==null?null:stateVo.powerType; //渚涚數鏂瑰紡锛�0: 220V锛�1锛氳搫鐢垫睜锛� + } } \ No newline at end of file diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmAlarmStateLast.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmAlarmStateLast.java index d2eefc7..fe09f57 100644 --- a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmAlarmStateLast.java +++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmAlarmStateLast.java @@ -5,7 +5,11 @@ import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; +import com.dy.common.mw.protocol.p206V1_0_0.DataV1_0_1; +import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataAlarmVo; +import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataStateVo; import com.dy.common.po.BaseEntity; +import com.dy.common.util.DateTime; import com.fasterxml.jackson.annotation.JsonFormat; import io.swagger.v3.oas.annotations.media.Schema; import lombok.*; @@ -67,7 +71,7 @@ public Date rtuDt; /** - * 鐘舵��-闃�闂�/娉碉紙1鎵撳紑銆�0鍏抽棴锛� + * 鐘舵��-闃�闂�/娉碉紙0鎵撳紑銆�1鍏抽棴锛� */ public Byte valveState; @@ -151,4 +155,58 @@ */ public Byte alarmValve; + /** + * 渚涚數鏂瑰紡锛�0: 220V锛�1锛氳搫鐢垫睜锛� + */ + public Byte powerType; + + public void valueFrom(DataV1_0_1 dV1_0_1, String rtuDt, DataAlarmVo alarmVo, DataStateVo stateVo) throws Exception{ + this.dt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt) ; + this.rtuDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(rtuDt) ; + this.valveState = stateVo==null?null:stateVo.valveState; //鐘舵��-闃�闂�/娉碉紙1鎵撳紑銆�0鍏抽棴 + this.alarmRemainWater = (byte)0; //鍓╀綑姘撮噺鎶ヨ (1锛氬皬浜庢姤璀︿笂闄愭姤璀� 0锛氭甯�) + this.alarm0WaterRemain = (byte)0; //鍓╀綑姘撮噺涓�0鍏虫车/闃� (1锛氬墿浣欐按閲忎负0鍏虫车 0锛氭甯�) + this.alarmExceedYear = (byte)0; //骞寸敤姘撮噺澶т簬闄愬埗姘撮噺鎶ヨ(1锛氭姤璀� 0锛氭甯�) + this.alarmWaterMeterFault = alarmVo==null?null:alarmVo.meter; // 娴侀噺璁℃晠闅�(1锛氭姤璀︼紝0锛氭甯�) + this.alarmLoss = alarmVo==null?null:alarmVo.loss; // 婕忔崯(鍋锋按)鎶ヨ(1锛氭姤璀︼紝 0锛氭甯�) + this.alarmWaterMeterBreak = (byte)0; //娴侀噺璁℃崯鍧�(姝e父閫氳浣嗙灛鏃朵负0)鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) + this.alarmEleMeterFault = (byte)0; //鐢佃〃鏁呴殰鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) + this.alarm0MoneyRemain = (byte)0; //鍓╀綑閲戦涓�0(1锛氭姤璀︼紝0锛氭甯�) + this.alarmInnerDoor = (byte)0; //鎺у埗鍣ㄥ唴闂ㄦ姤璀�(1锛氭姤璀︼紝0锛氭甯�) + this.alarmOuterDoor = (byte)0; //鎺у埗鍣ㄥ闂ㄦ墦寮�鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) + this.alarmEleMiss = (byte)0; //浜ゆ祦缂洪」鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) + this.alarmEleExceed = (byte)0; //浜ゆ祦杩囨祦鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) + this.alarmEleLowVolt = (byte)0; //涓夌浉鐢垫瑺鍘嬫姤璀�(1锛氭姤璀︼紝0锛氭甯�) + this.stateIcEnable = stateVo==null?null:stateVo.icCard; //IC鍗$姸鎬�(1銆佹湁鏁堬紝0锛氭棤鏁�) + this.alarmBatteryVolt = alarmVo==null?null:alarmVo.batteryVolt; //鐢垫睜鐢靛帇(1锛氭姤璀︼紝0锛氭甯�) + this.alarmValve = alarmVo==null?null:alarmVo.valve; //闃�闂ㄦ姤璀�(1锛氭姤璀︼紝0锛氭甯�) + this.powerType = stateVo==null?null:stateVo.powerType; //渚涚數鏂瑰紡锛�0: 220V锛�1锛氳搫鐢垫睜锛� + } + + public void updateFrom(DataV1_0_1 dV1_0_1, String rtuDt, DataAlarmVo alarmVo, DataStateVo stateVo) throws Exception{ + this.dt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt) ; + this.rtuDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(rtuDt) ; + if(alarmVo != null){ + this.alarmBatteryVolt = alarmVo.batteryVolt ; + this.alarmLoss = alarmVo.loss ; + this.alarmWaterMeterBreak = alarmVo.meter ; + this.alarmValve = alarmVo.valve ; + }/*else{ + this.alarmBatteryVolt = null ; + this.alarmLoss = null ; + this.alarmWaterMeterBreak = null ; + this.alarmValve = null ; + }*/ + if(stateVo != null){ + this.stateIcEnable = stateVo.icCard ; + this.valveState = stateVo.valveState; + this.powerType = stateVo.powerType; + //this.valveState = stateVo.valve ; + }/*else{ + this.stateIcEnable = null ; + this.valveState = null ; + this.powerType = null ; + //this.valveState = null ; + }*/ + } } \ No newline at end of file diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmOpenCloseValveLast.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmOpenCloseValveLast.java index 9eef5cf..949b6e1 100644 --- a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmOpenCloseValveLast.java +++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmOpenCloseValveLast.java @@ -67,7 +67,7 @@ /** * 寮�闃�鏁版嵁鎺ユ敹鏃ユ湡鏃堕棿 */ - @Schema(description = "鏁版嵁鎺ユ敹鏃ユ湡鏃堕棿", requiredMode = Schema.RequiredMode.NOT_REQUIRED) + @Schema(description = "寮�闃�鏁版嵁鎺ユ敹鏃ユ湡鏃堕棿", requiredMode = Schema.RequiredMode.NOT_REQUIRED) @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") public Date opDt; diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmWorkReportHistory.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmWorkReportHistory.java index 313bc5c..054d6b8 100644 --- a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmWorkReportHistory.java +++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmWorkReportHistory.java @@ -260,7 +260,7 @@ this.dt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt); this.rtuDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt); //this.orderNo = cdData.orderNo ; - //this.icCardAddr = cdData.icCardAddr ; + this.icCardAddr = cdData.cardAddr ; this.icCardNo = cdData.cardNo ; //this.waterLevel = cdData.waterLevel ; //this.waterPress = cdData.waterPress ; diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmWorkReportLast.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmWorkReportLast.java index c51c98f..97b522b 100644 --- a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmWorkReportLast.java +++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmWorkReportLast.java @@ -259,7 +259,7 @@ this.dt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt); this.rtuDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt); //this.orderNo = cdData.orderNo ; - //this.icCardAddr = cdData.icCardAddr ; + this.icCardAddr = cdData.cardAddr ; this.icCardNo = cdData.cardNo ; //this.waterLevel = cdData.waterLevel ; //this.waterPress = cdData.waterPress ; diff --git a/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmAlarmStateHistoryMapper.xml b/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmAlarmStateHistoryMapper.xml index 6f610a5..dcddb9b 100644 --- a/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmAlarmStateHistoryMapper.xml +++ b/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmAlarmStateHistoryMapper.xml @@ -27,13 +27,14 @@ <result column="state_ic_enable" jdbcType="TINYINT" property="stateIcEnable" /> <result column="alarm_battery_volt" jdbcType="TINYINT" property="alarmBatteryVolt" /> <result column="alarm_valve" jdbcType="TINYINT" property="alarmValve" /> + <result column="power_type" jdbcType="TINYINT" property="powerType" /> </resultMap> <sql id="Base_Column_List"> <!--@mbg.generated--> id, controller_id, intake_id, rtu_addr, dt, rtu_dt, valve_state, alarm_remain_water, alarm0_water_remain, alarm_exceed_year, alarm_water_meter_fault, alarm_loss, alarm_water_meter_break, alarm_ele_meter_fault, alarm0_money_remain, alarm_inner_door, alarm_outer_door, alarm_ele_miss, - alarm_ele_exceed, alarm_ele_low_volt, state_ic_enable,alarm_battery_volt,alarm_valve + alarm_ele_exceed, alarm_ele_low_volt, state_ic_enable,alarm_battery_volt,alarm_valve,power_type </sql> <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap"> <!--@mbg.generated--> @@ -56,7 +57,7 @@ alarm_loss, alarm_water_meter_break, alarm_ele_meter_fault, alarm0_money_remain, alarm_inner_door, alarm_outer_door, alarm_ele_miss, alarm_ele_exceed, alarm_ele_low_volt, - state_ic_enable,alarm_battery_volt,alarm_valve) + state_ic_enable,alarm_battery_volt,alarm_valve,power_type) values (#{id,jdbcType=BIGINT}, #{controllerId,jdbcType=BIGINT}, #{intakeId,jdbcType=BIGINT}, #{rtuAddr,jdbcType=VARCHAR}, #{dt,jdbcType=TIMESTAMP}, #{rtuDt,jdbcType=TIMESTAMP}, #{valveState,jdbcType=TINYINT}, #{alarmRemainWater,jdbcType=TINYINT}, #{alarm0WaterRemain,jdbcType=TINYINT}, @@ -64,7 +65,8 @@ #{alarmLoss,jdbcType=TINYINT}, #{alarmWaterMeterBreak,jdbcType=TINYINT}, #{alarmEleMeterFault,jdbcType=TINYINT}, #{alarm0MoneyRemain,jdbcType=TINYINT}, #{alarmInnerDoor,jdbcType=TINYINT}, #{alarmOuterDoor,jdbcType=TINYINT}, #{alarmEleMiss,jdbcType=TINYINT}, #{alarmEleExceed,jdbcType=TINYINT}, #{alarmEleLowVolt,jdbcType=TINYINT}, - #{stateIcEnable,jdbcType=TINYINT}, #{alarmBatteryVolt,jdbcType=TINYINT}, #{alarmValve,jdbcType=TINYINT}) + #{stateIcEnable,jdbcType=TINYINT}, #{alarmBatteryVolt,jdbcType=TINYINT}, #{alarmValve,jdbcType=TINYINT}, + #{powerType,jdbcType=TINYINT}) </insert> <insert id="insertSelective" parameterType="com.dy.pipIrrGlobal.pojoRm.RmAlarmStateHistory"> <!--@mbg.generated--> @@ -139,6 +141,9 @@ <if test="alarmValve != null"> alarm_valve, </if> + <if test="powerType != null"> + power_type, + </if> </trim> <trim prefix="values (" suffix=")" suffixOverrides=","> <if test="id != null"> @@ -209,6 +214,9 @@ </if> <if test="alarmValve != null"> #{alarmValve,jdbcType=TINYINT}, + </if> + <if test="powerType != null"> + #{powerType,jdbcType=TINYINT}, </if> </trim> </insert> @@ -282,6 +290,9 @@ <if test="alarmValve != null"> alarm_valve = #{alarmValve,jdbcType=TINYINT}, </if> + <if test="powerType != null"> + power_type = #{powerType,jdbcType=TINYINT}, + </if> </set> where id = #{id,jdbcType=BIGINT} </update> @@ -310,6 +321,7 @@ state_ic_enable = #{stateIcEnable,jdbcType=TINYINT}, alarm_battery_volt = #{alarmBatteryVolt,jdbcType=TINYINT}, alarm_valve = #{alarmValve,jdbcType=TINYINT}, + power_type = #{powerType,jdbcType=TINYINT} where id = #{id,jdbcType=BIGINT} </update> </mapper> \ No newline at end of file diff --git a/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmAlarmStateLastMapper.xml b/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmAlarmStateLastMapper.xml index 0402aec..c9fee5d 100644 --- a/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmAlarmStateLastMapper.xml +++ b/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmAlarmStateLastMapper.xml @@ -27,13 +27,14 @@ <result column="state_ic_enable" jdbcType="TINYINT" property="stateIcEnable" /> <result column="alarm_battery_volt" jdbcType="TINYINT" property="alarmBatteryVolt" /> <result column="alarm_valve" jdbcType="TINYINT" property="alarmValve" /> + <result column="power_type" jdbcType="TINYINT" property="alarmValve" /> </resultMap> <sql id="Base_Column_List"> <!--@mbg.generated--> id, controller_id, intake_id, rtu_addr, dt, rtu_dt, valve_state, alarm_remain_water, alarm0_water_remain, alarm_exceed_year, alarm_water_meter_fault, alarm_loss, alarm_water_meter_break, alarm_ele_meter_fault, alarm0_money_remain, alarm_inner_door, alarm_outer_door, alarm_ele_miss, - alarm_ele_exceed, alarm_ele_low_volt, state_ic_enable,alarm_battery_volt,alarm_valve + alarm_ele_exceed, alarm_ele_low_volt, state_ic_enable,alarm_battery_volt,alarm_valve,power_type </sql> <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap"> <!--@mbg.generated--> @@ -63,7 +64,7 @@ alarm_loss, alarm_water_meter_break, alarm_ele_meter_fault, alarm0_money_remain, alarm_inner_door, alarm_outer_door, alarm_ele_miss, alarm_ele_exceed, alarm_ele_low_volt, - state_ic_enable,alarm_battery_volt,alarm_valve) + state_ic_enable,alarm_battery_volt,alarm_valve,power_type) values (#{id,jdbcType=BIGINT}, #{controllerId,jdbcType=BIGINT}, #{intakeId,jdbcType=BIGINT}, #{rtuAddr,jdbcType=VARCHAR}, #{dt,jdbcType=TIMESTAMP}, #{rtuDt,jdbcType=TIMESTAMP}, #{valveState,jdbcType=TINYINT}, #{alarmRemainWater,jdbcType=TINYINT}, #{alarm0WaterRemain,jdbcType=TINYINT}, @@ -71,7 +72,8 @@ #{alarmLoss,jdbcType=TINYINT}, #{alarmWaterMeterBreak,jdbcType=TINYINT}, #{alarmEleMeterFault,jdbcType=TINYINT}, #{alarm0MoneyRemain,jdbcType=TINYINT}, #{alarmInnerDoor,jdbcType=TINYINT}, #{alarmOuterDoor,jdbcType=TINYINT}, #{alarmEleMiss,jdbcType=TINYINT}, #{alarmEleExceed,jdbcType=TINYINT}, #{alarmEleLowVolt,jdbcType=TINYINT}, - #{stateIcEnable,jdbcType=TINYINT}, #{alarmBatteryVolt,jdbcType=TINYINT}, #{alarmValve,jdbcType=TINYINT}) + #{stateIcEnable,jdbcType=TINYINT}, #{alarmBatteryVolt,jdbcType=TINYINT}, #{alarmValve,jdbcType=TINYINT}, + #{powerType,jdbcType=TINYINT}) </insert> <insert id="insertSelective" parameterType="com.dy.pipIrrGlobal.pojoRm.RmAlarmStateLast"> <!--@mbg.generated--> @@ -146,6 +148,9 @@ <if test="alarmValve != null"> alarm_valve, </if> + <if test="powerType != null"> + power_type, + </if> </trim> <trim prefix="values (" suffix=")" suffixOverrides=","> <if test="id != null"> @@ -216,6 +221,9 @@ </if> <if test="alarmValve != null"> #{alarmValve,jdbcType=TINYINT}, + </if> + <if test="powerType != null"> + #{powerType,jdbcType=TINYINT}, </if> </trim> </insert> @@ -289,6 +297,9 @@ <if test="alarmValve != null"> alarm_valve = #{alarmValve,jdbcType=TINYINT}, </if> + <if test="powerType != null"> + power_type = #{powerType,jdbcType=TINYINT}, + </if> </set> where id = #{id,jdbcType=BIGINT} </update> @@ -317,6 +328,7 @@ state_ic_enable = #{stateIcEnable,jdbcType=TINYINT}, alarm_battery_volt = #{alarmBatteryVolt,jdbcType=TINYINT}, alarm_valve = #{alarmValve,jdbcType=TINYINT}, + power_type = #{powerType,jdbcType=TINYINT} where id = #{id,jdbcType=BIGINT} </update> </mapper> \ No newline at end of file diff --git a/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmWorkReportLastMapper.xml b/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmWorkReportLastMapper.xml index 9e6c609..41bb3ed 100644 --- a/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmWorkReportLastMapper.xml +++ b/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmWorkReportLastMapper.xml @@ -407,4 +407,11 @@ water_meter_work_volt = #{waterMeterWorkVolt,jdbcType=FLOAT} where id = #{id,jdbcType=BIGINT} </update> + <select id="selectByRtuAddr" parameterType="java.lang.String" resultMap="BaseResultMap"> + <!--@mbg.generated--> + select + <include refid="Base_Column_List" /> + from rm_work_report_last + where rtu_addr = #{rtuAddr,jdbcType=VARCHAR} + </select> </mapper> \ No newline at end of file diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealAlarmStatus.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealAlarmStatus.java index 3d80663..32e4271 100644 --- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealAlarmStatus.java +++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealAlarmStatus.java @@ -87,28 +87,11 @@ private void saveOrUpdateLast(DbSv sv, PrController controller, String rtuAddr, String rtuDt, DataV1_0_1 dV1_0_1, DataAlarmVo alarmVo, DataStateVo stateVo) throws Exception { RmAlarmStateLast po = sv.getRmAlarmStateLast(rtuAddr) ; if(po == null){ - po = new RmAlarmStateLast(null, controller==null?null:controller.getId(), controller==null?null:controller.getIntakeId(), - rtuAddr, - DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt), - DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(rtuDt), - stateVo==null?null:stateVo.working,//鐘舵��-闃�闂�/娉碉紙1鎵撳紑銆�0鍏抽棴锛� - (byte)0,//鍓╀綑姘撮噺鎶ヨ (1锛氬皬浜庢姤璀︿笂闄愭姤璀� 0锛氭甯�) - (byte)0,//鍓╀綑姘撮噺涓�0鍏虫车/闃� (1锛氬墿浣欐按閲忎负0鍏虫车 0锛氭甯�) - (byte)0,//骞寸敤姘撮噺澶т簬闄愬埗姘撮噺鎶ヨ(1锛氭姤璀� 0锛氭甯�) - alarmVo==null?null:alarmVo.meter,// 娴侀噺璁℃晠闅�(1锛氭姤璀︼紝0锛氭甯�) - alarmVo==null?null:alarmVo.loss,// 婕忔崯(鍋锋按)鎶ヨ(1锛氭姤璀︼紝 0锛氭甯�) - (byte)0,//娴侀噺璁℃崯鍧�(姝e父閫氳浣嗙灛鏃朵负0)鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) - (byte)0,//鐢佃〃鏁呴殰鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) - (byte)0,//鍓╀綑閲戦涓�0(1锛氭姤璀︼紝0锛氭甯�) - (byte)0,//鎺у埗鍣ㄥ唴闂ㄦ姤璀�(1锛氭姤璀︼紝0锛氭甯�) - (byte)0,//鎺у埗鍣ㄥ闂ㄦ墦寮�鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) - (byte)0,//浜ゆ祦缂洪」鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) - (byte)0,//浜ゆ祦杩囨祦鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) - (byte)0,//涓夌浉鐢垫瑺鍘嬫姤璀�(1锛氭姤璀︼紝0锛氭甯�) - stateVo==null?null:stateVo.icCard,//IC鍗$姸鎬�(1銆佹湁鏁堬紝0锛氭棤鏁�) ; - alarmVo==null?null:alarmVo.batteryVolt,//鐢垫睜鐢靛帇(1锛氭姤璀︼紝0锛氭甯�) - alarmVo==null?null:alarmVo.valve//闃�闂ㄦ姤璀�(1锛氭姤璀︼紝0锛氭甯�) - ); + po = new RmAlarmStateLast(); + po.controllerId = controller==null?null:controller.getId() ; + po.intakeId = controller==null?null:controller.getIntakeId() ; + po.rtuAddr = rtuAddr ; + po.valueFrom(dV1_0_1, rtuDt, alarmVo, stateVo); sv.saveRmAlarmStateLast(po) ; }else{ po = this.update(controller, po, rtuDt, dV1_0_1, alarmVo, stateVo) ; @@ -126,28 +109,11 @@ * @param stateVo 鐘舵�佸璞� */ private void saveHistory(DbSv sv, PrController controller, String rtuAddr, String rtuDt, DataV1_0_1 dV1_0_1, DataAlarmVo alarmVo, DataStateVo stateVo) throws Exception { - RmAlarmStateHistory po = new RmAlarmStateHistory(null, controller==null?null:controller.getId(), controller==null?null:controller.getIntakeId(), - rtuAddr, - DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt), - DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(rtuDt), - stateVo==null?null:stateVo.working,//鐘舵��-闃�闂�/娉碉紙1鎵撳紑銆�0鍏抽棴锛� - (byte)0,//鍓╀綑姘撮噺鎶ヨ (1锛氬皬浜庢姤璀︿笂闄愭姤璀� 0锛氭甯�) - (byte)0,//鍓╀綑姘撮噺涓�0鍏虫车/闃� (1锛氬墿浣欐按閲忎负0鍏虫车 0锛氭甯�) - (byte)0,//骞寸敤姘撮噺澶т簬闄愬埗姘撮噺鎶ヨ(1锛氭姤璀� 0锛氭甯�) - alarmVo==null?null:alarmVo.meter,// 娴侀噺璁℃晠闅�(1锛氭姤璀︼紝0锛氭甯�) - alarmVo==null?null:alarmVo.loss,// 婕忔崯(鍋锋按)鎶ヨ(1锛氭姤璀︼紝 0锛氭甯�) - (byte)0,//娴侀噺璁℃崯鍧�(姝e父閫氳浣嗙灛鏃朵负0)鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) - (byte)0,//鐢佃〃鏁呴殰鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) - (byte)0,//鍓╀綑閲戦涓�0(1锛氭姤璀︼紝0锛氭甯�) - (byte)0,//鎺у埗鍣ㄥ唴闂ㄦ姤璀�(1锛氭姤璀︼紝0锛氭甯�) - (byte)0,//鎺у埗鍣ㄥ闂ㄦ墦寮�鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) - (byte)0,//浜ゆ祦缂洪」鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) - (byte)0,//浜ゆ祦杩囨祦鎶ヨ(1锛氭姤璀︼紝0锛氭甯�) - (byte)0,//涓夌浉鐢垫瑺鍘嬫姤璀�(1锛氭姤璀︼紝0锛氭甯�) - stateVo==null?null:stateVo.icCard,//IC鍗$姸鎬�(1銆佹湁鏁堬紝0锛氭棤鏁�) ; - alarmVo==null?null:alarmVo.batteryVolt,//鐢垫睜鐢靛帇(1锛氭姤璀︼紝0锛氭甯�) - alarmVo==null?null:alarmVo.valve//闃�闂ㄦ姤璀�(1锛氭姤璀︼紝0锛氭甯�) - ); + RmAlarmStateHistory po = new RmAlarmStateHistory() ; + po.controllerId = controller==null?null:controller.getId() ; + po.intakeId = controller==null?null:controller.getIntakeId() ; + po.rtuAddr = rtuAddr ; + po.valueFrom(dV1_0_1, rtuDt, alarmVo, stateVo); sv.saveRmAlarmStateHistory(po) ; } @@ -156,28 +122,7 @@ po.controllerId = controller==null?null:controller.getId() ; po.intakeId = controller==null?null:controller.getIntakeId() ; - po.dt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt) ; - po.rtuDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(rtuDt) ; - if(alarmVo != null){ - po.alarmBatteryVolt = alarmVo.batteryVolt ; - po.alarmLoss = alarmVo.loss ; - po.alarmWaterMeterBreak = alarmVo.meter ; - po.alarmValve = alarmVo.valve ; - }/*else{ - po.alarmBatteryVolt = null ; - po.alarmLoss = null ; - po.alarmWaterMeterBreak = null ; - po.alarmValve = null ; - }*/ - if(stateVo != null){ - po.stateIcEnable = stateVo.icCard ; - po.valveState = stateVo.working ; - //po.valvestate = stateVo.valve ; - }/*else{ - po.stateIcEnable = null ; - po.valveState = null ; - //po.valvestate = null ; - }*/ + po.updateFrom(dV1_0_1, rtuDt, alarmVo, stateVo); return po ; } @@ -190,7 +135,7 @@ PrController controller, DataStateVo stateVo){ if(stateVo != null){ - if(stateVo.working != null && stateVo.working.byteValue() == 0){ + if(stateVo.valveState != null && stateVo.valveState.byteValue() == 0){ //闃�闂ㄥ叧闂姸鎬� if(controller != null && controller.getIntakeId() != null){ //铏氭嫙鍗″湪鍙栨按涓殑鍗犵敤鐘舵�佹敼涓洪潪搴旂敤鐘舵�� diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealCloseValveReport.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealCloseValveReport.java index e5ec88e..76b86b6 100644 --- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealCloseValveReport.java +++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealCloseValveReport.java @@ -68,8 +68,7 @@ sv.saveRmOpenCloseValveLast(poLast); }else{ if(poLast.clType == null){ - //鍘熻褰曚笉瀛樺湪鍏抽榾鏁版嵁锛屾墍浠ュ綋鍓嶅叧闃�涓婃姤鏄柊鐨勪竴娆″叧闃�锛屼繚鐣欏師璁板綍涓殑寮�闃�鏁版嵁 - this.updateCloseValve(controller, poLast, null, dV1_0_1, dataCd83CloseVo, false) ; + //鍘熻褰曚笉瀛樺湪鍏抽榾鏁版嵁锛屾墍浠ュ綋鍓嶅叧闃�涓婃姤鏄柊鐨勪竴娆″叧闃� if(poLast.opType == null){ //鍘熻褰曚腑涓嶅瓨鍦ㄥ紑闃�鏁版嵁锛屾病鍔炴硶杩涜鍖归厤 //鐢熸垚骞朵繚瀛樻柊鐨勫叧闃�涓婃姤鍘嗗彶鏁版嵁璁板綍 @@ -80,6 +79,8 @@ if(poLast.lastHistoryId != null){ poHistory = sv.getRmOpenCloseValveHistory(poLast.lastHistoryId) ; if(poHistory != null){ + //褰撳墠鍏抽榾涓婃姤鏄柊鐨勪竴娆″叧闃�锛屼繚鐣欏師璁板綍涓殑寮�闃�鏁版嵁 + this.updateCloseValve(controller, poLast, poHistory, dV1_0_1, dataCd83CloseVo, false) ; sv.updateRmOpenCloseValveHistory(poHistory); }else{ //娌℃湁鍘嗗彶鏁版嵁锛岀敓鎴愬苟淇濆瓨鏂扮殑鍏抽榾涓婃姤鍘嗗彶鏁版嵁璁板綍 @@ -98,12 +99,13 @@ //閲嶅涓婃姤浜嗭紝涓嶈繘琛屽鐞� }else { //褰撳墠涓婃姤鐨勫叧闃�鏁版嵁鏅氫簬鍘熸潵鐨勫叧闃�鏁版嵁锛屾槸鏂扮殑涓婃姤鍏抽榾鏁版嵁 + this.updateCloseValve(controller, poLast, null, dV1_0_1, dataCd83CloseVo, false) ; this.newHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataCd83CloseVo, poLast); } }else{ //if(po.opType == null) //鍘熻褰曚笉瀛樺湪寮�闃�鏁版嵁涔熶笉瀛樺湪鍏抽榾鏁版嵁锛岃繖绉嶆儏鍐典笉瀛樺湪锛屼絾涓哄畨鍏ㄤ篃杩涜澶勭悊 - this.updateCloseValve(controller,poLast, null, dV1_0_1, dataCd83CloseVo, false) ; + this.updateCloseValve(controller, poLast, null, dV1_0_1, dataCd83CloseVo, false) ; //鐢熸垚骞朵繚瀛樻柊鐨勫叧闃�涓婃姤鍘嗗彶鏁版嵁璁板綍 this.newHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataCd83CloseVo, poLast); } diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealLoss.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealLoss.java index fb6b51f..3149e81 100644 --- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealLoss.java +++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealLoss.java @@ -89,7 +89,7 @@ //鏂扮殑鏃ユ湡 poLast = this.newRmLossLast(controller, rtuAddr, dV1_0_1, dataCdC0Vo); this.newAndSaveHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataCdC0Vo, poLast); - sv.saveRmLossLast(poLast); + sv.updateRmLossLast(poLast); }else{ //杩欑鎯呭喌涓嶅瓨鍦紙RTU鏃堕挓鏃╀簬鏈湴璁板綍涓殑RTU鏃堕挓锛圧TU绌胯秺鍥炶繃鍘讳簡锛屽彲鑳芥椂閽熼噸缃簡锛夛紝姝ょ鎯呭喌涓嶅鐞嗭級 } diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V202404/TkDealAlarmStatusV202404.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V202404/TkDealAlarmStatusV202404.java index 1828835..f2fe40d 100644 --- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V202404/TkDealAlarmStatusV202404.java +++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V202404/TkDealAlarmStatusV202404.java @@ -106,7 +106,8 @@ alarmVo==null?null:alarmVo.alarmEleLowVolt, alarmVo==null?null:alarmVo.stateIcEnable, (byte)0,//鐢垫睜鐢靛帇(1锛氭姤璀︼紝0锛氭甯�) - (byte)0//闃�闂ㄦ姤璀�(1锛氭姤璀︼紝0锛氭甯�) + (byte)0,//闃�闂ㄦ姤璀�(1锛氭姤璀︼紝0锛氭甯�) + (byte)0//渚涚數鏂瑰紡锛�0: 220V锛�1锛氳搫鐢垫睜锛� ) ; sv.saveRmAlarmStateLast(po) ; }else{ @@ -153,7 +154,8 @@ alarmVo==null?null:alarmVo.alarmEleLowVolt, alarmVo==null?null:alarmVo.stateIcEnable, (byte)0,//鐢垫睜鐢靛帇(1锛氭姤璀︼紝0锛氭甯�) - (byte)0//闃�闂ㄦ姤璀�(1锛氭姤璀︼紝0锛氭甯�) + (byte)0,//闃�闂ㄦ姤璀�(1锛氭姤璀︼紝0锛氭甯�) + (byte)0//渚涚數鏂瑰紡锛�0: 220V锛�1锛氳搫鐢垫睜锛� ) ; sv.saveRmAlarmStateHistory(po) ; } -- Gitblit v1.8.0