设备会在多种功能码上报数据中携带报警与状态数据，这样数据库保存设备报警与状态数据可能很多，为此修改逻辑，当前实现为一设备一个小时内只保存一条报警与状态数据。

liurunyu

8 天以前 656aa4f953eb52502a6414965e46642c31b6e8ee

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/TkRtuData.java

New file
@@ -0,0 +1,37 @@
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);
         }
      }
   }

}