From 56d1a6a5093cfca9235a2d7423d06d515cb260da Mon Sep 17 00:00:00 2001 From: "liu.zixi" Date: Wed, 12 Nov 2025 21:43:53 +0800 Subject: [PATCH] =?UTF-8?q?=E9=80=BB=E8=BE=91=E4=BF=AE=E6=AD=A3=EF=BC=9A?= =?UTF-8?q?=E5=B7=B2=E7=BB=8F=E4=B8=8A=E4=BC=A0=E6=88=90=E5=8A=9F=E8=BF=87?= =?UTF-8?q?=E7=9A=84=EF=BC=8C=E6=89=8D=E4=B8=8D=E8=BF=9B=E8=A1=8C=E8=BF=87?= =?UTF-8?q?=E6=BB=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/xboe/module/boecase/task/CaseUploadTask.java | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) 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 2aabf74b..e8d18120 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 @@ -1,6 +1,10 @@ package com.xboe.module.boecase.task; +import com.xboe.constants.CaseAiConstants; +import com.xboe.enums.CaseDocumentLogCaseStatusEnum; +import com.xboe.enums.CaseDocumentLogOptStatusEnum; import com.xboe.enums.CaseDocumentLogOptTypeEnum; +import com.xboe.enums.CaseDocumentLogRunStatusEnum; import com.xboe.module.boecase.async.CaseAiDocumentAsyncHandler; import com.xboe.module.boecase.dao.CaseDocumentLogDao; import com.xboe.module.boecase.dao.CasesDao; @@ -8,6 +12,7 @@ import com.xboe.module.boecase.entity.CaseDocumentLog; import com.xboe.module.boecase.entity.Cases; import com.xxl.job.core.handler.annotation.XxlJob; import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Component; @@ -16,6 +21,7 @@ import javax.annotation.Resource; import java.time.LocalDateTime; import java.util.ArrayList; import java.util.List; +import java.util.Objects; /** * 旧案例上传 @@ -72,7 +78,11 @@ public class CaseUploadTask { for (Cases cases : casesToProcess) { boolean exists = false; for (CaseDocumentLog log : existingLogs) { - if (cases.getId().equals(log.getCaseId())) { + if (cases.getId().equals(log.getCaseId()) + && StringUtils.equals(log.getRequestUrl(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME) + && Objects.equals(log.getRunStatus(), CaseDocumentLogRunStatusEnum.COMPLETED.getCode()) + && Objects.equals(log.getOptStatus(), CaseDocumentLogOptStatusEnum.SUCCESS.getCode()) + && Objects.equals(log.getRunStatus(), CaseDocumentLogCaseStatusEnum.SUCCESS.getCode())) { exists = true; break; }