hz/java-servers
1
0
Fork 0
mirror of https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git synced 2025-12-09 10:56:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: 增加批处理，处理元数据异常的旧文档

Browse Source
This commit is contained in:
liu.zixi
2025-12-02 11:48:55 +08:00
parent 92aaf2bed7
commit a045f470e6
3 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
servers/boe-server-all/src/main/java/com/xboe/module/boecase/entity/CaseDocumentLog.java
View File

@@ -93,4 +93,12 @@ public class CaseDocumentLog extends BaseEntity {
*/ */
@Column(name = "execute_duration") @Column(name = "execute_duration")
private Long executeDuration; private Long executeDuration;
/**
* 元数据处理状态
* 0-未处理
* 1-已处理
*/
@Column(name = "metadata_status")
private Integer metadataStatus;
} }

1
servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CaseKnowledgeServiceImpl.java
View File

@@ -1362,6 +1362,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
caseLog.setRunStatus(CaseDocumentLogRunStatusEnum.COMPLETED.getCode()); caseLog.setRunStatus(CaseDocumentLogRunStatusEnum.COMPLETED.getCode());
caseLog.setOptStatus(CaseDocumentLogOptStatusEnum.SUCCESS.getCode()); caseLog.setOptStatus(CaseDocumentLogOptStatusEnum.SUCCESS.getCode());
caseLog.setCaseStatus(CaseDocumentLogCaseStatusEnum.SUCCESS.getCode()); caseLog.setCaseStatus(CaseDocumentLogCaseStatusEnum.SUCCESS.getCode());
caseLog.setMetadataStatus(1);
needUpdate = true; needUpdate = true;
// log.info("文档向量化成功，更新状态，taskId: {}, caseId: {}", caseLog.getTaskId(), caseLog.getCaseId()); // log.info("文档向量化成功，更新状态，taskId: {}, caseId: {}", caseLog.getTaskId(), caseLog.getCaseId());
} else if ("failed".equals(fileStatus)) { } else if ("failed".equals(fileStatus)) {

1
servers/boe-server-all/src/main/java/com/xboe/module/boecase/task/CaseUploadTask.java
View File

@@ -206,6 +206,7 @@ public class CaseUploadTask {
queryBuilder.addFilter(FieldFilters.eq("deleted", false)); queryBuilder.addFilter(FieldFilters.eq("deleted", false));
queryBuilder.addFilter(FieldFilters.eq("requestUrl", CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME)); queryBuilder.addFilter(FieldFilters.eq("requestUrl", CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME));
queryBuilder.addFilter(FieldFilters.eq("caseStatus", CaseDocumentLogCaseStatusEnum.SUCCESS.getCode())); queryBuilder.addFilter(FieldFilters.eq("caseStatus", CaseDocumentLogCaseStatusEnum.SUCCESS.getCode()));
queryBuilder.addFilter(FieldFilters.eq("metadataStatus", 0));
if (lastProcessedId != null && !lastProcessedId.isEmpty()) { if (lastProcessedId != null && !lastProcessedId.isEmpty()) {
queryBuilder.addFilter(FieldFilters.gt("id", lastProcessedId)); queryBuilder.addFilter(FieldFilters.gt("id", lastProcessedId));
} }