From 24f92273cf76717064b64763be373d2217e7a4ef Mon Sep 17 00:00:00 2001
From: zch <765536121@qq.com>
Date: Sat, 21 Mar 2026 11:03:07 +0800
Subject: [PATCH] =?UTF-8?q?=E7=9B=91=E6=8E=A7=E5=90=AF=E6=99=BA=E6=99=BA?=
 =?UTF-8?q?=E7=AE=97=E4=BB=BB=E5=8A=A1=E7=8A=B6=E6=80=81=E5=AE=9A=E6=97=B6?=
 =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E4=BF=AE=E6=94=B9=E5=88=A4=E6=96=AD=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../scheduling/ServiceVersionStatusTask.java     | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/ServiceVersionStatusTask.java b/ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/ServiceVersionStatusTask.java
index 9c748ec1..de879393 100644
--- a/ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/ServiceVersionStatusTask.java
+++ b/ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/ServiceVersionStatusTask.java
@@ -44,7 +44,7 @@ public class ServiceVersionStatusTask {
         STATUS_URL = zsServiceVersionUrl + "/api/v1/getInferenceTaskAsync";
     }
 
-//    @Scheduled(cron = "0 * * * * ?") // 每分钟执行一次
+    @Scheduled(cron = "0 * * * * ?") // 每分钟执行一次
     public void executeServiceVersionStatus() {
         try {
             // 1. 调用queryAllVersionList接口获取所有runState为RUNNING的数据
@@ -163,7 +163,7 @@ public class ServiceVersionStatusTask {
     /**
      * 新增定时任务：处理已完成的任务，获取URL
      */
-//    @Scheduled(cron = "0 * * * * ?") // 每分钟执行一次
+    @Scheduled(cron = "0 * * * * ?") // 每分钟执行一次
     public void executeSetUrl() {
         try {
             // 1. 调用queryAllComplList接口获取所有runState为COMPLETED且url为空的数据
@@ -205,11 +205,11 @@ public class ServiceVersionStatusTask {
      */
     @Scheduled(cron = "0 * * * * ?") // 每分钟执行一次
     public void executeServiceStatusChange() {
-        try {
-            List<ServiceVersionZs> completedVersions = serviceVersionMapper.queryAllRunList();
 
-            if (completedVersions != null && !completedVersions.isEmpty()) {
-                for (ServiceVersionZs version : completedVersions) {
+        List<ServiceVersionZs> runningVersions = serviceVersionMapper.queryAllRunList();
+        if (runningVersions != null && !runningVersions.isEmpty()) {
+            try {
+                for (ServiceVersionZs version : runningVersions) {
                     // 2. 过滤获取数据中的jobSetId字段
                     String jobSetId = version.getJobSetId();
                     if (jobSetId != null && !jobSetId.isEmpty()) {
@@ -231,9 +231,9 @@ public class ServiceVersionStatusTask {
                         }
                     }
                 }
+            } catch (Exception e) {
+                logger.error("Error executing service version URL task", e);
             }
-        } catch (Exception e) {
-            logger.error("Error executing service version URL task", e);
         }
     }