1

zhang

2025-06-17 bc64b3b45cf00885696aea4cfa97230390717012

 zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/KernelScheduler.java

@@ -3,7 +3,7 @@
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.zy.acs.manager.core.domain.AgvTaskDto;
import com.zy.acs.manager.core.service.MainLockWrapService;
import com.zy.acs.manager.core.service.MainService;
import com.zy.acs.manager.core.service.MainLxtService;
import com.zy.acs.manager.core.service.TrafficService;
import com.zy.acs.manager.manager.entity.Bus;
import com.zy.acs.manager.manager.entity.Segment;
@@ -16,8 +16,6 @@
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;
import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@@ -53,7 +51,7 @@
    @Autowired
    private TaskService taskService;
    @Autowired
    private MainService mainService;
    private MainLxtService mainService;
    @Autowired
    private MainLockWrapService mainLockWrapService;
    @Autowired
@@ -69,7 +67,7 @@
    @Autowired
    private AgvModelService agvModelService;

    @Scheduled(cron = "0/1 * * * * ? ")
    //@Scheduled(cron = "0/1 * * * * ? ")
    private void startupBus() throws InterruptedException {
//        if (!configService.getVal("TaskAssignMode", Boolean.class)) { return; }
        if (!this.lock.tryLock(LOCK_TIMEOUT, TimeUnit.SECONDS)) { return; }
@@ -80,7 +78,7 @@
        this.lock.unlock();
    }

    @Scheduled(cron = "0/1 * * * * ? ")
    //@Scheduled(cron = "0/1 * * * * ? ")
    private void calculateSeg() throws InterruptedException {
        if (!this.lock.tryLock(LOCK_TIMEOUT, TimeUnit.SECONDS)) { return; }
        List<Task> taskList = taskService.selectBySts(TaskStsType.WAITING);
@@ -103,7 +101,7 @@
        this.lock.unlock();
    }

    @EventListener(ApplicationReadyEvent.class)
    //@EventListener(ApplicationReadyEvent.class)
    public void init() {
        try { Thread.sleep(1200); } catch (InterruptedException ignore) {}
        // traffic calculate
@@ -118,7 +116,7 @@
                    for (Segment segment : segments) {
                        long startTime = System.currentTimeMillis();
                        trafficService.trigger(segment);
                        log.info("traffic calculation spend {} ms", System.currentTimeMillis() - startTime);
//                        log.info("traffic calculation spend {} ms", System.currentTimeMillis() - startTime);
                    }

                } catch (Exception e) {