进度只统计分类级别

src/main/java/com/supervision/police/service/impl/ExtractTripleInfoServiceImpl.java

@@ -73,10 +73,10 @@ public class ExtractTripleInfoServiceImpl implements ExtractTripleInfoService {
 
         List<TripleExtractTask> 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<NoteRecordSplit> 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);
+//            }
         };
 
     }