| New file | 
 |  |  | 
 |  |  | 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 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() ; | 
 |  |  |          Short pVer = d.getProtocolVer() ; | 
 |  |  |          if(protocol == null || protocol.trim().equals("")){ | 
 |  |  |             log.error("严重错误,RTU上行数据中无协议名称!" ); | 
 |  |  |          }else if(pVer == null){ | 
 |  |  |             log.error("严重错误,RTU上行数据中无协议版本号!" ); | 
 |  |  |          }else{ | 
 |  |  |             this.toNextTasks(data); | 
 |  |  |          } | 
 |  |  |       } | 
 |  |  |    } | 
 |  |  |  | 
 |  |  | } |