|
|
|
@ -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
|
|
|
|
|