From 9916f641ac72cea314f7a730df6d6726a5e8bb05 Mon Sep 17 00:00:00 2001
From: wkc <978997012@qq.com>
Date: Wed, 4 Mar 2026 10:55:31 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E5=AE=9E=E7=8E=B0callLsfxPlatform?=
 =?UTF-8?q?=E6=96=B9=E6=B3=95=E8=B0=83=E7=94=A8=E6=B5=81=E6=B0=B4=E5=88=86?=
 =?UTF-8?q?=E6=9E=90=E5=B9=B3=E5=8F=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/CcdiProjectServiceImpl.java  | 39 +++++++++++++++++++
 1 file changed, 39 insertions(+)

diff --git a/ccdi-project/src/main/java/com/ruoyi/ccdi/project/service/impl/CcdiProjectServiceImpl.java b/ccdi-project/src/main/java/com/ruoyi/ccdi/project/service/impl/CcdiProjectServiceImpl.java
index a6e0bb5..20f2e31 100644
--- a/ccdi-project/src/main/java/com/ruoyi/ccdi/project/service/impl/CcdiProjectServiceImpl.java
+++ b/ccdi-project/src/main/java/com/ruoyi/ccdi/project/service/impl/CcdiProjectServiceImpl.java
@@ -126,4 +126,43 @@ public class CcdiProjectServiceImpl implements ICcdiProjectService {
 
         return vo;
     }
+
+    /**
+     * 调用流水分析平台获取projectId
+     *
+     * @param projectName 项目名称
+     * @return 流水分析平台项目ID
+     * @throws ServiceException 调用失败或响应无效时抛出
+     */
+    private Integer callLsfxPlatform(String projectName) {
+        // 构建请求参数
+        GetTokenRequest request = new GetTokenRequest();
+        request.setProjectNo("902000_" + System.currentTimeMillis());
+        request.setEntityName(projectName);
+        request.setUserId("902001");
+        request.setUserName("902001");
+        request.setRole("VIEWER");
+        request.setOrgCode("902000");
+        request.setAnalysisType("-1");
+        request.setDepartmentCode("902000");
+
+        // 调用流水分析平台（异常处理和日志已在 LsfxAnalysisClient 中完成）
+        GetTokenResponse response = lsfxAnalysisClient.getToken(request);
+
+        // 业务层校验：确保响应有效
+        if (response == null || response.getData() == null) {
+            throw new ServiceException("流水分析平台响应数据为空");
+        }
+
+        if (response.getData().getProjectId() == null) {
+            throw new ServiceException("流水分析平台返回的projectId为空");
+        }
+
+        // 校验返回码
+        if (!"200".equals(response.getCode())) {
+            throw new ServiceException("流水分析平台返回错误: " + response.getMessage());
+        }
+
+        return response.getData().getProjectId();
+    }
 }