diff --git a/src/main/java/com/supervision/police/service/impl/ExtractTripleInfoServiceImpl.java b/src/main/java/com/supervision/police/service/impl/ExtractTripleInfoServiceImpl.java index 997de46..87641fd 100644 --- a/src/main/java/com/supervision/police/service/impl/ExtractTripleInfoServiceImpl.java +++ b/src/main/java/com/supervision/police/service/impl/ExtractTripleInfoServiceImpl.java @@ -73,10 +73,10 @@ public class ExtractTripleInfoServiceImpl implements ExtractTripleInfoService { List taskList = notePromptList.stream() .filter(prompt -> StrUtil.isNotBlank(prompt.getPrompt())) - .peek(prompt -> { - caseTaskRecordService.taskCountIncrement(caseId, recordSplit.getNoteRecordId()); - log.info("extractTripleInfo:三元组抽取任务数量加1,笔录片段id:{}", prompt.getId()); - }) +// .peek(prompt -> { +// caseTaskRecordService.taskCountIncrement(caseId, recordSplit.getNoteRecordId()); +// log.info("extractTripleInfo:三元组抽取任务数量加1,笔录片段id:{}", prompt.getId()); +// }) .map(prompt -> new TripleExtractTask(chatClient, prompt, recordSplit, postExtractTriple(), mainActor)).toList(); if (CollUtil.isEmpty(taskList)) { @@ -116,12 +116,12 @@ public class ExtractTripleInfoServiceImpl implements ExtractTripleInfoService { private Consumer postExtractTriple() { return (recordSplit) -> { - try { - caseTaskRecordService.finishCountIncrement(recordSplit.getCaseId(), recordSplit.getNoteRecordId()); - log.info("postExtractTriple:抽取任务完成数量加1,笔录片段id:{}", recordSplit.getId()); - } catch (Exception e) { - log.error("postExtractTriple:笔录片段:{} 抽取任务执行后更新任务状态失败...", recordSplit.getId(), e); - } +// try { +// caseTaskRecordService.finishCountIncrement(recordSplit.getCaseId(), recordSplit.getNoteRecordId()); +// log.info("postExtractTriple:抽取任务完成数量加1,笔录片段id:{}", recordSplit.getId()); +// } catch (Exception e) { +// log.error("postExtractTriple:笔录片段:{} 抽取任务执行后更新任务状态失败...", recordSplit.getId(), e); +// } }; }