| | |
|---|
| | | |
|---|
| | | |
|---|
| | | import com.dy.common.mw.protocol.*; |
|---|
| | | import com.dy.common.mw.protocol.p206V2.upVos.DataCd83CloseVo; |
|---|
| | | import com.dy.common.mw.protocol.p206V2.upVos.DataCd83OpenVo; |
|---|
| | | import com.dy.common.mw.protocol.p206V202404.*; |
|---|
| | | import com.dy.common.mw.protocol.p206V202404.parse.global.GlParse; |
|---|
| | | import com.dy.common.mw.protocol.p206V202404.upVos.DataCdC2Vo; |
|---|
| | |
|---|
| | | @Override |
|---|
| | | public MidResult[] parse(Boolean isLowPower, CodeParseParams params, CodeParseCallback callback)throws Exception { |
|---|
| | | ParseParamsForUpV202404 para = (ParseParamsForUpV202404)params ; |
|---|
| | | int bsLen = new CommonV202404().parseDataLen(para.upBuffer) ; |
|---|
| | | int bsLen = new CommonV202404().parseDataLen4P202404(para.upBuffer) ; |
|---|
| | | if(bsLen > 0){ |
|---|
| | | this.doParse(para.upBuffer, |
|---|
| | | bsLen, |
|---|
| | |
|---|
| | | //低功耗时，尽快发送 |
|---|
| | | confirmCommand.isQuickSend = true ; |
|---|
| | | } |
|---|
| | | callback.callback(midRs.reportOrResponse_trueOrFalse); |
|---|
| | | callback.callback(midRs.reportOrResponse_trueOrFalse, para.data.subData==null?null:((DataV202404)(para.data.subData)).subData); |
|---|
| | | if(para.data != null && para.data.getSubData() != null){ |
|---|
| | | DataCdC2Vo subData = (DataCdC2Vo)((DataV202404)para.data.getSubData()).subData ; |
|---|
| | | /* 2025-06-03 下面阀门状态是原来实现，现在统计改为用状态位数据判断阀门状态 |
|---|
| | | // public Byte opType2 ;//开启关闭：0: 开启 -1:关闭 |
|---|
| | | // public Boolean success ;//执行结果（true成功, false失败） |
|---|
| | | if(subData.opType2.byteValue() == 0 && subData.success){ |
|---|
| | | callback.notify(new ValveStateInfo(true)); |
|---|
| | | }else if(subData.opType2.byteValue() == 1 && subData.success){ |
|---|
| | | }else if(subData.opType2.byteValue() == -1 && subData.success){ |
|---|
| | | callback.notify(new ValveStateInfo(false)); |
|---|
| | | } |
|---|
| | | */ |
|---|
| | | if(subData.statePump != null){ |
|---|
| | | //(表阀一体机：1：开泵/阀；0：关泵/阀)(测控一体阀：0：开泵/阀；1：关泵/阀) |
|---|
| | | //协议解析时，统一转换为了测控一体阀， |
|---|
| | | callback.notify(new ValveStateInfo(subData.statePump.byteValue()== 0?true:false)); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | return new MidResult[]{midRs, confirmCommand} ; |
|---|
| | | return new MidResult[]{confirmCommand, midRs} ; |
|---|
| | | } |
|---|
| | | /** |
|---|
| | | * 执行分析 |
|---|
| | |
|---|
| | | * @throws Exception 异常 |
|---|
| | | */ |
|---|
| | | protected void doParse(byte[] bs, int bsLen, String dataCode, Data data) throws Exception { |
|---|
| | | DataV202404 dV1 = (DataV202404)data.getSubData() ; |
|---|
| | | DataV202404 dV202404 = (DataV202404)data.getSubData() ; |
|---|
| | | DataCdC2Vo cdData = new DataCdC2Vo(CodeV202404.getCodeName(dataCode)) ; |
|---|
| | | dV1.subData = cdData ; |
|---|
| | | dV202404.subData = cdData ; |
|---|
| | | int index = ProtocolConstantV206V202404.dataIndex ; |
|---|
| | | cdData.controllerType = ByteUtil.bytes2Hex(bs, false, index, 1) ; |
|---|
| | | |
|---|
| | |
|---|
| | | cdData.success = false ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(!cdData.success){ |
|---|
| | | return ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | index++ ; |
|---|
| | | cdData.orderNo = ByteUtil.BCD2String_BE(bs, index, index + 7) ; |
|---|
| | | |
|---|
| | | index += 8 ; |
|---|
| | | GlParse.parseRtuDt(bs, index); |
|---|
| | | cdData.rtuDt = GlParse.parseRtuDt(bs, index); |
|---|
| | | |
|---|
| | | index+= 6 ; |
|---|
| | | GlParse.parseAlarmAndState(bs, index, cdData);//四个字节 |
|---|
