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 c14c8e1..0c2d186 100644 --- a/src/main/java/com/supervision/police/service/impl/ModelCaseServiceImpl.java +++ b/src/main/java/com/supervision/police/service/impl/ModelCaseServiceImpl.java @@ -398,6 +398,10 @@ public class ModelCaseServiceImpl extends ServiceImpl<ModelCaseMapper, ModelCase log.info("案件:{} 已创建知识库,不进行创建...",modelCase.getCaseName()); } + if (null == modelCase.getCaseAnalysisSuccessTime()){ + log.info("案件:{} 尚未完成案件分析,不进行笔录上传...",modelCase.getCaseName()); + return; + } log.info("案件:{} 开始上传笔录到支持库...",modelCase.getCaseName()); noteRecordService.uploadRecordFileToDifyKnowledgeBase(caseId); log.info("案件:{} 上传笔录到支持库成功...",modelCase.getCaseName()); @@ -409,8 +413,7 @@ public class ModelCaseServiceImpl extends ServiceImpl<ModelCaseMapper, ModelCase // 获取所有案件 int success = 0; int fail = 0; - // 只 同步 已经分析的案件 - List<ModelCase> allModelCase = this.lambdaQuery().isNotNull(ModelCase::getCaseAnalysisSuccessTime).list(); + List<ModelCase> allModelCase = this.list(); log.info("===========>>>>>案件总数:{},开始迁移笔录到支持库...<<<<<===========",allModelCase.size()); TimeInterval timer = DateUtil.timer(); timer.start();