From 6cff241b690cfda683932b6dc0a2a5852c6a8169 Mon Sep 17 00:00:00 2001
From: lilin <succ_secret@163.com>
Date: Fri, 23 May 2025 18:08:58 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/TsFilesController.java         | 59 ++++++++++---------
 1 file changed, 30 insertions(+), 29 deletions(-)

diff --git a/java/src/main/java/com/yfd/platform/modules/experimentalData/controller/TsFilesController.java b/java/src/main/java/com/yfd/platform/modules/experimentalData/controller/TsFilesController.java
index d4e1f95..1b9d38d 100644
--- a/java/src/main/java/com/yfd/platform/modules/experimentalData/controller/TsFilesController.java
+++ b/java/src/main/java/com/yfd/platform/modules/experimentalData/controller/TsFilesController.java
@@ -564,6 +564,36 @@ public class TsFilesController {
             return ResponseResult.success("任务已由其他请求启动");
         }
     }
+    /**********************************
+     * 用途说明: 获取异步信息
+     * 参数说明  taskId 所属项目ID
+     * 参数说明  nodeId 所属节点ID
+     * 返回值说明: com.yfd.platform.config.ResponseResult 返回成功或者失败
+     ***********************************/
+    @Log(module = "根据项目和节点获取异步信息", value = "根据项目和节点获取异步信息！")
+    @PostMapping("/automaticFileBackupData")
+    @ApiOperation("获取异步信息")
+    public ResponseResult automaticFileBackupData(String taskId, String nodeId) throws Exception {
+        if (StrUtil.isEmpty(taskId) || StrUtil.isEmpty(nodeId)) {
+            return ResponseResult.error("参数为空");
+        }
+        // 生成唯一Key
+        String asyncKey = taskStatusHolder.generateKey(taskId, nodeId);
+
+        // 检查任务是否已存在
+        String existingStatus = taskStatusHolder.getStatus(asyncKey);
+        if ("TASK_NOT_FOUND".equals(existingStatus)) {
+            return ResponseResult.success("1");
+        }
+        if ("IN_PROGRESS".equals(existingStatus)) {
+            return ResponseResult.success("0");
+        } else if ("COMPLETED".equals(existingStatus)) {
+            return ResponseResult.success("自动备份任务已完成!");
+        }
+
+        return null;
+    }
+
 
     /**********************************
      * 用途说明: 文件自动备份通过ID
@@ -600,36 +630,7 @@ public class TsFilesController {
         }
     }
 
-    /**********************************
-     * 用途说明: 获取异步信息
-     * 参数说明  id 所属项目ID
-     * 返回值说明: com.yfd.platform.config.ResponseResult 返回成功或者失败
-     ***********************************/
-    @Log(module = "获取异步信息", value = "获取异步信息！")
-    @PostMapping("/automaticFileBackupData")
-    @ApiOperation("获取异步信息")
-    public ResponseResult automaticFileBackupData(String id) throws Exception {
-        if (StrUtil.isEmpty(id) ) {
-            return ResponseResult.error("参数为空");
-        }
-        List<String> dataset = StrUtil.split(id, ",");
 
-        // 生成唯一Key
-        String asyncKey = taskStatusHolder.generateKeybyId(dataset);
-
-        // 检查任务是否已存在
-        String existingStatus = taskStatusHolder.getStatus(asyncKey);
-        if ("TASK_NOT_FOUND".equals(existingStatus)) {
-            return ResponseResult.success("1");
-        }
-        if ("IN_PROGRESS".equals(existingStatus)) {
-            return ResponseResult.success("0");
-        } else if ("COMPLETED".equals(existingStatus)) {
-            return ResponseResult.success("自动备份任务已完成!");
-        }
-
-        return null;
-    }
 
     /**********************************
      * 用途说明: 实时获取轨迹数据