package com.dy.rtuMw.server.rtuData.p206V1_0_0; import com.dy.common.mw.protocol.p206V1_0_0.DataV1_0_1; import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd02Vo; import com.dy.rtuMw.server.rtuData.TaskSurpport; import com.dy.common.mw.protocol.Data; import com.dy.common.mw.protocol.p206V1_0_0.ProtocolConstantV206V1_0_0; public class TkFindP206V1_0_0 extends TaskSurpport { //类ID,一定与Tree.xml配置文件中配置一致 public static final String taskId = "TkFindP206V1_0_0" ; /** * 执行节点任务 * @param data 需要处理的数据 */ @Override public void execute(Object data) { Data d = (Data)data ; if(d.getProtocol() != null && d.getProtocol().equals(ProtocolConstantV206V1_0_0.protocolName)){ //识别出是P206V1.0.0协议数据 //无命令ID boolean toNext = true ; if(d.getSubData() != null) { DataV1_0_1 dataV1_0_1 = (DataV1_0_1)d.getSubData() ; if(dataV1_0_1 != null && dataV1_0_1.subData != null && dataV1_0_1.subData instanceof DataCd02Vo){ //过滤掉心跳数据 toNext = false ; } } if(toNext){ this.toNextTasks(data); } }else{ //不是本协议的数据 } } }