From e8c64195a275b261e2245c9138d6b307e0d6078d Mon Sep 17 00:00:00 2001 From: "DESKTOP-DDTUS3E\\yaxin" Date: Sun, 29 Sep 2024 16:50:59 +0800 Subject: [PATCH] =?UTF-8?q?=E8=BF=9B=E5=BA=A6=E5=8F=AA=E7=BB=9F=E8=AE=A1?= =?UTF-8?q?=E5=88=86=E7=B1=BB=E7=BA=A7=E5=88=AB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/ExtractTripleInfoServiceImpl.java | 20 +++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) 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); +// } }; }