From bc64b3b45cf00885696aea4cfa97230390717012 Mon Sep 17 00:00:00 2001 From: zhang <zc857179121@qq.com> Date: 星期二, 17 六月 2025 15:38:59 +0800 Subject: [PATCH] 1 --- zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/KernelScheduler.java | 12 +++++------- 1 files changed, 5 insertions(+), 7 deletions(-) diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/KernelScheduler.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/KernelScheduler.java index 43d4ac0..cd4e72d 100644 --- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/KernelScheduler.java +++ b/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 -- Gitblit v1.9.1