1

zhang

2025-06-17 6b1c3d08808590cd8358c5c3b098fb5f72ef2993

1

 zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvCompleteSubscriber.java

@@ -4,6 +4,7 @@
import com.zy.acs.common.domain.AgvProtocol;
import com.zy.acs.common.utils.RedisSupport;
import com.zy.acs.manager.core.service.MainService;
import com.zy.acs.manager.system.service.ConfigService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.event.ApplicationReadyEvent;
@@ -25,6 +26,10 @@
    @Autowired
    private MainService mainService;

    @Autowired
    private ConfigService configService;


    @EventListener(ApplicationReadyEvent.class)
    private void start(){
        thread = new Thread(() -> {
@@ -33,6 +38,8 @@
                    // 间隔
                    Thread.sleep(30);

                    if (configService.getVal("stopDownData", Boolean.class)) { return; }

                    AgvProtocol protocol = redis.pop(RedisConstant.AGV_COMPLETE_FLAG);
                    if (null != protocol){


 zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvDataSubscriber.java

@@ -4,6 +4,7 @@
import com.zy.acs.common.domain.AgvProtocol;
import com.zy.acs.common.utils.RedisSupport;
import com.zy.acs.manager.core.service.AgvDataService;
import com.zy.acs.manager.system.service.ConfigService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.event.ApplicationReadyEvent;
@@ -25,6 +26,10 @@
    @Autowired
    private AgvDataService agvDataService;

    @Autowired
    private ConfigService configService;


    @EventListener(ApplicationReadyEvent.class)
    private void start(){
//        redis.deleteList(RedisConstant.AGV_DATA_FLAG);
@@ -34,6 +39,8 @@
                    // 间隔
                    Thread.sleep(10);

                    if (configService.getVal("stopDownData", Boolean.class)) { return; }

                    AgvProtocol protocol = redis.pop(RedisConstant.AGV_DATA_FLAG);
                    if (null != protocol){