|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.dy.common.mw.protocol.*; | 
|---|
|  |  |  | import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd02Vo; | 
|---|
|  |  |  | import com.dy.common.util.ByteUtil; | 
|---|
|  |  |  | import org.apache.logging.log4j.LogManager; | 
|---|
|  |  |  | import org.apache.logging.log4j.Logger; | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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( | 
|---|
|  |  |  | null, | 
|---|
|  |  |  | ProtocolConstantV206V1_0_0.protocolName, | 
|---|
|  |  |  | para.rtuAddr, | 
|---|
|  |  |  | Command.defaultId, | 
|---|
|  |  |  | confirmComCode, | 
|---|
|  |  |  | null, | 
|---|
|  |  |  | para.data!=null?(para.data.subData!=null?(((DataV1_0_1)(para.data.subData)).subData):null):null, | 
|---|
|  |  |  | null); | 
|---|
|  |  |  | //构造应答 | 
|---|
|  |  |  | byte[] data = new Cd_02_Down().doParse(downCpParams) ; | 
|---|
|  |  |  | 
|---|
|  |  |  | 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 数据 | 
|---|
|  |  |  | 
|---|
|  |  |  | protected void doParse(byte[] bs, int bsLen, String dataCode, Data data) throws Exception { | 
|---|
|  |  |  | DataV1_0_1 dV1 = (DataV1_0_1)data.getSubData() ; | 
|---|
|  |  |  | DataCd02Vo cdData = new DataCd02Vo() ; | 
|---|
|  |  |  | dV1.dataCd02Vo = cdData ; | 
|---|
|  |  |  | dV1.subData = cdData ; | 
|---|
|  |  |  | cdData.status = ByteUtil.bytes2Hex(bs, false, ProtocolConstantV206V1_0_0.dataIndex, 1) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|