| New file |
| | |
|---|
| | | 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; |
|---|
| | | import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd84Vo; |
|---|
| | | import com.dy.common.util.ByteUtil; |
|---|
| | | import org.apache.logging.log4j.LogManager; |
|---|
| | | import org.apache.logging.log4j.Logger; |
|---|
| | | |
|---|
| | | @AnnotationCodeUp(ifAny={ |
|---|
| | | CodeV1_0_1.cd_84 |
|---|
| | | }) |
|---|
| | | @SuppressWarnings("unused") |
|---|
| | | public class Cd_84_Up implements CodeParse { |
|---|
| | | |
|---|
| | | private static final Logger log = LogManager.getLogger(Cd_84_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 = true ;//主动上报 |
|---|
| | | |
|---|
| | | 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, |
|---|
| | | null); |
|---|
| | | //构造应答 |
|---|
| | | byte[] data = new Cd_84_Down().doParse(downCpParams) ; |
|---|
| | | |
|---|
| | | MidResultToRtu confirmCommand = new MidResultToRtu() ; |
|---|
| | | confirmCommand.protocolName = para.protocolName ;//协议名称 |
|---|
| | | confirmCommand.rtuAddr = para.rtuAddr ;//Rtu地址 |
|---|
| | | confirmCommand.commandId = Command.defaultId ;//命令ID，发起命令的客户端(web端)生成，以匹配命令结果 |
|---|
| | | confirmCommand.downCode = confirmComCode ;//下行命令功能码; |
|---|
| | | confirmCommand.downBuffer = data ;//下行命令数据 |
|---|
| | | confirmCommand.downBufHex = ByteUtil.bytes2Hex(data, true) ;//下行命令数据十六进制形式 |
|---|
| | | confirmCommand.hasResponse = false ;//是否有应答 |
|---|
| | | confirmCommand.maxSendTimes = 1 ;//命令最大发送次数(当收不到应答时，将重发2次)，如果不设置，命令缓存器进行补充设置 |
|---|
| | | 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 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() ; |
|---|
| | | DataCd84Vo cdData = new DataCd84Vo() ; |
|---|
| | | dV1.subData = cdData ; |
|---|
| | | |
|---|
| | | short index = ProtocolConstantV206V1_0_0.dataIndex ; |
|---|
| | | cdData.opType = bs[index] ; |
|---|
| | | |
|---|
| | | index++ ; |
|---|
| | | cdData.cardType = bs[index] ; |
|---|
| | | |
|---|
| | | index++ ; |
|---|
| | | cdData.cardAddr = ByteUtil.bytes2Hex_LE(bs, false, index, 4) ; |
|---|
| | | |
|---|
| | | index += 4 ; |
|---|
| | | //用水户号数据格式：8字节低位在前高位在后。 |
|---|
| | | cdData.cardNo = GlParse.parseIcCardNo(bs, index) ; |
|---|
| | | |
|---|
| | | index += 8 ; |
|---|
| | | //用水户余额：用户余额4字节BCD码，取值范围0.00~999999.99，单位为元。 |
|---|
| | | int tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 3) ; |
|---|
| | | cdData.remainMoney = tpInt/100.0 ; |
|---|
| | | |
|---|
| | | index += 4 ; |
|---|
| | | //累计流量：5字节BCD码，取值范围0~9999999999，单位为m3。 |
|---|
| | | tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 4) ; |
|---|
| | | cdData.totalAmount = tpInt/100.0; |
|---|
| | | |
|---|
| | | index += 5 ; |
|---|
| | | //瞬时流量：5字节BCD码，取值范围0~9999999.999，单位为m3/h。 |
|---|
| | | tpInt = ByteUtil.BCD2Int_LE(bs, index, index + 4) ; |
|---|
| | | cdData.instantAmount = tpInt/1000.0 ; |
|---|
| | | |
|---|
| | | index += 5 ; |
|---|
| | | cdData.alarmVo = GlParse.parseAlarm(bs, index) ; |
|---|
| | | index += 2 ; |
|---|
| | | cdData.stateVo = GlParse.parseState(bs, index) ; |
|---|
| | | index += 2 ; |
|---|
| | | |
|---|
| | | //控制器时钟 |
|---|
| | | cdData.rtuDt = GlParse.parseTp(bs, index) ; |
|---|
| | | //index += 6 ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
