pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/CodeV1_0_1.java
@@ -6,14 +6,14 @@ public static final String cd_C0 = "C0" ;//遥测站自报实时数据 public static final String cd_83 = "83" ;//遥测站开关阀自报 public static final String cd_84 = "84" ;//开阀工作报 public static final String cd_06 = "06" ;//阀门动作结果 public static final String cd_71 = "71" ;//查询阀门状态 public static String getCodeName(String code) { String name = (code.equals(cd_02) ? "链路检测" : (code.equals(cd_C0) ? "自报实时数据" : (code.equals(cd_83) ? "开关阀自报" : (code.equals(cd_84) ? "开阀工作报" : (code.equals(cd_06) ? "阀门动作结果" : (code.equals(cd_71) ? "查询阀门状态" : ""))))) ; return name ; } pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/DataCd71Vo.java
New file @@ -0,0 +1,21 @@ package com.dy.common.mw.protocol.p206V1_0_0; import lombok.Data; @Data public class DataCd71Vo { public Byte state ;//阀门状态码（0：阀门关闭状态；1：阀门打开状态） public String stateName ; public String toString(){ StringBuilder sb = new StringBuilder() ; sb.append(" 查询设备阀门状态应答:\n"); sb.append(" 阀门状态："); sb.append(state==null?"":state); sb.append(stateName==null?"":("(" + stateName + ")")); sb.append("\n"); return sb.toString() ; } } pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/DataV1_0_1.java
@@ -14,6 +14,7 @@ public DataCd83OpenVo dataCd83OpenVo;//开阀自报 public DataCd83CloseVo dataCd83CloseVo;//关阀自报 public DataCd84Vo dataCd84Vo;//开阀工作报 public DataCd71Vo dataCd71Vo;//查询阀门状态 public String dt ;//通信中间件产生发报时间(yyyy-MM-dd hh:mm:ss)
@@ -24,15 +24,13 @@ midRs.downCode = para.commandCode ;//下行命令功能码; midRs.downBuffer = bs ;//下行命令数据 midRs.downBufHex = ByteUtil.bytes2Hex(bs, true) ;//下行命令数据十六进制形式 midRs.hasResponse = true ;//是否有应答 midRs.maxSendTimes = null ;//命令最大发送次数(当收不到应答时，将重发)，如果不设置，命令缓存器进行补充设置 midRs.isCachForOffLine = true ;//RTU不在线，命令是否缓存，低功耗时为true //对RTU上行数据的应答 midRs.hasResponse = false ;//是否有应答 midRs.maxSendTimes = 1 ;//对RTU上行数据应答，所以只需发一次 midRs.maxSendTimes = 1 ;//命令最大发送次数(当收不到应答时，将重发)，如果不设置，命令缓存器进行补充设置 midRs.isCachForOffLine = false ;//RTU不在线，命令是否缓存，低功耗时为true midRs.isSendFirst = true ;//命令应答，首先发送，防止RTU重新上报 if(isLowPower != null && isLowPower.booleanValue()){ //低功耗时 //低功耗时，尽快发送 midRs.isQuickSend = true ; }
@@ -41,7 +41,7 @@ midRs.reportOrResponse_trueOrFalse = true ;//主动上报 String confirmComCode = CodeV1_0_1.cd_02 ; String confirmComCode = para.upCode ; ParseParamsForDownV1_0_1 downCpParams = new ParseParamsForDownV1_0_1() ; downCpParams.setValue( ProtocolConstantV206V1_0_0.protocolName, @@ -62,15 +62,19 @@ confirmCommand.downBufHex = ByteUtil.bytes2Hex(data, true) ;//下行命令数据十六进制形式 confirmCommand.hasResponse = false ;//是否有应答 confirmCommand.maxSendTimes = 1 ;//命令最大发送次数(当收不到应答时，将重发2次)，如果不设置，命令缓存器进行补充设置 confirmCommand.isSendFirst = true ;//确认命令，优先发送 confirmCommand.isCachForOffLine = false ;//RTU不在线，命令是否缓存 confirmCommand.isSendFirst = true ;//确认命令，优先发送 if(isLowPower != null && isLowPower.booleanValue()){ //低功耗时，尽快发送 confirmCommand.isQuickSend = true ; } callback.callback(midRs.reportOrResponse_trueOrFalse); return new MidResult[]{midRs, confirmCommand} ; } /** * 执行分析 * @param bs * @param bs 字节数组 * @param bsLen 字节长度（总包长，包括包头和包尾） * @param dataCode 功能码 * @param data 数据 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_71_Down.java
New file @@ -0,0 +1,85 @@ package com.dy.common.mw.protocol.p206V1_0_0.parse; import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V1_0_0.CodeV1_0_1; 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.parse.global.GlCreate; import com.dy.common.util.ByteUtil; @AnnotationCodeDown(ifAny={ CodeV1_0_1.cd_71 }) public class Cd_71_Down implements CodeParse { //private static Logger log = LogManager.getLogger(Cd_71_Down.class); @Override public MidResult[] parse(Boolean isLowPower, CodeParseParams params, CodeParseCallback callback) throws Exception { ParseParamsForDownV1_0_1 para = (ParseParamsForDownV1_0_1) params ; byte[] bs = this.doParse(para) ; MidResultToRtu midRs = new MidResultToRtu() ; midRs.protocolName = para.protocolName ;//协议名称 midRs.rtuAddr = para.rtuAddr ;//Rtu地址（电信平台设备IMEI） midRs.commandId = para.commandId ;//命令ID，发起命令的客户端(web端)生成，以匹配命令结果 midRs.downCode = para.commandCode ;//下行命令功能码; midRs.downBuffer = bs ;//下行命令数据 midRs.downBufHex = ByteUtil.bytes2Hex(bs, true) ;//下行命令数据十六进制形式 midRs.hasResponse = true ;//是否有应答 midRs.maxSendTimes = null ;//命令最大发送次数(当收不到应答时，将重发)，如果不设置，命令缓存器进行补充设置 midRs.isCachForOffLine = false ;//RTU不在线，命令是否缓存，低功耗时为true if(isLowPower != null && isLowPower.booleanValue()){ //低功耗时，尽快发送 midRs.isQuickSend = true ; } return new MidResult[]{midRs} ; } /** * 构造下行数据 * @param para 参数 * @return 字节数组 * @throws Exception 异常 */ public byte[] doParse(ParseParamsForDownV1_0_1 para) throws Exception { CommonV1_0_1 commonV1_0_1 = new CommonV1_0_1() ; byte[] bytes ; byte[] bsHead = new byte[ProtocolConstantV206V1_0_0.lenHead2Code] ; byte index = 0 ; bsHead[index] = ProtocolConstantV206V1_0_0.P_Head_Byte ; index++ ; bsHead[index] = 0 ;//帧长度 index++ ; bsHead[index] = ProtocolConstantV206V1_0_0.P_Head_Byte ; index++ ; bsHead[index] = commonV1_0_1.createCtrl((byte)0) ; index++ ; GlCreate.createRtuAddr(para.rtuAddr, bsHead, index); index += 5 ; ByteUtil.hex2Bytes(para.commandCode, bsHead, index) ; byte[] bs = new byte[0] ; //确认帧的数据域用于遥测终端工作模式的确认或转换。数据为 1 个字节 HEX，00H 时遥测终 //端在兼容工作状态； 01H 时遥测终端在自报工作状态； 02H 时遥测终端在查询/应答工作 //状态； 03H 时遥测终端在调试/维修状态。 bs[0] = (byte)0xF1;//数据域 bytes = ByteUtil.bytesMerge(bsHead, bs) ; GlCreate.createLen(bytes);//长度放字节数组中 bytes = GlCreate.createCrcTail(bytes) ;//CRC和尾叠加字节数组中 return bytes ; } } pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_71_Up.java
New file @@ -0,0 +1,65 @@ package com.dy.common.mw.protocol.p206V1_0_0.parse; import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V1_0_0.*; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; @AnnotationCodeUp(ifAny={ CodeV1_0_1.cd_71 }) @SuppressWarnings("unused") public class Cd_71_Up implements CodeParse { private static final Logger log = LogManager.getLogger(Cd_71_Up.class); /** * 分析上行数据 */ @Override public MidResult[] parse(Boolean isLowPower, CodeParseParams params, CodeParseCallback callback)throws Exception { ParseParamsForUpV1_0_1 para = (ParseParamsForUpV1_0_1)params ; int bsLen = new CommonV1_0_1().parseDataLen(para.upBuffer) ; if(bsLen > 0){ this.doParse(para.upBuffer, bsLen, para.upCode, para.data) ; } log.info("分析上行数据<" + CodeV1_0_1.getCodeName(para.upCode) + " RTU地址=" + para.rtuAddr + ">:\n" + para.data.toString()); MidResultFromRtu midRs = new MidResultFromRtu() ; midRs.protocolName = para.protocolName ;//协议名称 midRs.rtuAddr = para.rtuAddr ;//Rtu地址 midRs.upCode = para.upCode ;//上行数据中的功能码 midRs.upHex = para.upHex ;//上行数据十六进制形式 midRs.upBuffer = para.upBuffer ;//上行数据字节数组 midRs.data = para.data ;//解析后的数据 midRs.reportOrResponse_trueOrFalse = false ;//主动上报 callback.callback(midRs.reportOrResponse_trueOrFalse); return new MidResult[]{midRs} ; } /** * 执行分析 * @param bs 字节数组 * @param bsLen 字节长度（总包长，包括包头和包尾） * @param dataCode 功能码 * @param data 数据 * @throws Exception 异常 */ protected void doParse(byte[] bs, int bsLen, String dataCode, Data data) throws Exception { DataV1_0_1 dV1 = (DataV1_0_1)data.getSubData() ; DataCd71Vo cdData = new DataCd71Vo() ; dV1.dataCd71Vo = cdData ; cdData.state = bs[ProtocolConstantV206V1_0_0.dataIndex] ; if(cdData.state == 0){ cdData.stateName = "阀门关闭" ; }else if(cdData.state == 1){ cdData.stateName = "阀门打开" ; }else{ cdData.stateName = "未知" ; } } } pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_83_Down.java
@@ -27,15 +27,13 @@ midRs.downCode = para.commandCode ;//下行命令功能码; midRs.downBuffer = bs ;//下行命令数据 midRs.downBufHex = ByteUtil.bytes2Hex(bs, true) ;//下行命令数据十六进制形式 midRs.hasResponse = true ;//是否有应答 midRs.maxSendTimes = null ;//命令最大发送次数(当收不到应答时，将重发)，如果不设置，命令缓存器进行补充设置 midRs.isCachForOffLine = true ;//RTU不在线，命令是否缓存，低功耗时为true //对RTU上行数据的应答 midRs.hasResponse = false ;//是否有应答 midRs.maxSendTimes = 1 ;//对RTU上行数据应答，所以只需发一次 midRs.maxSendTimes = 1 ;//命令最大发送次数(当收不到应答时，将重发)，如果不设置，命令缓存器进行补充设置 midRs.isCachForOffLine = false ;//RTU不在线，命令是否缓存，低功耗时为true midRs.isSendFirst = true ;//命令应答，首先发送，防止RTU重新上报 if(isLowPower != null && isLowPower.booleanValue()){ //低功耗时 //低功耗时，尽快发送 midRs.isQuickSend = true ; }
@@ -40,7 +40,7 @@ midRs.reportOrResponse_trueOrFalse = true ;//主动上报 String confirmComCode = CodeV1_0_1.cd_C0 ; String confirmComCode = para.upCode ; ParseParamsForDownV1_0_1 downCpParams = new ParseParamsForDownV1_0_1() ; downCpParams.setValue( ProtocolConstantV206V1_0_0.protocolName, @@ -61,9 +61,14 @@ confirmCommand.downBufHex = ByteUtil.bytes2Hex(data, true) ;//下行命令数据十六进制形式 confirmCommand.hasResponse = false ;//是否有应答 confirmCommand.maxSendTimes = 1 ;//命令最大发送次数(当收不到应答时，将重发2次)，如果不设置，命令缓存器进行补充设置 confirmCommand.isSendFirst = true ;//确认命令，优先发送 confirmCommand.isCachForOffLine = false ;//RTU不在线，命令是否缓存 confirmCommand.isSendFirst = true ;//确认命令，优先发送 if(isLowPower != null && isLowPower.booleanValue()){ //低功耗时，尽快发送 confirmCommand.isQuickSend = true ; } callback.callback(midRs.reportOrResponse_trueOrFalse); return new MidResult[]{midRs, confirmCommand} ; } pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_84_Down.java
@@ -27,15 +27,13 @@ midRs.downCode = para.commandCode ;//下行命令功能码; midRs.downBuffer = bs ;//下行命令数据 midRs.downBufHex = ByteUtil.bytes2Hex(bs, true) ;//下行命令数据十六进制形式 midRs.hasResponse = true ;//是否有应答 midRs.maxSendTimes = null ;//命令最大发送次数(当收不到应答时，将重发)，如果不设置，命令缓存器进行补充设置 midRs.isCachForOffLine = true ;//RTU不在线，命令是否缓存，低功耗时为true //对RTU上行数据的应答 midRs.hasResponse = false ;//是否有应答 midRs.maxSendTimes = 1 ;//对RTU上行数据应答，所以只需发一次 midRs.maxSendTimes = 1 ;//命令最大发送次数(当收不到应答时，将重发)，如果不设置，命令缓存器进行补充设置 midRs.isCachForOffLine = false ;//RTU不在线，命令是否缓存，低功耗时为true midRs.isSendFirst = true ;//命令应答，首先发送，防止RTU重新上报 if(isLowPower != null && isLowPower.booleanValue()){ //低功耗时 //低功耗时，尽快发送 midRs.isQuickSend = true ; }
@@ -40,7 +40,7 @@ midRs.reportOrResponse_trueOrFalse = true ;//主动上报 String confirmComCode = CodeV1_0_1.cd_C0 ; String confirmComCode = para.upCode ; ParseParamsForDownV1_0_1 downCpParams = new ParseParamsForDownV1_0_1() ; downCpParams.setValue( ProtocolConstantV206V1_0_0.protocolName, @@ -61,9 +61,14 @@ confirmCommand.downBufHex = ByteUtil.bytes2Hex(data, true) ;//下行命令数据十六进制形式 confirmCommand.hasResponse = false ;//是否有应答 confirmCommand.maxSendTimes = 1 ;//命令最大发送次数(当收不到应答时，将重发2次)，如果不设置，命令缓存器进行补充设置 confirmCommand.isSendFirst = true ;//确认命令，优先发送 confirmCommand.isCachForOffLine = false ;//RTU不在线，命令是否缓存 confirmCommand.isSendFirst = true ;//确认命令，优先发送 if(isLowPower != null && isLowPower.booleanValue()){ //低功耗时，尽快发送 confirmCommand.isQuickSend = true ; } callback.callback(midRs.reportOrResponse_trueOrFalse); return new MidResult[]{midRs, confirmCommand} ; } pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_C0_Down.java
@@ -27,15 +27,13 @@ midRs.downCode = para.commandCode ;//下行命令功能码; midRs.downBuffer = bs ;//下行命令数据 midRs.downBufHex = ByteUtil.bytes2Hex(bs, true) ;//下行命令数据十六进制形式 midRs.hasResponse = true ;//是否有应答 midRs.maxSendTimes = null ;//命令最大发送次数(当收不到应答时，将重发)，如果不设置，命令缓存器进行补充设置 midRs.isCachForOffLine = true ;//RTU不在线，命令是否缓存，低功耗时为true //对RTU上行数据的应答 midRs.hasResponse = false ;//是否有应答 midRs.maxSendTimes = 1 ;//对RTU上行数据应答，所以只需发一次 midRs.maxSendTimes = 1 ;//命令最大发送次数(当收不到应答时，将重发)，如果不设置，命令缓存器进行补充设置 midRs.isCachForOffLine = false ;//RTU不在线，命令是否缓存，低功耗时为true midRs.isSendFirst = true ;//命令应答，首先发送，防止RTU重新上报 if(isLowPower != null && isLowPower.booleanValue()){ //低功耗时 //低功耗时，尽快发送 midRs.isQuickSend = true ; }
@@ -1,6 +1,5 @@ package com.dy.common.mw.protocol.p206V1_0_0.parse; import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V1_0_0.*; import com.dy.common.mw.protocol.p206V1_0_0.parse.global.GlParse; @@ -41,7 +40,7 @@ midRs.reportOrResponse_trueOrFalse = true ;//主动上报 String confirmComCode = CodeV1_0_1.cd_C0 ; String confirmComCode = para.upCode ; ParseParamsForDownV1_0_1 downCpParams = new ParseParamsForDownV1_0_1() ; downCpParams.setValue( ProtocolConstantV206V1_0_0.protocolName, @@ -62,9 +61,14 @@ confirmCommand.downBufHex = ByteUtil.bytes2Hex(data, true) ;//下行命令数据十六进制形式 confirmCommand.hasResponse = false ;//是否有应答 confirmCommand.maxSendTimes = 1 ;//命令最大发送次数(当收不到应答时，将重发2次)，如果不设置，命令缓存器进行补充设置 confirmCommand.isSendFirst = true ;//确认命令，优先发送 confirmCommand.isCachForOffLine = false ;//RTU不在线，命令是否缓存 confirmCommand.isSendFirst = true ;//确认命令，优先发送 if(isLowPower != null && isLowPower.booleanValue()){ //低功耗时，尽快发送 confirmCommand.isQuickSend = true ; } callback.callback(midRs.reportOrResponse_trueOrFalse); return new MidResult[]{midRs, confirmCommand} ; } pipIrr-platform/pipIrr-global/src/main/resources/application-global.yml
@@ -77,7 +77,7 @@ commandCallback: http://127.0.0.1:8079/remote/rtu/comCallback webPort: 8070 actutorPort: 9070 idSuffix: 0 idSuffix: 0 #此处只是占位，具体设置在通信中间件的config.xml中设置 sso: checkUrl: http://127.0.0.1:8079/sso/sso/ssoCheck webPort: 8079 pipIrr-platform/pipIrr-mw/pipIrr-mw-accept/src/main/java/com/dy/aceMw/server/forTcp/TcpDownCommandObj.java
@@ -73,8 +73,8 @@ } Long lastSendStamp = tcpSe.lastDownComTime ; if(lastSendStamp == null || (now - lastSendStamp >= ServerProperties.commandSendInterval)){ //未收到命令结果，未达到最大发送次数，RTU在线，超过命令间下发间隔，以上满足发送命令条件，执行发送命令 if(this.result.isQuickSend || lastSendStamp == null || (now - lastSendStamp >= ServerProperties.commandSendInterval)){ //未收到命令结果，未达到最大发送次数，RTU在线，速发命令或超过命令下发间隔，以上满足发送命令条件，执行发送命令 tcpSe.ioSession.write(this.result.downBuffer) ; tcpSe.lastDownComTime = now ; if(!this.result.hasResponse){ pipIrr-platform/pipIrr-mw/pipIrr-mw-accept/src/main/resources/config.xml
@@ -20,18 +20,18 @@ <base isLowPower="false" onlyOneProtocol="true" downComandMaxResendTimes="1" downComandMaxResendTimes="3" commandSendInterval="3" cachWaitResultTimeout="60" offLineCachTimeout="86400" lastUpDataTimeLive="1" dbDataIdSuffix="1" dbDataIdSuffix="0" cacheUpDownDataWarnCount="100000" cacheUpDownDataMaxCount="110000" /> <!-- centerAddr: 中心地址，当前，在户表系统中的，centerAddr未用到 centerAddr: 中心地址，当前，centerAddr未用到 synchroRtuClock: 是否对RTU校时 synchroRtuClockTimepieces：当RTU与服务器时钟相差一定毫秒（配置文件是秒钟）后，进行校时 --> @@ -45,7 +45,7 @@ <!-- 软件升级 --> <updateRtuSoft enable="true"> <soft1 enable="true" oldVersionName="meter_v2_0,meter_v1_0" > <newVersion newVersionName="meter_v3_0" file="rtuSoft/meter_v3_0.txt"></newVersion> <newVersion newVersionName="meter_v3_0" file="rtuSoft/meter_v3_0.txt"> </newVersion> </soft1> <!-- <soft2 enable="false" oldVersionName="rtu_v1_0,rtu_v2_0,rtu_v3_0" >
