package com.dy.rtuMw.server.rtuData; import com.dy.common.mw.protocol.Data; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; public class TkReceive extends TaskSurpport { private static final Logger log = LogManager.getLogger(TkReceive.class.getName()) ; //类ID,一定与Tree.xml配置文件中配置一致 public static final String taskId = "TkReceive" ; /** * 执行节点任务 * @param data 需要处理的数据 */ @Override public void execute(Object data) { if(data == null){ log.error("严重错误,RTU上行数据为空!" ); }else{ if(data instanceof Data){ this.toNextTasks(data); }else{ log.error("严重错误,该数据类型(" + data.getClass().getName() + "),接收数据任务还未实现!" ); } } } }