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

---
 .../project/service/impl/CcdiProjectServiceImpl.java  | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

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 20f2e31..807a358 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
@@ -16,6 +16,7 @@ import com.ruoyi.lsfx.domain.response.GetTokenResponse;
 import jakarta.annotation.Resource;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 /**
  * 项目Service实现类
@@ -32,20 +33,28 @@ public class CcdiProjectServiceImpl implements ICcdiProjectService {
     private LsfxAnalysisClient lsfxAnalysisClient;
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public CcdiProjectVO createProject(CcdiProjectSaveDTO dto) {
+        // 1. 调用流水分析平台获取projectId
+        Integer lsfxProjectId = callLsfxPlatform(dto.getProjectName());
+
+        // 2. 创建项目实体
         CcdiProject project = new CcdiProject();
         BeanUtils.copyProperties(dto, project);
 
-        // 设置默认值
+        // 3. 设置默认值和流水分析平台ID
         project.setStatus("0"); // 进行中
         project.setIsArchived(0); // 未归档
         project.setTargetCount(0);
         project.setHighRiskCount(0);
         project.setMediumRiskCount(0);
         project.setLowRiskCount(0);
+        project.setLsfxProjectId(lsfxProjectId);  // 设置流水分析平台ID
 
+        // 4. 保存到数据库
         projectMapper.insert(project);
 
+        // 5. 返回VO
         CcdiProjectVO vo = new CcdiProjectVO();
         BeanUtils.copyProperties(project, vo);
         return vo;