admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

重试次数用配置控制

Browse Source
This commit is contained in:
lxu75
2025-05-07 19:00:06 +08:00
parent 6d81f16588
commit 99e7bbcc41
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
View File

@@ -84,6 +84,9 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
@Value("${rocketmq.producer.topic}") @Value("${rocketmq.producer.topic}")
private String topic; private String topic;
@Value("${community.maxRetryCount}")
private int maxRetryCount;
@Autowired @Autowired
private Executor getAsyncExecutor; private Executor getAsyncExecutor;
@@ -612,7 +615,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
List<AiAnalysisErrors> aiAnalysisErrors = aiAnalysisErrorsMapper.selectList(new LambdaQueryWrapper<AiAnalysisErrors>() List<AiAnalysisErrors> aiAnalysisErrors = aiAnalysisErrorsMapper.selectList(new LambdaQueryWrapper<AiAnalysisErrors>()
.eq(AiAnalysisErrors::getAiAnalysisRequestType, BusinessTypeEnum.COMMUNITYTARGET.getCode()) .eq(AiAnalysisErrors::getAiAnalysisRequestType, BusinessTypeEnum.COMMUNITYTARGET.getCode())
.eq(AiAnalysisErrors::getAiAnalysisErrorHandlingStatus, "0") .eq(AiAnalysisErrors::getAiAnalysisErrorHandlingStatus, "0")
.lt(AiAnalysisErrors::getRetryCount, 4)); .lt(AiAnalysisErrors::getRetryCount, maxRetryCount));
if (aiAnalysisErrors != null && aiAnalysisErrors.size() > 0) { if (aiAnalysisErrors != null && aiAnalysisErrors.size() > 0) {
//根据ai_analysis_request_id获取AiAnalysisRequestLogs表中的对应的dify_request字段 //根据ai_analysis_request_id获取AiAnalysisRequestLogs表中的对应的dify_request字段
for (AiAnalysisErrors aiAnalysisError : aiAnalysisErrors) { for (AiAnalysisErrors aiAnalysisError : aiAnalysisErrors) {