| 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); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|