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

liurunyu

2025-07-31 d15cae9e8d2cabf8d0f3ed41f2f88b04131f8c76

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

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/rtuMw/CodeLocal.java

@@ -3,7 +3,13 @@
public class CodeLocal {

    public static final String clock = "LCD0000" ;//查询监控中间件时钟
    public static final String mwState = "LCD0200" ;//得到通信中间件运行信息

    ////////////////////////////////////////////
    //
    // 以下是相关基于TCP连接的RTU设备的内部命令
    //
    ////////////////////////////////////////////
    public static final String onLineAll = "LCD0001" ;//查询所有RTU在线情况

    public static final String onLinePart = "LCD0002" ;//查询部分RTU在线情况
@@ -22,6 +28,27 @@

    public static final String recoverTcpSv = "LCD0112" ;//重启TCP服务，接入新的TCP连接

    public static final String mwState = "LCD0200" ;//得到通信中间件运行信息

    ////////////////////////////////////////////
    //
    // 以下是相关基于MQTT连接的设备的内部命令
    //
    ////////////////////////////////////////////
    public static final String onAllLineMqtt = "LMCD0001" ;//查询所有MQTT设备在线情况

    public static final String onPartLineMqtt = "LMCD0002" ;//查询部分MQTT设备在线情况

    public static final String onLineStatisticsMqtt = "LMCD0003" ;//查询所有MQTT设备在线状态统计情况

    public static final String allRtuStatesMqtt = "LMCD0010" ;//查询所有MQTT设备状态

    public static final String partRtuStatesMqtt = "LMCD0011" ;//查询部分MQTT设备状态

    public static final String oneRtuStatesMqtt = "LMCD0012" ;//查询一个MQTT设备状态

    public static final String stopMqttSv = "LMCD0110" ;//停止Mqtt服务

    public static final String recoverMqttSv = "LMCD0112" ;//重启MQTT服务，接入新的MQTT连接


}

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/monitor/MonitorCtrl.java

@@ -30,6 +30,43 @@
    private final MonitorSv monitorSv;

    /**
     * 查询设备是否在线
     *
     * @param rtuAddr
     * @return
     */
    @GetMapping(path = "isOnLine4Rtu")
    @SsoAop()
    public BaseResponse<Boolean> isOnLine4Rtu(String rtuAddr) {
        try {
            Boolean res = monitorSv.isOnLine4Rtu(rtuAddr);
            return BaseResponseUtils.buildSuccess(res);
        } catch (Exception e) {
            log.error("命令执行异常", e);
            return BaseResponseUtils.buildException(e.getMessage());
        }
    }

    /**
     * 查询设备是否在线
     *
     * @param rtuAddr
     * @return
     */
    @GetMapping(path = "isOnLine4Mqtt")
    @SsoAop()
    public BaseResponse<Boolean> isOnLine4Mqtt(String rtuAddr) {
        try {
            Boolean res = monitorSv.isOnLine4Mqtt(rtuAddr);
            return BaseResponseUtils.buildSuccess(res);
        } catch (Exception e) {
            log.error("命令执行异常", e);
            return BaseResponseUtils.buildException(e.getMessage());
        }
    }


    /**
     * 获取取水口列表（在线和不在线）
     *
     * @param qo

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/monitor/MonitorSv.java

@@ -46,6 +46,23 @@
    private RestTemplate restTemplate;

    /**
     * 查询设备是否在线
     *
     * @return
     */
    public Boolean isOnLine4Rtu(String devId) {
        return selectOnOrOffLine4Rtu(devId) ;
    }

    /**
     * 查询设备是否在线
     *
     * @return
     */
    public Boolean isOnLine4Mqtt(String devId) {
        return selectOnOrOffLine4Mqtt(devId) ;
    }
    /**
     * 获取已经绑定控制器的取水口列表（并标记在线与不在线）
     *
     * @return
@@ -152,6 +169,79 @@


    /**
     * 查询RTU在线或离线状态
     * @param rtuAddr
     * @return
     */
    private Boolean selectOnOrOffLine4Rtu(String rtuAddr) {
        //向通信中间件发关命令，查询部分RTU在线情况
        Command com = this.createInnerCommand(CodeLocal.onPartLineMqtt);
        com.setParam(rtuAddr) ;
        String rqUrl = this.get2MwRequestUrl(this.env, ContextComSend) ;
        BaseResponse res = sendPostRequest2Mw(restTemplate, rqUrl, com) ;
        if(res != null){
            if(res.isSuccess()){
                Command reCom = JSON.parseObject(res.getContent() == null ? null : JSON.toJSONString(res.getContent()), Command.class) ;
                CommandBackParam bakParam = JSON.parseObject((reCom== null || reCom.param == null) ? null : JSON.toJSONString(reCom.param), CommandBackParam.class) ;
                if(bakParam != null){
                    if(bakParam.getSuccess().booleanValue()){
                        //通信中间件成功返回命令结果
                        HashMap<String, Boolean> onLineMap = JSON.parseObject(JSON.toJSONString(reCom.getAttachment()), HashMap.class);
                        Boolean flag = onLineMap.get(rtuAddr);
                        if(flag != null){
                            return flag ;
                        }
                    }
                }else{
                    log.error("通信中间件返回内部命令结果中不包含CommandBackParam类型参数");
                }
            }else{
                log.error("通信中间件返回内部命令执行失败" + (res.getMsg() == null? "" : ("，" + res.getMsg()))) ;
            }
        }else{
            log.error("通信中间件返回内部命令结果为null");
        }
        return null ;
    }


    /**
     * 查询MQTT在线或离线状态
     * @param devId
     * @return
     */
    private Boolean selectOnOrOffLine4Mqtt(String devId) {
        //向通信中间件发关命令，查询部分RTU在线情况
        Command com = this.createInnerCommand(CodeLocal.onPartLineMqtt);
        com.setParam(devId) ;
        String rqUrl = this.get2MwRequestUrl(this.env, ContextComSend) ;
        BaseResponse res = sendPostRequest2Mw(restTemplate, rqUrl, com) ;
        if(res != null){
            if(res.isSuccess()){
                Command reCom = JSON.parseObject(res.getContent() == null ? null : JSON.toJSONString(res.getContent()), Command.class) ;
                CommandBackParam bakParam = JSON.parseObject((reCom== null || reCom.param == null) ? null : JSON.toJSONString(reCom.param), CommandBackParam.class) ;
                if(bakParam != null){
                    if(bakParam.getSuccess().booleanValue()){
                        //通信中间件成功返回命令结果
                        HashMap<String, Boolean> onLineMap = JSON.parseObject(JSON.toJSONString(reCom.getAttachment()), HashMap.class);
                        Boolean flag = onLineMap.get(devId);
                        if(flag != null){
                            return flag ;
                        }
                    }
                }else{
                    log.error("通信中间件返回内部命令结果中不包含CommandBackParam类型参数");
                }
            }else{
                log.error("通信中间件返回内部命令执行失败" + (res.getMsg() == null? "" : ("，" + res.getMsg()))) ;
            }
        }else{
            log.error("通信中间件返回内部命令结果为null");
        }
        return null ;
    }

    /**
     * 查询取水口，在线或离线状态
     * @param vo
     * @return