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

liurunyu

8 天以前 656aa4f953eb52502a6414965e46642c31b6e8ee

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

New file
@@ -0,0 +1,73 @@
package com.dy.rtuMw.server;

import com.dy.common.mw.protocol.MidResultAction;
import com.dy.common.mw.protocol.Notify;
import com.dy.common.mw.protocol.ProtocolConfigVo;
import com.dy.common.mw.protocol.ProtocolUnitAdapter;
import com.dy.rtuMw.server.forTcp.MidResultActionError;
import com.dy.rtuMw.server.forTcp.MidResultActionFromRtu;
import com.dy.rtuMw.server.forTcp.MidResultActionToRtu;
import com.dy.rtuMw.server.rtuStateFrProt.RtuInfoNotify;

public class AdapterImp_ProtocolUnit implements ProtocolUnitAdapter {
	
   private static final MidResultAction toRtu = new MidResultActionToRtu() ;
   private static final MidResultAction fromRtu = new MidResultActionFromRtu() ;
   private static final MidResultAction error = new MidResultActionError() ;

   private static final RtuInfoNotify notify = new RtuInfoNotify() ;
	
   private ProtocolConfigVo configVo = null ;

   @Override
   public ProtocolConfigVo getConfig() {
      return this.configVo;
   }

   public void setConfig(ProtocolConfigVo configVo) {
      this.configVo = configVo;
   }
   /**
    * 单线程环境中运行，得到单个RTU信息通知器
    * @param protocolName 协议名称
    * @return Notify
    */
   @Override
   public Notify getSingleRtuInfoNotify(String protocolName) {
      return notify ;
   }

   /**
    * 单线程环境中运行，得到单个 处理RTU下行数据的MidResultAction执行对象
    * @param protocolName 协议名称
    * @return MidResultAction
    */
   @Override
   public MidResultAction getSingleActionToRtu(String protocolName) {
      return toRtu ;
   }

   /**
    * 单线程环境中运行，得到单个处理RTU上行数据的MidResultAction执行对象
    * @param protocolName 协议名称
    * @return MidResultAction
    */
   @Override
   public MidResultAction getSingleActionFromRtu(String protocolName) {
      return fromRtu ;
   }

   /**
    * 单线程环境中运行，得到单个处理出错的MidResultAction执行对象
    * @param protocolName 协议名称
    * @return MidResultAction
    */
   @Override
   public MidResultAction getSingleActionError(String protocolName) {
      return error ;
   }
	



}