增加查询单个设备（RTU或FBox）是否在线的功能接口

liurunyu

2025-07-31 85f4fbf75505c35a4d0e53515ffb3affb6fd95f2

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

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

import com.dy.common.mw.channel.tcp.TcpIoSessionAttrIdIsRtuAddr;
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.CRC16;
import com.dy.common.util.CRC8_for_2_0;
import org.apache.mina.core.session.IoSession;


public class CommonV2 {

   /**
    * 在Io会话中设置协议名称及版本号
    * @param ioSession 会话
    */
   public void setThisProtocolArr2IoSession(IoSession ioSession){
      ioSession.setAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrProtocolName, ProtocolConstantV206V1.protocolName) ;
      ioSession.setAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrProtocolName, ProtocolConstantV206V1.protocolVer) ;
   }
   /**
    * 检查头
    * @param bs 上行字节数组
    * @return true是,false否
    * @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) ;
         if(vs.shortValue() == ProtocolConstantV206V2.protocolVer){
            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 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
    * @return
    */
   public Short parseVersion(byte[] bs)throws Exception{
      return ByteUtil.byte2PlusInt(bs[ProtocolConstantV206V2.versionIndex]) ;
   }

   /**
    * 检查尾
    * @param bs 上行字节数组
    * @throws Exception 异常
    */
   public void checkTail(byte[] bs) throws Exception{
      if(bs.length < 1 || bs[bs.length - 1] != ProtocolConstantV206V2.P_Tail_Byte){
         throw new Exception("上行数据尾不正确！") ;
      }
   }


   /**
    * 分析帧长度
    * @param bs 上行字节数组
    * @param p206TrueUgFalse 206协议为true，升级协议为false
    * @return 数据长度
    * @throws Exception 异常
    */
   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 parseDataLen4P206(byte[] bs)throws Exception{
      int len = ByteUtilUnsigned.byte2Byte(bs, ProtocolConstantV206V2.dataLenIndex) ;
      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 ;
   }


   /**
    * 分析Rtu地址
    * @param bs 上行字节数组
    * @return 控制器地址
    * @throws Exception 异常
    */
   public String parseRtuAddr(byte[] bs)throws Exception{
      String rtuAddrBCD = "" + ByteUtil.BCD2Long_BE(bs, ProtocolConstantV206V2.rtuAddr1Index_start, ProtocolConstantV206V2.rtuAddr1Index_end) ;
      String rtuAddrStr = "" + ByteUtilUnsigned.bytes2Short_LE(bs, ProtocolConstantV206V2.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 ;
   }


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

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

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


   /**
    * 校验和检查
    * @param bs  上行字节数组
    * @param p206TrueUgFalse 206协议为true，升级协议为false
    * @return 通过null，未通过返回原因
    * @throws Exception 异常
    */
   public String checkCrc_str(byte[] bs, boolean p206TrueUgFalse) throws Exception {
      if(p206TrueUgFalse){
         byte crcCompute = (byte)new CRC8_for_2_0().CRC8(bs, ProtocolConstantV206V1.ctrlIndex, bs.length - 3) ;
         byte crcInBs = bs[bs.length - 2] ;
         if(crcCompute == crcInBs){
            return null ;
         }else{
            return "计算CRC是:" + crcCompute + "，上传CRC是" + crcInBs ;
         }
      }else{
         short crcCompute = new CRC16().CRC(bs, 0, bs.length - 4) ;
         short crcInBs = ByteUtil.bytes2Short_BE(bs,bs.length - 3) ;
         //int crcInBs = ByteUtilUnsigned.bytes2Short_BE(bs, bs.length - 3) ;
         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 ;
   }
   /**
    * 得到IC卡类型名称 （ 卡类型(1:用户卡；2：管理员卡；3：调试卡；4：巡检卡；5：清空卡)）
    * @param type 字节
    * @return 名称
    */
   public static String icCardType(byte type){
      return switch (type) {
         case 0 -> "无卡";
         case 1 -> "用户卡";
         case 2 -> "管理员卡";
         case 3 -> "调试卡";
         case 4 -> "巡检卡";
         case 5 -> "清空卡";
         default -> "未知";
      };
   }

   /**
    * 得到关开阀类型名称
    * 开关阀类型(
    * 1:刷卡开阀；
    * 2:刷卡关阀；
    * 3:中心站开阀；
    * 4:中心站关阀；
    * 5:余额不足关阀；
    * 6:流量计故障关阀；
    * 7:紧急关闭；
    * 8:用户远程开阀；
    * 9:用户远程关阀；
    * 10:巡检卡关阀；
    * 11:巡检卡刷卡卡开阀；
    * 12:黑名单命令关阀；
    * 13:远程定时关阀；
    * 14:远程定量关阀；
    * 16:管道无水自动关阀；(王江海协议)
    * )
    * @param type 字节
    * @return 名称
    */
   public static String openCloseValveType(Byte type){
      if(type == null){
         return "" ;
      }
      return switch (type) {
         case 1 -> "刷卡开阀";
         case 2 -> "刷卡关阀";
         case 3 -> "中心站开阀";
         case 4 -> "中心站关阀";
         case 5 -> "余额不足关阀";
         case 6 -> "流量计故障关阀";
         case 7 -> "紧急关阀";
         case 8 -> "用户远程开阀";
         case 9 -> "用户远程关阀";
         case 10 -> "巡检卡关阀";
         case 11 -> "巡检卡开阀";
         case 12 -> "黑名单命令关阀";
         case 13 -> "远程定时关阀";
         case 14 -> "远程定量关阀";
         case 16 -> "管道无水自动关阀";
         default -> "未知";
      };
   }
   public static Boolean isCloseValveType(byte type){
      return switch (type) {
         case 1, 3, 8, 11 -> false ;
         case 2, 4, 5, 6, 7, 9, 10, 12, 13, 14 -> true ;
         default -> null ;
      };
   }


}