From 3d537706cc01c444ee6bbd3a5f0cc3d7a63c15a1 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Thu, 22 Jan 2026 16:06:19 +0800
Subject: [PATCH] feat(ai): 添加AI产品状态变更前的完整性验证

---
 src/main/java/cc/mrbird/febs/ai/service/impl/AiProductServiceImpl.java |   53 ++++++++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 48 insertions(+), 5 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/ai/service/impl/AiProductServiceImpl.java b/src/main/java/cc/mrbird/febs/ai/service/impl/AiProductServiceImpl.java
index 2a934fb..8d0fa7b 100644
--- a/src/main/java/cc/mrbird/febs/ai/service/impl/AiProductServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/ai/service/impl/AiProductServiceImpl.java
@@ -18,6 +18,7 @@
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.Date;
 import java.util.List;
@@ -79,11 +80,36 @@
     }
 
     @Override
+    @Transactional
     public FebsResponse changeState(String id, Integer type, Integer state) {
 
         AiProduct entity = this.getById(id);
         if(ObjectUtil.isNotNull(entity)){
             if(1 == type){
+                if (1 == state){
+                    List<AiProductPointLink> list = aiProductPointLinkService.selectListByQuery(
+                            Wrappers.lambdaQuery(AiProductPointLink.class)
+                                    .eq(AiProductPointLink::getProductId, id)
+                    );
+                    if(CollUtil.isEmpty(list)){
+                        return new FebsResponse().fail().message("请配置知识点");
+                    }
+                    List<AiProductRoleLink> list1 = aiProductRoleLinkService.selectListByQuery(
+                            Wrappers.lambdaQuery(AiProductRoleLink.class)
+                                    .eq(AiProductRoleLink::getProductId, id)
+                    );
+                    if(CollUtil.isEmpty(list1)){
+                        return new FebsResponse().fail().message("请配置AI陪练");
+                    }
+                    List<AiProductQuestionLink> list2 = aiProductQuestionLinkService.selectListByQuery(
+                            Wrappers.lambdaQuery(AiProductQuestionLink.class)
+                                    .eq(AiProductQuestionLink::getProductId, id)
+                    );
+                    if(CollUtil.isEmpty(list2)){
+                        return new FebsResponse().fail().message("请配置AI题目");
+                    }
+                }
+
                 aiProductMapper.update(null,
                         Wrappers.lambdaUpdate(AiProduct.class)
                                 .set(AiProduct::getState, state)
@@ -116,6 +142,7 @@
         entity.setTarget(dto.getTarget());
         entity.setDescription(dto.getDescription());
         entity.setQuestionCount(dto.getQuestionCount());
+        entity.setTalkCnt(dto.getTalkCnt());
         entity.setCreatedTime(new Date());
         this.save(entity);
         return new FebsResponse().success().message("操作成功");
@@ -138,6 +165,7 @@
                             .set(AiProduct::getTarget, dto.getTarget())
                             .set(AiProduct::getDescription, dto.getDescription())
                             .set(AiProduct::getQuestionCount, dto.getQuestionCount())
+                            .set(AiProduct::getTalkCnt, dto.getTalkCnt())
                             .set(AiProduct::getUpdatedTime, new Date())
                             .eq(AiProduct::getId, id)
             );
@@ -162,11 +190,12 @@
 
     @Override
     public List<AiProduct> selectList(String companyId) {
-        return aiProductMapper.selectList(
-                Wrappers.lambdaQuery(AiProduct.class)
-                        .eq(AiProduct::getCompanyId, companyId)
-                .ne(AiProduct::getState, 2)
-        );
+        LambdaQueryWrapper<AiProduct> query = Wrappers.lambdaQuery(AiProduct.class);
+        if (StrUtil.isNotEmpty(companyId)){
+            query.eq(AiProduct::getCompanyId, companyId);
+        }
+        query.ne(AiProduct::getState, 2);
+        return aiProductMapper.selectList(query);
     }
 
     @Override
@@ -254,4 +283,18 @@
         }
         return new FebsResponse().success().message("操作成功");
     }
+
+    @Override
+    public List<AiProduct> listByCategory(AiProduct dto) {
+        LambdaQueryWrapper<AiProduct> query = Wrappers.lambdaQuery(AiProduct.class);
+        if (StrUtil.isNotEmpty(dto.getProductCategoryId())){
+            query.eq(AiProduct::getProductCategoryId, dto.getProductCategoryId());
+        }
+        if (StrUtil.isNotEmpty(dto.getCompanyId())){
+            query.eq(AiProduct::getCompanyId, dto.getCompanyId());
+        }
+        query.ne(AiProduct::getState, 2);
+        query.orderByAsc(AiProduct::getSort);
+        return aiProductMapper.selectList(query);
+    }
 }

--
Gitblit v1.9.1