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

Administrator

2024-06-06 70cd3733e8d72a6bbcfcbfa78f8eecbdec7ee8f9

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

@@ -2,6 +2,7 @@

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 {
@@ -49,13 +50,26 @@


   /**
    * 分析数据字节数
    * 分析帧长度
    * @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{
      return ByteUtilUnsigned.bytes2Short_BE(bs, ProtocolConstantV206V1_0_0.dataLenIndex) ;
      int len = ByteUtilUnsigned.byte2Byte(bs, ProtocolConstantV206V1_0_0.dataLenIndex) ;
      return len + ProtocolConstantV206V1_0_0.lenHead2ctrl + ProtocolConstantV206V1_0_0.lenTail ;
   }


@@ -67,12 +81,30 @@
    */
   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() < 6){
      String rtuAddrStr = "" + ByteUtilUnsigned.bytes2Short_LE(bs, ProtocolConstantV206V1_0_0.rtuAddr2Index_start) ;
      while(rtuAddrStr.length() <= 5){
         rtuAddrStr = "0" + rtuAddrStr ;
      }
      return rtuAddrBCD + rtuAddrStr ;
   }


   /**
    * 分析Rtu地址
    * @param bs 上行字节数组
    * @param index 启始位
    * @return 控制器地址
    * @throws Exception 异常
    */
   public String parseRtuAddr(byte[] bs, int index)throws Exception{
      String rtuAddrBCD = "" + ByteUtil.BCD2Long_BE(bs, index, index + 2) ;//地址是大端模式
      String rtuAddrStr = "" + ByteUtilUnsigned.bytes2Short_LE(bs, index + 3) ;
      while(rtuAddrStr.length() < 5){
         rtuAddrStr = "0" + rtuAddrStr ;
      }
      return rtuAddrBCD + rtuAddrStr ;
   }


   /**
    * 分析功能码
@@ -83,20 +115,6 @@
      return ByteUtil.bytes2Hex(bs, false, ProtocolConstantV206V1_0_0.codeIndex, 1) ;
   }


   /**
    * 校验和检查
    * @param bs 上行字节数组
    * @return 通过true,未通过false
    */
   public boolean checkCrc(byte[] bs) {
      byte he = 0 ;
      for(int i = 0 ; i <= bs.length - 3 ; i++){
         he = (byte)(he + bs[i]) ;
      }
      return bs[bs.length - 2] == he ;
   }

   /**
    * 校验和检查
    * @param bs  上行字节数组
@@ -104,16 +122,12 @@
    * @throws Exception 异常
    */
   public String checkCrc_str(byte[] bs) throws Exception {
      byte[] he = new byte[1] ;
      for(int i = 0 ; i <= bs.length - 3 ; i++){
         he[0] = (byte)(he[0] + bs[i]) ;
      }
      short hes = ByteUtilUnsigned.byte2Byte(he, 0);
      short heOrg = ByteUtilUnsigned.byte2Byte(bs, bs.length - 2);
      if(hes == heOrg){
      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 "计算校验和是:" + hes + "，上传校验和是" + heOrg ;
         return "计算CRC是:" + crcCompute + "，上传CRC是" + crcInBs ;
      }
   }

@@ -123,18 +137,34 @@
   D7                  D6                  D5～D4            D3～D0
   传输方向位 DIR        拆分标志位 DIV       帧计数位 FCB       功能码
   */
   public byte createCtrl(byte funcCode){
      byte b = 0 ;
   public byte createCtrl(byte dir, byte funcCode){
      byte b = dir;//(byte)0x80//控制域：DIR=1，表示此帧报文是由终端发出的上行报文；
      b = (byte)(b | funcCode) ;
      //FCB == 3
      b = (byte)(b | (byte)60) ;
      b = (byte)(b | (byte)0x18) ;
      //DIV = 0
      //DIR = 0
      return b ;
   }
   /**
    * 得到IC卡类型名称 （ 卡类型(1:用户卡；2：管理员卡；3：调试卡；4：开关阀卡；5：清空卡)）
    * @param type 字节
    * @return 名称
    */
   public static String icCardType(byte type){
      return switch (type) {
         case 1 -> "用户卡";
         case 2 -> "管理员卡";
         case 3 -> "调试卡";
         case 4 -> "开关阀卡";
         case 5 -> "清空卡";
         default -> "未知";
      };
   }

   /**
    * 得到关开阀类型名称
    * 开关阀类型(1:刷卡开阀；2:刷卡关阀；3:中心站开阀；4:中心站关阀；5:欠费关阀；6:流量计故障关阀；7:紧急关闭；8:用户远程开阀；9:用户远程关阀；10:开关阀卡关阀；11:开关阀卡刷卡卡开阀；)
    * @param type 字节
    * @return 名称
    */
@@ -149,9 +179,47 @@
         case 7 -> "紧急关阀";
         case 8 -> "用户远程开阀";
         case 9 -> "用户远程关阀";
         case 10 -> "开关阀卡关阀";
         case 11 -> "开关阀卡开阀";
         default -> "未知";
      };
   }
   public static Boolean isCloseValveType(byte type){
      return switch (type) {
         case 1 -> false ;
         case 2 -> true ;
         case 3 -> false ;
         case 4 -> true ;
         case 5 -> true ;
         case 6 -> true ;
         case 7 -> true ;
         case 8 -> false ;
         case 9 -> true ;
         case 10 -> true ;
         case 11 -> false ;
         default -> null ;
      };
   }

   /**
    * 处理IC卡编号，靳总制定的协议要求10位IC卡编号
    * @param icCardNo
    * @return
    */
   public static String[] dealIcCardNo(String icCardNo){
      if(icCardNo.length() > 10){
         String tail = icCardNo.substring(icCardNo.length() - 10) ;
         String head = icCardNo.substring(0, icCardNo.length() - 10) ;
         return new String[]{head , tail} ;
      }else if(icCardNo.length() < 10){
         while(icCardNo.length() != 10){
            icCardNo = "0" + icCardNo ;
         }
         return new String[]{null , icCardNo} ;
      }else{
         return new String[]{null , icCardNo} ;
      }
   }
   
   /*
    * 分析版本号