From 1a2b07f01ba4616fd9e894dddf474b56d020158c Mon Sep 17 00:00:00 2001 From: zhubaomin <zhubaomin> Date: 星期一, 07 四月 2025 15:18:51 +0800 Subject: [PATCH] 整理版本 --- pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1/parse/Cd_1602_Down.java | 95 +++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 95 insertions(+), 0 deletions(-) diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1/parse/Cd_1602_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1/parse/Cd_1602_Down.java new file mode 100644 index 0000000..2ba003d --- /dev/null +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1/parse/Cd_1602_Down.java @@ -0,0 +1,95 @@ +package com.dy.common.mw.protocol.p206V1.parse; + +import com.dy.common.mw.protocol.*; +import com.dy.common.mw.protocol.p206V1.CodeV1; +import com.dy.common.mw.protocol.p206V1.ParseParamsForDownV1; +import com.dy.common.mw.protocol.p206V1.ProtocolConstantV206V1; +import com.dy.common.mw.protocol.p206V1.parse.global.GlCreate; +import com.dy.common.softUpgrade.Com1601Vo; +import com.dy.common.util.ByteUtil; + +/** + * @Author liurunyu + * @Date 2024/06/12 9:30 + * @Description + */ +@AnnotationCodeDown(ifAny={ + CodeV1.cd_1602 +}) +public class Cd_1602_Down implements CodeParse { + + @Override + public MidResult[] parse(Boolean isLowPower, CodeParseParams params, CodeParseCallback callback) throws Exception { + ParseParamsForDownV1 para = (ParseParamsForDownV1) params ; + MidResultToRtu midRs = new MidResultToRtu() ; + byte[] bs = this.doParse(midRs, para) ; + + midRs.rtuResultSendWebUrl = para.rtuResultSendWebUrl ;//rtu杩斿洖鍛戒护缁撴灉 鍙戝悜鐩殑鍦皐eb URL + midRs.protocolName = para.protocolName ;//鍗忚鍚嶇О + midRs.protocolVersion = para.protocolVersion; //鍗忚鐗堟湰鍙� + midRs.rtuAddr = para.rtuAddr ;//Rtu鍦板潃 + midRs.commandId = para.commandId ;//鍛戒护ID锛屽彂璧峰懡浠ょ殑瀹㈡埛绔�(web绔�)鐢熸垚锛屼互鍖归厤鍛戒护缁撴灉 + midRs.downCode = para.commandCode ;//涓嬭鍛戒护鍔熻兘鐮�; + midRs.downCodeName = CodeV1.getCodeName(para.commandCode) ;//涓嬭鍛戒护鍔熻兘鐮佸悕绉�; + midRs.downBuffer = bs ;//涓嬭鍛戒护鏁版嵁 + midRs.downBufHex = ByteUtil.bytes2Hex(bs, true) ;//涓嬭鍛戒护鏁版嵁鍗佸叚杩涘埗褰㈠紡 + midRs.hasResponse = false ;//鏄惁鏈夊簲绛� + midRs.maxSendTimes = null ;//鍛戒护鏈�澶у彂閫佹鏁�(褰撴敹涓嶅埌搴旂瓟鏃讹紝灏嗛噸鍙�)锛屽鏋滀笉璁剧疆锛屽懡浠ょ紦瀛樺櫒杩涜琛ュ厖璁剧疆 + midRs.isCachForOffLine = false ;//RTU涓嶅湪绾匡紝鍛戒护鏄惁缂撳瓨锛屼綆鍔熻�楁椂涓簍rue + + midRs.isFastCom = true ;//閫熷彂鍛戒护锛屼笅鍙戞暟鎹椂闂撮棿闅斿彈灏忓�硷紙閰嶇疆鏂囦欢涓璮astCommandSendInterval锛夐檺鍒� + + if(isLowPower != null && isLowPower.booleanValue()){ + //浣庡姛鑰楁椂锛屽敖蹇彂閫� + midRs.isQuickSend = true ; + } + + return new MidResult[]{midRs} ; + } + + + /** + * 鏋勯�犱笅琛屾暟鎹� + * @param midRs 鍙傛暟 + * @param para 鍙傛暟 + * @return 瀛楄妭鏁扮粍 + * @throws Exception 寮傚父 + */ + public byte[] doParse(MidResultToRtu midRs, ParseParamsForDownV1 para) throws Exception { + byte[] preBytes = new byte[ProtocolConstantV206V1.UG_lenHead2RtuAddr] ; + byte index = 0 ; + preBytes[index] = ProtocolConstantV206V1.UG_P_Head_Byte ; + + index++ ; + preBytes[index] = 0 ;//甯ч暱搴� + index++ ; + preBytes[index] = 0 ;//甯ч暱搴� + + index++ ; + preBytes[index] = ProtocolConstantV206V1.UG_P_Head_Byte ; + + index++ ; + ByteUtil.hex2Bytes(para.commandCode, preBytes, index) ; + + index += 2 ; + GlCreate.createRtuAddr4PUg(para.rtuAddr, preBytes, index); + if(para.param == null){ + throw new Exception("鍙傛暟涓虹┖") ; + } + Integer ramAddr = (Integer)para.param ; + + byte[] bs = new byte[4] ; + ByteUtil.int2Bytes_BE(bs, ramAddr, 0); + byte[] bytes = ByteUtil.bytesMerge(preBytes, bs) ; + + bytes = ByteUtil.bytesMerge(bytes, (byte[])para.attachment) ; + + GlCreate.createLen4PUg(bytes);//闀垮害鏀惧瓧鑺傛暟缁勪腑 + + byte[] bsTail = GlCreate.createCrcTail4Ug(bytes) ;//CRC鍜屽熬鍙犲姞瀛楄妭鏁扮粍涓� + + return ByteUtil.bytesMerge(bytes, bsTail) ; + } + +} + -- Gitblit v1.8.0