package com.dy.aceMw.server.rtuData; import com.dy.common.mw.protocol.Data; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; public class TkRtuData extends TaskSurpport { private static Logger log = LogManager.getLogger(TkRtuData.class.getName()) ; //类ID,一定与Tree.xml配置文件中配置一致 public static final String taskId = "TkRtuData" ; /** * 执行节点任务 * @param data 需要处理的数据 */ @Override public void execute(Object data) { Data d = (Data)data ; String rtuAddr = d.getRtuAddr() ; if(rtuAddr == null || rtuAddr.trim().equals("")){ log.error("严重错误,RTU上行数据中无RTU地址!" ); }else{ String protocol = d.getProtocol() ; if(protocol == null || protocol.trim().equals("")){ log.error("严重错误,RTU上行数据中无协议名称!" ); }else{ this.toNextTasks(data); } } } }