From 36331c994ac8a77ea1fa593fb4d7b1b5630771d2 Mon Sep 17 00:00:00 2001
From: xueqingkun <xueqingkun@126.com>
Date: Wed, 11 Dec 2024 16:16:54 +0800
Subject: [PATCH 1/3] =?UTF-8?q?1.=20=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../police/service/ModelCaseService.java           |  2 +-
 .../police/service/impl/ModelCaseServiceImpl.java  | 14 ++++++++++----
 2 files changed, 11 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/supervision/police/service/ModelCaseService.java b/src/main/java/com/supervision/police/service/ModelCaseService.java
index 1109945..ec05238 100644
--- a/src/main/java/com/supervision/police/service/ModelCaseService.java
+++ b/src/main/java/com/supervision/police/service/ModelCaseService.java
@@ -50,7 +50,7 @@ public interface ModelCaseService extends IService<ModelCase> {
     IPage<IndexDetail> getIndexDetail(IndexResultQuery query, Integer page, Integer size);
 
 
-    void initCaseKnowledgeBase(String caseId);
+    boolean initCaseKnowledgeBase(String caseId);
 
 
     /**
diff --git a/src/main/java/com/supervision/police/service/impl/ModelCaseServiceImpl.java b/src/main/java/com/supervision/police/service/impl/ModelCaseServiceImpl.java
index 0e340c1..6a795b3 100644
--- a/src/main/java/com/supervision/police/service/impl/ModelCaseServiceImpl.java
+++ b/src/main/java/com/supervision/police/service/impl/ModelCaseServiceImpl.java
@@ -381,7 +381,7 @@ public class ModelCaseServiceImpl extends ServiceImpl<ModelCaseMapper, ModelCase
     }
 
     @Override
-    public void initCaseKnowledgeBase(String caseId) {
+    public boolean initCaseKnowledgeBase(String caseId) {
         ModelCase modelCase = this.getById(caseId);
         if (StrUtil.isEmpty(modelCase.getKnowledgeBaseId())){
             log.info("案件：{} 尚未创建知识库，即将创建知识库库...",modelCase.getCaseName());
@@ -389,7 +389,7 @@ public class ModelCaseServiceImpl extends ServiceImpl<ModelCaseMapper, ModelCase
                     StrUtil.join("_", modelCase.getCaseName(), modelCase.getCaseNo()), modelCase.getCaseDetail());
             if (StrUtil.isEmpty(knowledgeBaseId)){
                 log.error("案件：{} 创建知识库失败...",modelCase.getCaseName());
-                return;
+                return false;
             }
             modelCase.setKnowledgeBaseId(knowledgeBaseId);
             modelCaseMapper.updateById(modelCase);
@@ -400,12 +400,13 @@ public class ModelCaseServiceImpl extends ServiceImpl<ModelCaseMapper, ModelCase
 
         if (null == modelCase.getCaseAnalysisSuccessTime()){
             log.info("案件：{} 尚未完成案件分析，不进行笔录上传...",modelCase.getCaseName());
-            return;
+            return true;
         }
         log.info("案件：{} 开始上传笔录到知识库...",modelCase.getCaseName());
         difyApiUtil.syncCaseFileToDifyKnowledgeBase(modelCase,this.listCaseFileIds(caseId));
         log.info("案件：{} 上传笔录到知识库成功...",modelCase.getCaseName());
 
+        return true;
     }
 
     @Override
@@ -421,7 +422,12 @@ public class ModelCaseServiceImpl extends ServiceImpl<ModelCaseMapper, ModelCase
             try {
                 log.info("开始迁移案件：{} 笔录到知识库,当前总体进度:{}...",modelCase.getCaseName(),NumberUtil.formatPercent((success + fail)/(allModelCase.size()*1.0), 2));
                 timer.start(modelCase.getId());
-                initCaseKnowledgeBase(modelCase.getId());
+                boolean ok = initCaseKnowledgeBase(modelCase.getId());
+                if (ok){
+                    success++;
+                }else {
+                    fail++;
+                }
                 log.info("案件：{} 迁移笔录到知识库成功，耗时：{}秒...",modelCase.getCaseName(),timer.intervalSecond(modelCase.getId()));
                 success++;
             } catch (Exception e) {

From 7cbf8d79e3b2d9eed101024f4eaed20f0a35e129 Mon Sep 17 00:00:00 2001
From: xueqingkun <xueqingkun@126.com>
Date: Wed, 11 Dec 2024 16:39:37 +0800
Subject: [PATCH 2/3] =?UTF-8?q?1.=20=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../police/service/impl/ModelCaseServiceImpl.java         | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/supervision/police/service/impl/ModelCaseServiceImpl.java b/src/main/java/com/supervision/police/service/impl/ModelCaseServiceImpl.java
index 6a795b3..da7d8ce 100644
--- a/src/main/java/com/supervision/police/service/impl/ModelCaseServiceImpl.java
+++ b/src/main/java/com/supervision/police/service/impl/ModelCaseServiceImpl.java
@@ -385,8 +385,9 @@ public class ModelCaseServiceImpl extends ServiceImpl<ModelCaseMapper, ModelCase
         ModelCase modelCase = this.getById(caseId);
         if (StrUtil.isEmpty(modelCase.getKnowledgeBaseId())){
             log.info("案件：{} 尚未创建知识库，即将创建知识库库...",modelCase.getCaseName());
+            // 防止名称超长，在这里统一采用案件id 作为知识库名称
             String knowledgeBaseId = difyApiUtil.createDataset(
-                    StrUtil.join("_", modelCase.getCaseName(), modelCase.getCaseNo()), modelCase.getCaseDetail());
+                    StrUtil.join("_", "case", modelCase.getId()), modelCase.getCaseDetail());
             if (StrUtil.isEmpty(knowledgeBaseId)){
                 log.error("案件：{} 创建知识库失败...",modelCase.getCaseName());
                 return false;
@@ -425,18 +426,17 @@ public class ModelCaseServiceImpl extends ServiceImpl<ModelCaseMapper, ModelCase
                 boolean ok = initCaseKnowledgeBase(modelCase.getId());
                 if (ok){
                     success++;
+                    log.info("案件：{} 迁移笔录到知识库成功，耗时：{}秒...",modelCase.getCaseName(),timer.intervalSecond(modelCase.getId()));
                 }else {
                     fail++;
                 }
-                log.info("案件：{} 迁移笔录到知识库成功，耗时：{}秒...",modelCase.getCaseName(),timer.intervalSecond(modelCase.getId()));
-                success++;
             } catch (Exception e) {
                 log.error("案件：{} 迁移笔录到知识库失败..",modelCase.getCaseName(),e);
                 fail++;
             }
         }
 
-        log.info("===========>>>>>迁移笔录到知识库完成,成功个数:{},失败个数：{},总耗时:{}秒...<<<<<===========",success,allModelCase.size()-success,timer.intervalSecond());
+        log.info("===========>>>>>迁移笔录到知识库完成,成功个数:{},失败个数：{},总耗时:{}秒...<<<<<===========",success,fail,timer.intervalSecond());
     }
 
     @Override

From 0e413f709b8327b68baa9fe3b84a4fbbf08fd20a Mon Sep 17 00:00:00 2001
From: xueqingkun <xueqingkun@126.com>
Date: Wed, 11 Dec 2024 16:51:46 +0800
Subject: [PATCH 3/3] =?UTF-8?q?1.=20=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../police/service/impl/ModelCaseServiceImpl.java          | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/supervision/police/service/impl/ModelCaseServiceImpl.java b/src/main/java/com/supervision/police/service/impl/ModelCaseServiceImpl.java
index da7d8ce..1ca519c 100644
--- a/src/main/java/com/supervision/police/service/impl/ModelCaseServiceImpl.java
+++ b/src/main/java/com/supervision/police/service/impl/ModelCaseServiceImpl.java
@@ -386,8 +386,13 @@ public class ModelCaseServiceImpl extends ServiceImpl<ModelCaseMapper, ModelCase
         if (StrUtil.isEmpty(modelCase.getKnowledgeBaseId())){
             log.info("案件：{} 尚未创建知识库，即将创建知识库库...",modelCase.getCaseName());
             // 防止名称超长，在这里统一采用案件id 作为知识库名称
+            String caseDetail = modelCase.getCaseDetail();
+            if (StrUtil.length(caseDetail) > 400){
+                caseDetail = StrUtil.sub(caseDetail,0,400);
+                log.info("案件：{} 描述内容太长，已截取前400个字符",modelCase.getCaseName());
+            }
             String knowledgeBaseId = difyApiUtil.createDataset(
-                    StrUtil.join("_", "case", modelCase.getId()), modelCase.getCaseDetail());
+                    StrUtil.join("_", "case", modelCase.getId()), caseDetail);
             if (StrUtil.isEmpty(knowledgeBaseId)){
                 log.error("案件：{} 创建知识库失败...",modelCase.getCaseName());
                 return false;