|
|
@ -388,12 +388,12 @@ public class ModelCaseServiceImpl extends ServiceImpl<ModelCaseMapper, ModelCase
|
|
|
|
String knowledgeBaseId = difyApiUtil.createDataset(
|
|
|
|
String knowledgeBaseId = difyApiUtil.createDataset(
|
|
|
|
StrUtil.join("_", modelCase.getCaseName(), modelCase.getCaseNo()), modelCase.getCaseDetail());
|
|
|
|
StrUtil.join("_", modelCase.getCaseName(), modelCase.getCaseNo()), modelCase.getCaseDetail());
|
|
|
|
if (StrUtil.isEmpty(knowledgeBaseId)){
|
|
|
|
if (StrUtil.isEmpty(knowledgeBaseId)){
|
|
|
|
log.error("案件:{} 创建支持库失败...",modelCase.getCaseName());
|
|
|
|
log.error("案件:{} 创建知识库失败...",modelCase.getCaseName());
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
modelCase.setKnowledgeBaseId(knowledgeBaseId);
|
|
|
|
modelCase.setKnowledgeBaseId(knowledgeBaseId);
|
|
|
|
modelCaseMapper.updateById(modelCase);
|
|
|
|
modelCaseMapper.updateById(modelCase);
|
|
|
|
log.info("案件:{} 创建支持库成功,知识库id为:{}",modelCase.getCaseName(),modelCase.getKnowledgeBaseId());
|
|
|
|
log.info("案件:{} 创建知识库成功,知识库id为:{}",modelCase.getCaseName(),modelCase.getKnowledgeBaseId());
|
|
|
|
}else {
|
|
|
|
}else {
|
|
|
|
log.info("案件:{} 已创建知识库,不进行创建...",modelCase.getCaseName());
|
|
|
|
log.info("案件:{} 已创建知识库,不进行创建...",modelCase.getCaseName());
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -404,7 +404,7 @@ public class ModelCaseServiceImpl extends ServiceImpl<ModelCaseMapper, ModelCase
|
|
|
|
}
|
|
|
|
}
|
|
|
|
log.info("案件:{} 开始上传笔录到支持库...",modelCase.getCaseName());
|
|
|
|
log.info("案件:{} 开始上传笔录到支持库...",modelCase.getCaseName());
|
|
|
|
difyApiUtil.uploadCaseFileToDifyKnowledgeBase(modelCase,this.listCaseFileIds(caseId));
|
|
|
|
difyApiUtil.uploadCaseFileToDifyKnowledgeBase(modelCase,this.listCaseFileIds(caseId));
|
|
|
|
log.info("案件:{} 上传笔录到支持库成功...",modelCase.getCaseName());
|
|
|
|
log.info("案件:{} 上传笔录到知识库成功...",modelCase.getCaseName());
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -414,23 +414,23 @@ public class ModelCaseServiceImpl extends ServiceImpl<ModelCaseMapper, ModelCase
|
|
|
|
int success = 0;
|
|
|
|
int success = 0;
|
|
|
|
int fail = 0;
|
|
|
|
int fail = 0;
|
|
|
|
List<ModelCase> allModelCase = this.list();
|
|
|
|
List<ModelCase> allModelCase = this.list();
|
|
|
|
log.info("===========>>>>>案件总数:{},开始迁移笔录到支持库...<<<<<===========",allModelCase.size());
|
|
|
|
log.info("===========>>>>>案件总数:{},开始迁移笔录到知识库...<<<<<===========",allModelCase.size());
|
|
|
|
TimeInterval timer = DateUtil.timer();
|
|
|
|
TimeInterval timer = DateUtil.timer();
|
|
|
|
timer.start();
|
|
|
|
timer.start();
|
|
|
|
for (ModelCase modelCase : allModelCase) {
|
|
|
|
for (ModelCase modelCase : allModelCase) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
log.info("开始迁移案件:{} 笔录到支持库,当前总体进度:{}...",modelCase.getCaseName(),NumberUtil.formatPercent((success + fail)/(allModelCase.size()*1.0), 2));
|
|
|
|
log.info("开始迁移案件:{} 笔录到知识库,当前总体进度:{}...",modelCase.getCaseName(),NumberUtil.formatPercent((success + fail)/(allModelCase.size()*1.0), 2));
|
|
|
|
timer.start(modelCase.getId());
|
|
|
|
timer.start(modelCase.getId());
|
|
|
|
initCaseKnowledgeBase(modelCase.getId());
|
|
|
|
initCaseKnowledgeBase(modelCase.getId());
|
|
|
|
log.info("案件:{} 迁移笔录到支持库成功,耗时:{}秒...",modelCase.getCaseName(),timer.intervalSecond(modelCase.getId()));
|
|
|
|
log.info("案件:{} 迁移笔录到知识库成功,耗时:{}秒...",modelCase.getCaseName(),timer.intervalSecond(modelCase.getId()));
|
|
|
|
success++;
|
|
|
|
success++;
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
log.error("案件:{} 迁移笔录到支持库失败..",modelCase.getCaseName(),e);
|
|
|
|
log.error("案件:{} 迁移笔录到知识库失败..",modelCase.getCaseName(),e);
|
|
|
|
fail++;
|
|
|
|
fail++;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
log.info("===========>>>>>迁移笔录到支持库完成,成功个数:{},失败个数:{},总耗时:{}秒...<<<<<===========",success,allModelCase.size()-success,timer.intervalSecond());
|
|
|
|
log.info("===========>>>>>迁移笔录到知识库完成,成功个数:{},失败个数:{},总耗时:{}秒...<<<<<===========",success,allModelCase.size()-success,timer.intervalSecond());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|