From a045f470e6e085724fb68bd188eaf63dee8bdfdb Mon Sep 17 00:00:00 2001 From: "liu.zixi" Date: Tue, 2 Dec 2025 11:48:55 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E5=A2=9E=E5=8A=A0=E6=89=B9=E5=A4=84?= =?UTF-8?q?=E7=90=86=EF=BC=8C=E5=A4=84=E7=90=86=E5=85=83=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E5=BC=82=E5=B8=B8=E7=9A=84=E6=97=A7=E6=96=87=E6=A1=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/xboe/module/boecase/entity/CaseDocumentLog.java | 8 ++++++++ .../boecase/service/impl/CaseKnowledgeServiceImpl.java | 1 + .../java/com/xboe/module/boecase/task/CaseUploadTask.java | 1 + 3 files changed, 10 insertions(+) diff --git a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/entity/CaseDocumentLog.java b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/entity/CaseDocumentLog.java index bbe9ba83..2040e6de 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/entity/CaseDocumentLog.java +++ b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/entity/CaseDocumentLog.java @@ -93,4 +93,12 @@ public class CaseDocumentLog extends BaseEntity { */ @Column(name = "execute_duration") private Long executeDuration; + + /** + * 元数据处理状态 + * 0-未处理 + * 1-已处理 + */ + @Column(name = "metadata_status") + private Integer metadataStatus; } diff --git a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CaseKnowledgeServiceImpl.java b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CaseKnowledgeServiceImpl.java index 597aba93..0ea1f611 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CaseKnowledgeServiceImpl.java +++ b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CaseKnowledgeServiceImpl.java @@ -1362,6 +1362,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { caseLog.setRunStatus(CaseDocumentLogRunStatusEnum.COMPLETED.getCode()); caseLog.setOptStatus(CaseDocumentLogOptStatusEnum.SUCCESS.getCode()); caseLog.setCaseStatus(CaseDocumentLogCaseStatusEnum.SUCCESS.getCode()); + caseLog.setMetadataStatus(1); needUpdate = true; // log.info("文档向量化成功，更新状态，taskId: {}, caseId: {}", caseLog.getTaskId(), caseLog.getCaseId()); } else if ("failed".equals(fileStatus)) { diff --git a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/task/CaseUploadTask.java b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/task/CaseUploadTask.java index 974a9d4e..a69faf03 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/task/CaseUploadTask.java +++ b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/task/CaseUploadTask.java @@ -206,6 +206,7 @@ public class CaseUploadTask { queryBuilder.addFilter(FieldFilters.eq("deleted", false)); queryBuilder.addFilter(FieldFilters.eq("requestUrl", CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME)); queryBuilder.addFilter(FieldFilters.eq("caseStatus", CaseDocumentLogCaseStatusEnum.SUCCESS.getCode())); + queryBuilder.addFilter(FieldFilters.eq("metadataStatus", 0)); if (lastProcessedId != null && !lastProcessedId.isEmpty()) { queryBuilder.addFilter(FieldFilters.gt("id", lastProcessedId)); }