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