Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

wuzeyu

2023-12-02 120448e8c6826b453d5b96e9076d61479a987677

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/CommonV1_0_1.java

New file
@@ -0,0 +1,172 @@
package com.dy.common.mw.protocol.p206V1_0_0;

import com.dy.common.util.ByteUtil;
import com.dy.common.util.ByteUtilUnsigned;
import com.dy.common.util.CRC8_for_2_0;


public class CommonV1_0_1 {
   /**
    * 检查头
    * @param bs 上行字节数组
    * @return true是,false否
    * @throws Exception  异常
    */
   public Boolean isThisProtocolHead(byte[] bs) throws Exception{
      if(bs == null){
         return null ;
      }else if(bs.length >= (ProtocolConstantV206V1_0_0.ctrlIndex - 1)
            && bs[0] == ProtocolConstantV206V1_0_0.P_Head_Byte
            && bs[2] == ProtocolConstantV206V1_0_0.P_Head_Byte){
         //String vs = this.parseVersion(bs) ;
         //return vs.equals(ProtocolConstantV206V1_0_0.version);
         return true ;
      }else{
         return false ;
      }
   }
	
   /**
    * 检查头
    * @param bs 上行字节数组
    * @throws Exception 异常
    */
   public void checkHead(byte[] bs) throws Exception{
      if(bs.length < 13 || bs[0] != ProtocolConstantV206V1_0_0.P_Head_Byte || bs[2] != ProtocolConstantV206V1_0_0.P_Head_Byte){
         throw new Exception("上行数据帧头不正确！") ;
      }
   }
	
   /**
    * 检查尾
    * @param bs 上行字节数组
    * @throws Exception 异常
    */
   public void checkTail(byte[] bs) throws Exception{
      if(bs.length < 1 || bs[bs.length - 1] != ProtocolConstantV206V1_0_0.P_Tail_Byte){
         throw new Exception("上行数据尾不正确！") ;
      }
   }


   /**
    * 分析帧长度
    * @param bs 上行字节数组
    * @return 数据长度
    * @throws Exception 异常
    */
   public int parseFrameLen(byte[] bs)throws Exception{
      int len = ByteUtilUnsigned.byte2Byte(bs, ProtocolConstantV206V1_0_0.dataLenIndex) ;
      return len + ProtocolConstantV206V1_0_0.lenHead2ctrl + ProtocolConstantV206V1_0_0.lenTail ;
   }


   /**
    * 分析用户数据域字节数
    * @param bs 上行字节数组
    * @return 数据长度
    * @throws Exception 异常
    */
   public int parseDataLen(byte[] bs)throws Exception{
      int len = ByteUtilUnsigned.byte2Byte(bs, ProtocolConstantV206V1_0_0.dataLenIndex) ;
      return len + ProtocolConstantV206V1_0_0.lenHead2ctrl + ProtocolConstantV206V1_0_0.lenTail ;
   }


   /**
    * 分析Rtu地址
    * @param bs 上行字节数组
    * @return 控制器地址
    * @throws Exception 异常
    */
   public String parseRtuAddr(byte[] bs)throws Exception{
      String rtuAddrBCD = "" + ByteUtil.BCD2Long_BE(bs, ProtocolConstantV206V1_0_0.rtuAddr1Index_start, ProtocolConstantV206V1_0_0.rtuAddr1Index_end) ;
      String rtuAddrStr = "" + ByteUtilUnsigned.bytes2Short_BE(bs, ProtocolConstantV206V1_0_0.rtuAddr2Index_start) ;
      while(rtuAddrStr.length() < 4){
         rtuAddrStr = "0" + rtuAddrStr ;
      }
      return rtuAddrBCD + rtuAddrStr ;
   }

   /**
    * 分析功能码
    * @param bs 上行字节数组
    * @return 功能码
    */
   public String parseCode(byte[] bs){
      return ByteUtil.bytes2Hex(bs, false, ProtocolConstantV206V1_0_0.codeIndex, 1) ;
   }

   /**
    * 校验和检查
    * @param bs  上行字节数组
    * @return 通过null，未通过返回原因
    * @throws Exception 异常
    */
   public String checkCrc_str(byte[] bs) throws Exception {
      byte crcCompute = (byte)new CRC8_for_2_0().CRC8(bs, ProtocolConstantV206V1_0_0.ctrlIndex, bs.length - 3) ;
      byte crcInBs = bs[bs.length - 2] ;
      if(crcCompute == crcInBs){
         return null ;
      }else{
         return "计算CRC是:" + crcCompute + "，上传CRC是" + crcInBs ;
      }
   }


   /*
   构造控制域
   D7                  D6                  D5～D4            D3～D0
   传输方向位 DIR        拆分标志位 DIV       帧计数位 FCB       功能码
   */
   public byte createCtrl(byte dir, byte funcCode){
      byte b = dir;//(byte)0x80//控制域：DIR=1，表示此帧报文是由终端发出的上行报文；
      b = (byte)(b | funcCode) ;
      //FCB == 3
      b = (byte)(b | (byte)0x18) ;
      //DIV = 0
      //DIR = 0
      return b ;
   }

   /**
    * 得到关开阀类型名称
    * @param type 字节
    * @return 名称
    */
   public static String openCloseValveType(byte type){
      return switch (type) {
         case 1 -> "刷卡开阀";
         case 2 -> "刷卡关阀";
         case 3 -> "中心站开阀";
         case 4 -> "中心站关阀";
         case 5 -> "欠费关阀";
         case 6 -> "流量计故障关阀";
         case 7 -> "紧急关阀";
         case 8 -> "用户远程开阀";
         case 9 -> "用户远程关阀";
         default -> "未知";
      };
   }
	
   /*
    * 分析版本号
    * @param bs  上行字节数组
    * @return 版本号
    * @throws Exception 异常
   public String parseVersion(byte[] bs)throws Exception{
      short ver = ByteUtilUnsigned.byte2Byte(bs, ProtocolConstantV206V1_0_0.versionIndex) ;
      char[] cs = ("" + ver).toCharArray() ;
      StringBuilder vs = new StringBuilder() ;
      for(byte i = 0 ; i < cs.length; i++){
         if(i == 0){
            vs.append(cs[i]) ;
         }else{
            vs.append(".").append(cs[i]) ;
         }
      }
      return vs.toString() ;
   }
   */

}