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

liurunyu

2025-07-31 85f4fbf75505c35a4d0e53515ffb3affb6fd95f2

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/CommonV202404.java

@@ -1,8 +1,7 @@
package com.dy.common.mw.protocol.p206V202404;

import com.dy.common.mw.channel.tcp.TcpIoSessionAttrIdIsRtuAddr;
import com.dy.common.mw.protocol.p206V1.ProtocolConstantV206V1;
import com.dy.common.mw.protocol.p206V2.ProtocolConstantV206V2;

import com.dy.common.util.ByteUtil;
import com.dy.common.util.ByteUtilUnsigned;
import com.dy.common.util.CRC16;
@@ -17,8 +16,8 @@
     * @param ioSession 会话
     */
    public void setThisProtocolArr2IoSession(IoSession ioSession){
        ioSession.setAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrProtocolName, ProtocolConstantV206V1.protocolName) ;
        ioSession.setAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrProtocolName, ProtocolConstantV206V1.protocolVer) ;
        ioSession.setAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrProtocolName, ProtocolConstantV206V202404.protocolName) ;
        ioSession.setAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrProtocolName, ProtocolConstantV206V202404.protocolVer) ;
    }
    /**
     * 检查头
@@ -38,7 +37,7 @@
                    return false ;
                }
            }else if((byte)(bs[2] & 0xF8) == ProtocolConstantV206V202404.P_Head_Byte){
                //如果控制域、地址域、用户数据域(应用层)的字节总数大于255，则通过扩展第二个开始字符0x68的低3位作为长L的高位扩展
                //如果控制域、地址域、用户数据域(应用层)的字节总数大于255，则通过扩展第二个开始字符0x69的低3位作为长L的高位扩展
                //0xF8二进制： 11111000
                if(bs[3] == (byte)0x80 || bs[3] == (byte)0x81){
                    return true ;
@@ -123,8 +122,8 @@
     * @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 ;
        int len = ByteUtilUnsigned.bytes2Short_LE(bs, ProtocolConstantV206V202404.UG_dataLenIndex_start) ;
        return len - ProtocolConstantV206V202404.UG_lenCmd - ProtocolConstantV206V202404.UG_lenRtuAddr ;
    }


@@ -253,22 +252,113 @@
    }

    /**
     * 得到关开阀类型名称
     * 1个HEX
     * 0x01:正常刷卡开泵/阀用水
     * 0x02:平台远程开泵/阀用水
     * 0x08:用户远程开泵/阀用水
     * 0x0b:巡检卡，
     * 0x04:其它
     * @param type
     * @return
     */
    public static String openValveType(byte type){
        return switch (type) {
            case 1 -> "刷卡开阀";
            case 2 -> "中心站开阀";
            case 8 -> "用户远程开阀";
            case 11 -> "巡检卡开阀";
            case 4 -> "其它开阀";
            default -> "未知";
        };
    }
    /**
     * 0x01：刷卡开阀 => p206V1 1
     * 0x02：中心站开阀 => p206V1 3
     * 0x08：用户App远程开阀 => p206V1 3
     * 0x0B：巡检卡开阀 => p206V1 11
     * @param type
     * @return
     */
    public static byte openType2P206V1(byte type){
        return switch (type) {
            case 1 -> (byte)1 ;
            case 2 -> (byte)3 ;
            case 8 -> (byte)8 ;
            case 11 -> (byte)11 ;
            default -> (byte)-1;
        };
    }

    /**
     * 得到关阀类型名称
     * 0x01:刷卡闭
     * 0x02:平台关
     * 0x03:非法卡关
     * 0x04:水表通讯异常关，
     * 0x05:电表异常关，
     * 0x06:剩余水量不足关
     * 0x07:剩余金额为0关，
     * 0x08:APP关 ，
     * 0x09:掉电再上电关，
     * 0x0a:水表瞬时流量为0关，
     * 0x0b:巡检关，
     * 0x0c:电池低电压关。
     * @param type 字节
     * @return 名称
     */
    public static String openCloseValveType(byte type){
    public static String closeValveType(byte type){
        return switch (type) {
            case 1 -> "刷卡开阀";
            case 2 -> "刷卡关阀";
            case 3 -> "中心站开阀";
            case 4 -> "中心站关阀";
            case 5 -> "欠费关阀";
            case 6 -> "流量计故障关阀";
            case 7 -> "紧急关阀";
            case 8 -> "用户远程开阀";
            case 9 -> "用户远程关阀";
            case 16 -> "管道无水自动关阀";
            case 1 -> "刷卡关阀";
            case 2 -> "平台关阀";
            case 3 -> "非法卡关阀";
            case 4 -> "水表通讯异常关阀";
            case 5 -> "电表异常关阀";
            case 6 -> "剩余水量不足关阀";
            case 7 -> "剩余金额为0关阀";
            case 8 -> "APP关阀";
            case 9 -> "掉电再上电关阀";
            case 10 -> "水表瞬时流量为0关阀";
            case 11 -> "巡检关阀";
            case 12 -> "电池低电压关阀";
            default -> "未知";
        };
    }
    /**
     * 得到关开阀类型名称
     * 0x01:刷卡闭 => p206V1 1
     * 0x02:平台关 => p206V1 4
     * 0x03:非法卡关 => p206V1 12
     * 0x04:水表通讯异常关 => p206V1 6
     * 0x05:电表异常关 => p206V1 6
     * 0x06:剩余水量不足关 => p206V1 5
     * 0x07:剩余金额为0关 => p206V1 5
     * 0x08:APP关 => p206V1 9
     * 0x09:掉电再上电关， => p206V1 7
     * 0x0a:水表瞬时流量为0关， => p206V1 5
     * 0x0b:巡检关。 => p206V1 10
     * 0x0c:电池低电压关。 => p206V1 7
     * @param type 字节
     * @return 名称
     */
    public static byte closeType2P206V1(byte type){
        return switch (type) {
            case 1 -> (byte)2;
            case 2 -> (byte)4;
            case 3 -> (byte)12;
            case 4,5,10 -> (byte)6;
            case 6,7 -> (byte)5;
            case 8 -> (byte)9;
            case 9,12 -> (byte)7;
            case 11 -> (byte)10;
            default -> (byte)-1;
        };
    }

    public static String ctrlDevType(String hex){
        return switch (hex) {
            case "01" -> "测控一体阀";
            case "02" -> "表阀一体机";
            case "57" -> "井电控制器";
            default -> "未知";
        };
    }