diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java index 1a34d81..7b4a461 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java @@ -44,7 +44,7 @@ public class CorpusFailJob { } catch (Exception e) { log.error("processMessageByTask 定时任务补偿处理消息异常",e.getMessage()); - throw new RuntimeException(e); + } return ResultMsg.ok(); } diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/AiAnalysisErrorsServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/AiAnalysisErrorsServiceImpl.java index d99bd6b..531f9fe 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/AiAnalysisErrorsServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/AiAnalysisErrorsServiceImpl.java @@ -32,12 +32,7 @@ public class AiAnalysisErrorsServiceImpl extends ServiceImpl queryAnalysisErrorList(String businessType) { //捞取异常表中属于社区的异常数据 - List aiAnalysisErrors = aiAnalysisErrorsMapper.selectList(new LambdaQueryWrapper() - .eq(AiAnalysisErrors::getAiAnalysisRequestType, businessType) - .eq(AiAnalysisErrors::getAiAnalysisErrorHandlingStatus, "0") - .eq(AiAnalysisErrors::getIsDeleted, 0) - .lt(AiAnalysisErrors::getRetryCount, 4)); - return aiAnalysisErrors; + return null; } } diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java index b189e81..0d26cba 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java @@ -154,8 +154,9 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl ltoMap = new HashMap(); - ltoMap.put("aiAnalysisRequestId", execDifyFlow.getString("aiAnalysisRequestId")); + ltoMap.put("aiAnalysisRequestId", aiAnalysisRequestId); ltoMap.put("analysisScene", "2"); // ltoMap.put("unionId", aicorpusTelephone.getSourceId()); ltoMap.put("recordId", aicorpusTelephone.getSourceId()); @@ -180,7 +181,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl