From 14d7f0df63340ede75458c0e91b902376ef4dd64 Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期三, 20 十一月 2024 11:26:32 +0800 Subject: [PATCH] 1、优化代码;2、修改长级测试中发现的bug;3、通信中间件配置文件配置项修改 --- pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_8A_Up.java | 22 +++++++++++++--------- 1 files changed, 13 insertions(+), 9 deletions(-) diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_8A_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_8A_Up.java index e3196a5..a96b095 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_8A_Up.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_8A_Up.java @@ -29,10 +29,11 @@ para.upCode, para.data) ; } - log.info("鍒嗘瀽涓婅鏁版嵁<" + CodeV202404.getCodeName(para.upCode) + " RTU鍦板潃=" + para.rtuAddr + ">:\n" + para.data.toString()); + log.info("\n鍒嗘瀽鍛戒护搴旂瓟鏁版嵁<" + CodeV202404.getCodeName(para.upCode) + " RTU鍦板潃=" + para.rtuAddr + ">:\n" + para.data.toString()); MidResultFromRtu midRs = new MidResultFromRtu() ; midRs.protocolName = para.protocolName ;//鍗忚鍚嶇О + midRs.protocolVersion = para.protocolVersion ;//鍗忚鐗堟湰鍙� midRs.rtuAddr = para.rtuAddr ;//Rtu鍦板潃 midRs.upCode = para.upCode ;//涓婅鏁版嵁涓殑鍔熻兘鐮� midRs.upHex = para.upHex ;//涓婅鏁版嵁鍗佸叚杩涘埗褰㈠紡 @@ -46,6 +47,7 @@ downCpParams.setValue( null, ProtocolConstantV206V202404.protocolName, + para.protocolVersion, para.rtuAddr, Command.defaultId, confirmComCode, @@ -56,9 +58,11 @@ MidResultToRtu confirmCommand = new MidResultToRtu() ; confirmCommand.protocolName = para.protocolName ;//鍗忚鍚嶇О + confirmCommand.protocolVersion = para.protocolVersion ;//鍗忚鐗堟湰鍙� confirmCommand.rtuAddr = para.rtuAddr ;//Rtu鍦板潃 confirmCommand.commandId = Command.defaultId ;//鍛戒护ID锛屽彂璧峰懡浠ょ殑瀹㈡埛绔�(web绔�)鐢熸垚锛屼互鍖归厤鍛戒护缁撴灉 confirmCommand.downCode = confirmComCode ;//涓嬭鍛戒护鍔熻兘鐮�; + confirmCommand.downCodeName = CodeV202404.getCodeName(confirmComCode) ;//涓嬭鍛戒护鍔熻兘鐮佸悕绉�; confirmCommand.downBuffer = data ;//涓嬭鍛戒护鏁版嵁 confirmCommand.downBufHex = ByteUtil.bytes2Hex(data, true) ;//涓嬭鍛戒护鏁版嵁鍗佸叚杩涘埗褰㈠紡 confirmCommand.hasResponse = false ;//鏄惁鏈夊簲绛� @@ -71,7 +75,7 @@ confirmCommand.isQuickSend = true ; } callback.callback(midRs.reportOrResponse_trueOrFalse); - return new MidResult[]{midRs, confirmCommand} ; + return new MidResult[]{confirmCommand, midRs} ; } /** * 鎵ц鍒嗘瀽 @@ -83,32 +87,32 @@ */ protected void doParse(byte[] bs, int bsLen, String dataCode, Data data) throws Exception { DataV202404 dV1 = (DataV202404)data.getSubData() ; - DataCd8AVo cdData = new DataCd8AVo() ; + DataCd8AVo cdData = new DataCd8AVo(CodeV202404.getCodeName(dataCode)) ; dV1.subData = cdData ; int index = ProtocolConstantV206V202404.dataIndex ; cdData.controllerType = ByteUtil.bytes2Hex(bs, false, index, 1) ; index++ ; - cdData.projectNo = 0 + bs[index]; + cdData.projectNo = (int)bs[index]; index++ ; - int lng = ByteUtil.BCD2Int_BE(bs, index, index + 4) ; + Long lng = ByteUtil.BCD2Long_LE(bs, index, index + 4) ; cdData.lng = lng/1000000.0D; index += 5 ; - int lat = ByteUtil.BCD2Int_BE(bs, index, index + 4) ; + Long lat = ByteUtil.BCD2Long_LE(bs, index, index + 4) ; cdData.lat = lat/1000000.0D; index += 5 ; - int softVersion = ByteUtil.BCD2Int_BE(bs, index, index + 1) ; + int softVersion = ByteUtil.BCD2Int_LE(bs, index, index + 1) ; cdData.softVersion = softVersion/10.0F; index += 2 ; - int hardVersion = ByteUtil.BCD2Int_BE(bs, index, index + 1) ; + int hardVersion = ByteUtil.BCD2Int_LE(bs, index, index + 1) ; cdData.hardVersion = hardVersion/10.0F; index += 2 ; - int protocolVersion = ByteUtil.BCD2Int_BE(bs, index, index + 1) ; + int protocolVersion = ByteUtil.BCD2Int_LE(bs, index, index + 1) ; cdData.protocolVersion = protocolVersion/10.0F; } -- Gitblit v1.8.0