Merge remote-tracking branch 'origin/master'

zuoxiao

2025-06-25 d2fc819dc069c7b8d338ae52a90a7f38704fac08

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/tasks/MqttSubMessageConstantTask.java

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

import com.dy.common.mw.core.CoreTask;
import com.dy.common.queue.Node;
import com.dy.rtuMw.server.mqtt.DevStatusDealer;
import com.dy.rtuMw.server.mqtt.MqttSubMsgCache;
import com.dy.rtuMw.server.mqtt.MqttSubMsgNode;
import org.apache.logging.log4j.LogManager;
@@ -21,16 +22,26 @@
    @Override
    public Integer execute() {
        try{
            dealOneline() ;
        }catch(Exception e){
            log.error("更新RTU会话上报数据时刻时发生集合操作异常，此异常并不影响系统正常运行", e);
        }
        try{
            dealMqMsg() ;
        }catch(Exception e){
            log.error(e);
        }
        return MqttSubMsgCache.size()>0?0:1 ;
    }

    private void dealOneline(){
        DevStatusDealer.updateOnLineState();
    }

    /**
     * 处理MQTT订阅的消息
     */
    public void dealMqMsg() {
    private void dealMqMsg() {
        Node first = MqttSubMsgCache.getFirstQueueNode() ;
        if(first != null){
            Node last = MqttSubMsgCache.getLastQueueNode() ;