RTU远程升级管理及相关代码适应性调整与修改

liurunyu

2024-11-08 04779efe2410fb0df1ff983b26384d56471b85cf

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V2/CommonV2.java

@@ -1,5 +1,6 @@
package com.dy.common.mw.protocol.p206V2;

import com.dy.common.mw.protocol.p206V1.ProtocolConstantV206V1;
import com.dy.common.util.ByteUtil;
import com.dy.common.util.ByteUtilUnsigned;
import com.dy.common.util.CRC8_for_2_0;
@@ -12,19 +13,48 @@
    * @return true是,false否
    * @throws Exception  异常
    */
   public Boolean isThisProtocolHead(byte[] bs) throws Exception{
   public Boolean[] isThisProtocolHead(byte[] bs) throws Exception{
      if(bs == null){
         return null ;
      }else if(bs.length >= (ProtocolConstantV206V2.ctrlIndex)
            && bs[ProtocolConstantV206V2.headFlag1Index] == ProtocolConstantV206V2.P_Head_Byte
            && bs[ProtocolConstantV206V2.headFlag2Index] == ProtocolConstantV206V2.P_Head_Byte){
         Short vs = this.parseVersion(bs) ;
         return vs.shortValue() == ProtocolConstantV206V2.protocolVer.shortValue() ;
         if(vs.shortValue() == ProtocolConstantV206V2.protocolVer.shortValue()){
            return new Boolean[]{true, true};
         }else{
            return new Boolean[]{false, true};
         }
      }else if(bs.length >= (ProtocolConstantV206V2.UG_codeIndex)
            && bs[0] == ProtocolConstantV206V2.UG_P_Head_Byte
            && bs[3] == ProtocolConstantV206V2.UG_P_Head_Byte){
         return new Boolean[]{true, false} ;
      }else{
         return false ;
         return new Boolean[]{false, false} ;
      }
   }

   /**
    * 检查协议类型
    * @param bs 上行字节数组
    * @return 协议类型
    * @throws Exception 异常
    */
   public Boolean protocolType_p206TrueUgFalse(byte[] bs){
      if(bs == null){
         return null ;
      }else if(bs.length >= (ProtocolConstantV206V2.ctrlIndex)
            && bs[0] == ProtocolConstantV206V2.P_Head_Byte
            && bs[2] == ProtocolConstantV206V2.P_Head_Byte){
         return true ;
      }else if(bs.length >= (ProtocolConstantV206V2.UG_codeIndex)
            && bs[0] == ProtocolConstantV206V2.UG_P_Head_Byte
            && bs[3] == ProtocolConstantV206V2.UG_P_Head_Byte){
         return false ;
      }else{
         return null ;
      }
   }
   /**
    * 分析版本号
    * @param bs
@@ -33,18 +63,7 @@
   public Short parseVersion(byte[] bs)throws Exception{
      return ByteUtil.byte2PlusInt(bs[ProtocolConstantV206V2.versionIndex]) ;
   }
	
   /**
    * 检查头
    * @param bs 上行字节数组
    * @throws Exception 异常
    */
   public void checkHead(byte[] bs) throws Exception{
      if(bs.length < ProtocolConstantV206V2.onLineDataMinLength || bs[0] != ProtocolConstantV206V2.P_Head_Byte || bs[2] != ProtocolConstantV206V2.P_Head_Byte){
         throw new Exception("上行数据帧头不正确！") ;
      }
   }
	

   /**
    * 检查尾
    * @param bs 上行字节数组
@@ -60,24 +79,40 @@
   /**
    * 分析帧长度
    * @param bs 上行字节数组
    * @param p206TrueUgFalse 206协议为true，升级协议为false
    * @return 数据长度
    * @throws Exception 异常
    */
   public int parseFrameLen(byte[] bs)throws Exception{
      int len = ByteUtilUnsigned.byte2Byte(bs, ProtocolConstantV206V2.dataLenIndex) ;
      return len + ProtocolConstantV206V2.lenHead2ctrl + ProtocolConstantV206V2.lenTail ;
   public int parseFrameLen(byte[] bs, boolean p206TrueUgFalse)throws Exception{
      if(p206TrueUgFalse) {
         int len = ByteUtilUnsigned.byte2Byte(bs, ProtocolConstantV206V2.dataLenIndex);
         return len + ProtocolConstantV206V2.lenHead2ctrl + ProtocolConstantV206V2.lenTail;
      }else{
         int len = ByteUtilUnsigned.bytes2Short_BE(bs, ProtocolConstantV206V2.UG_dataLenIndex_start);
         return len + ProtocolConstantV206V2.UG_lenHead2Cmd + ProtocolConstantV206V2.UG_lenTail;
      }
   }


   /**
    * 分析用户数据域字节数
    * 分析用户数据域字节数(默认是非升级协议)
    * @param bs 上行字节数组
    * @return 数据长度
    * @throws Exception 异常
    */
   public int parseDataLen(byte[] bs)throws Exception{
   public int parseDataLen4P206(byte[] bs)throws Exception{
      int len = ByteUtilUnsigned.byte2Byte(bs, ProtocolConstantV206V2.dataLenIndex) ;
      return len + ProtocolConstantV206V2.lenHead2ctrl + ProtocolConstantV206V2.lenTail ;
      return len - ProtocolConstantV206V2.lenCtrl - ProtocolConstantV206V2.lenRtuAddr ;
   }

   /**
    * 分析用户数据域字节数(升级协议)
    * @param bs 上行字节数组
    * @return 数据长度
    * @throws Exception 异常
    */
   public int parseDataLen4Ug(byte[] bs)throws Exception{
      int len = ByteUtilUnsigned.bytes2Short_LE(bs, ProtocolConstantV206V2.UG_dataLenIndex_start) ;
      return len - ProtocolConstantV206V2.UG_lenCmd - ProtocolConstantV206V2.UG_lenRtuAddr ;
   }