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));
         }