1、协议版本号增加到协议解析与命令构造中； 2、增加RTU状态记录功能，为RTU远程升级做准备。

liurunyu

2024-11-03 db88628e7bb03f334fa65826bd655c27859a9973

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

@@ -58,38 +58,57 @@
      }
      String rtuAddr = (String)session.getAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrIdKey) ;
      String protocolName = null ;
      Short protocolVersion = null ;
      boolean isOnLine = false ;
      if(rtuAddr == null){
         //说明刚建立网络连接，此数据应该是上线数据
         isOnLine = true ;
         String[] rtuAddrProtocolName = this.parseOnLine(session, upBuf) ;
         if(rtuAddrProtocolName.length == 2){
         Object[] rtuAddrProtocolNameVersion = this.parseOnLine(session, upBuf) ;
         if(rtuAddrProtocolNameVersion.length == 2){
            //解析上线数据成功，并解析出RTU地址及通信协议名称
            rtuAddr = rtuAddrProtocolName[0] ;
            protocolName = rtuAddrProtocolName[1] ;
				
            rtuAddr = (String)rtuAddrProtocolNameVersion[0] ;
            protocolName = (String)rtuAddrProtocolNameVersion[1] ;
            protocolVersion = (Short)rtuAddrProtocolNameVersion[2] ;

            if(rtuAddr != null && protocolName != null){
               //设置session的属性ID
               TcpUnit.getInstance().setIoSessionArrId(session, rtuAddr);
               //缓存session
               TcpSessionCache.putNewTcpSession(rtuAddr, protocolName, session);
               TcpSessionCache.putNewTcpSession(rtuAddr, protocolName, protocolVersion, session);
               
               log.info("RTU(地址：" + rtuAddr + "，协议：" + protocolName + ")上线了。") ;
               log.info("RTU(地址：" + rtuAddr + "，协议：" + protocolName + "，协议版本号：" + protocolVersion + ")上线了。") ;
            }
         }
      }
		
      if(rtuAddr != null){
         if(protocolName == null){
            protocolName = TcpSessionCache.getTcpProtocolName(rtuAddr) ;
         boolean toDeal = true ;
         if(ServerProperties.onlyDealRtusTest){
            boolean find = false ;
            for(String testRtu : ServerProperties.onlyDealRtus){
               if(testRtu.equals(rtuAddr)){
                  find = true ;
                  break ;
               }
            }
            if(!find){
               //不在处理范围内
               toDeal = false ;
            }
         }
			
         //设置收到数据时刻
         TcpSessionCache.cacheUpDataTime(rtuAddr);
			
         if(protocolName != null){
            //对上行数据进行处理
            this.dealUpData(session, rtuAddr, protocolName, isOnLine, upBuf, upHex) ;
         if(toDeal){
            if(protocolName == null){
               Object[] objs = TcpSessionCache.getTcpProtocolNameVersion(rtuAddr) ;
               protocolName = (String)objs[0] ;
               protocolVersion = (Short)objs[1] ;
            }

            //设置收到数据时刻
            TcpSessionCache.cacheUpDataTime(rtuAddr);

            if(protocolName != null){
               //对上行数据进行处理
               this.dealUpData(session, rtuAddr, protocolName, protocolVersion, isOnLine, upBuf, upHex) ;
            }
         }
      }
   }
@@ -99,9 +118,10 @@
    * @param session IO会话
    * @param upBuf 上行数据
    */
   private String[] parseOnLine(IoSession session, byte[] upBuf){
   private Object[] parseOnLine(IoSession session, byte[] upBuf){
      String rtuAddr = null ;
      String protocolName = null ;
      Short protocolVersion = null ;
      try {
         OnLine.OnLineResult rs = new OnLineHandle().parse(upBuf) ;
         if(rs == null 
@@ -118,6 +138,7 @@
               log.error("严重错误，解析上线结果中协议名称为空 ！" ) ;
            }else{
               protocolName = rs.protocolName ;
               protocolVersion = rs.protocolVersion ;
            }
         }else if(rs.result == OnLine.OnLineAction_success_response){
            if(rs.remoteData != null && rs.remoteData.length > 0){
@@ -129,7 +150,7 @@
      } catch (Exception e) {
         log.error("严重错误，分析上线数据时产生异常 ！\n" + e.getMessage() , e) ;
      }
      return new String[]{rtuAddr, protocolName} ;
      return new Object[]{rtuAddr, protocolName, protocolVersion} ;
   }
   
   
@@ -138,23 +159,30 @@
    * @param session IO会话
    * @param rtuAddrAtHead 控制器地址头部
    * @param protocolName 协议名称
    * @param protocolVersion 协议版本号
    * @param isOnLine 是否上线数据
    * @param upBuf 上行数据
    * @param upHex 上行数据
    * @throws Exception 异常
    */
   private void dealUpData(IoSession session, String rtuAddrAtHead, String protocolName, boolean isOnLine, byte[] upBuf, String upHex) throws Exception{
   private void dealUpData(IoSession session,
                     String rtuAddrAtHead,
                     String protocolName,
                     Short protocolVersion,
                     boolean isOnLine,
                     byte[] upBuf,
                     String upHex) throws Exception{
      Driver dri = ProtocolCache.getDriver(protocolName) ;
      if(dri == null){
         log.error("严重错误，未能得到协议" + protocolName + "驱动类实例！");
      }else{
         MidResult[] midRs = dri.parseData(ServerProperties.isLowPower, rtuAddrAtHead, upBuf, upHex, new DriverParserDataCallback(){
            @Override
            public void callback(String rtuAddrAtHead, String code, String upHex, Boolean reportOrResponse_trueOrFalse, boolean parseFail, String rtuAddrInData) {
            public void callback(String rtuAddrAtHead, String code, String codeName, String upHex, Boolean reportOrResponse_trueOrFalse, boolean parseFail, String rtuAddrInData) {
               //更新终端状态
               if(rtuAddrInData != null && !rtuAddrInData.equals(rtuAddrAtHead)){
                  //数据头中的RTU地址与数据中的RTU地址不一致，更换成数据中的RTU地址
                  TcpSessionCache.changeRtuAddr(rtuAddrAtHead, rtuAddrInData, protocolName, session);
                  TcpSessionCache.changeRtuAddr(rtuAddrAtHead, rtuAddrInData, protocolName, protocolVersion, session);
                  session.setAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrIdKey, rtuAddrInData) ;
               }

@@ -168,19 +196,19 @@
               InetSocketAddress sa = (InetSocketAddress)session.getRemoteAddress() ;
               if(isOnLine){
                  //上线了
                  RtuStatusDealer.onLine(rtuAddr, sa.getAddress().getHostAddress(), sa.getPort());
                  RtuStatusDealer.onLine(rtuAddr, sa.getAddress().getHostAddress(), sa.getPort(), protocolName, protocolVersion);
               }
               if(reportOrResponse_trueOrFalse != null && reportOrResponse_trueOrFalse){
                  RtuStatusDealer.upReport(rtuAddr, upBuf.length) ;
                  RtuStatusDealer.upAutoReport(rtuAddr, code, codeName, upBuf.length) ;
               }else{
                  RtuStatusDealer.upData(rtuAddr, upBuf.length) ;
                  RtuStatusDealer.upData(rtuAddr, code, codeName, upBuf.length) ;
               }

               //记录日志
               if(parseFail){
                  RtuLogDealer.log(rtuAddr, (isOnLine?"上线数据 ":"上行数据 ") + "" + code + "：" + upHex + "（解析失败）");
                  RtuLogDealer.log(rtuAddr, (isOnLine?"上线数据 ":"上行数据 ") +  code + ("（" + codeName + "）") + "：" + upHex + "（解析失败）");
               }else{
                  RtuLogDealer.log(rtuAddr, (isOnLine?"上线数据 ":"上行数据 ") + "" + code + "：" + upHex);
                  RtuLogDealer.log(rtuAddr, (isOnLine?"上线数据 ":"上行数据 ") +  code + ("（" + codeName + "）") + "：" + upHex);
               }
            }
         }) ;