#

vincentlu

2026-03-25 bbec4bfd2d28d6063305e214676e7d03f9e797f2

#

 zy-acs-common/src/main/java/com/zy/acs/common/constant/RedisConstant.java

@@ -55,4 +55,8 @@

    public static final String MAP_AREA_DATA_FLAG = "MAP_AREA_DATA_FLAG";

    // ------------------------------------------------------------------------------------

    public static final String HK_AGV_ONLINE_FLAG = "HK_AGV_ONLINE_FLAG";

}

 zy-acs-hk/zy-acs-hk-latent/src/main/java/com/zy/acs/hk/latent/mqtt/handler/ConnectionMessageHandler.java

@@ -1,5 +1,7 @@
package com.zy.acs.hk.latent.mqtt.handler;

import com.zy.acs.common.constant.RedisConstant;
import com.zy.acs.common.utils.RedisSupport;
import com.zy.acs.hk.latent.mqtt.HkMessageHandler;
import com.zy.acs.hk.latent.mqtt.type.HkSubTopicType;
import com.zy.acs.hk.latent.mqtt.HkTopicInfo;
@@ -10,6 +12,8 @@
@Component
public class ConnectionMessageHandler implements HkMessageHandler {

    private final RedisSupport redis = RedisSupport.defaultRedisSupport;

    @Override
    public String supportSubTopic() {
        return HkSubTopicType.CONNECTION.getCode();
@@ -19,6 +23,8 @@
    public void handle(HkTopicInfo topicInfo, String payload) {
        log.info("handle connection message, agvNo={}, topic={}, payload={}",
                topicInfo.getAgvNo(), topicInfo.getRawTopic(), payload);

        redis.setObject(RedisConstant.HK_AGV_ONLINE_FLAG, topicInfo.getAgvNo(), 1, 30);
    }

}