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-03-13 17:20:08 +08:00
parent adc3b42cb2
commit 4cf0751938
1 changed files with 28 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -543,31 +543,41 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
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) {
AiAnalysisRequestLogs aiAnalysisRequestLogs = aiAnalysisRequestLogsMapper.selectOne(new LambdaQueryWrapper<AiAnalysisRequestLogs>() try {
.eq(AiAnalysisRequestLogs::getAiAnalysisRequestId, aiAnalysisError.getAiAnalysisRequestId())); AiAnalysisRequestLogs aiAnalysisRequestLogs = aiAnalysisRequestLogsMapper.selectOne(new LambdaQueryWrapper<AiAnalysisRequestLogs>()
if (aiAnalysisRequestLogs != null) { .eq(AiAnalysisRequestLogs::getAiAnalysisRequestId, aiAnalysisError.getAiAnalysisRequestId()));
//获取dify_request字段 if (aiAnalysisRequestLogs != null) {
String difyRequest = aiAnalysisRequestLogs.getDifyRequest(); //获取dify_request字段
if (StringUtils.isNotEmpty(difyRequest)) { String difyRequest = aiAnalysisRequestLogs.getDifyRequest();
//调用dify接口 if (StringUtils.isNotEmpty(difyRequest)) {
DiFyReq diFyReq = new DiFyReq(); //调用dify接口
diFyReq.setUser(user); DiFyReq diFyReq = new DiFyReq();
diFyReq.setFlowId(flowId); diFyReq.setUser(user);
diFyReq.setInputs(JSONObject.parseObject(difyRequest)); diFyReq.setFlowId(flowId);
JSONObject difResult = (JSONObject) diFyService.getDiFyObject(diFyReq); diFyReq.setInputs(JSONObject.parseObject(difyRequest));
this.dueCommunityDifyResponse(difResult); JSONObject difResult = (JSONObject) diFyService.getDiFyObject(diFyReq);
this.dueCommunityDifyResponse(difResult);
//根据ai_analysis_request_id更新ai_analysis_errors表中的retry_count字段+1,更新status字段为1
aiAnalysisErrorsMapper.update(new AiAnalysisErrors(), new LambdaUpdateWrapper<AiAnalysisErrors>()
.eq(AiAnalysisErrors::getAiAnalysisRequestId, aiAnalysisError.getAiAnalysisRequestId())
.set(AiAnalysisErrors::getRetryCount, aiAnalysisError.getRetryCount() + 1)
.set(AiAnalysisErrors::getAiAnalysisErrorHandlingStatus, "1"));
}else{
aiAnalysisErrorsMapper.update(new AiAnalysisErrors(), new LambdaUpdateWrapper<AiAnalysisErrors>()
.eq(AiAnalysisErrors::getAiAnalysisRequestId, aiAnalysisError.getAiAnalysisRequestId())
.set(AiAnalysisErrors::getAiAnalysisErrorHandlingStatus, "2"));
}
} }
//根据ai_analysis_request_id更新ai_analysis_errors表中的retry_count字段+1,更新status字段为1 } catch (Exception e) {
log.error("补偿社区消息,AIID:{},异常:{}",aiAnalysisError.getAiAnalysisRequestId(), e);
aiAnalysisErrorsMapper.update(new AiAnalysisErrors(), new LambdaUpdateWrapper<AiAnalysisErrors>() aiAnalysisErrorsMapper.update(new AiAnalysisErrors(), new LambdaUpdateWrapper<AiAnalysisErrors>()
.eq(AiAnalysisErrors::getAiAnalysisRequestId, aiAnalysisError.getAiAnalysisRequestId()) .eq(AiAnalysisErrors::getAiAnalysisRequestId, aiAnalysisError.getAiAnalysisRequestId())
.set(AiAnalysisErrors::getRetryCount, aiAnalysisError.getRetryCount() + 1) .set(AiAnalysisErrors::getRetryCount, aiAnalysisError.getRetryCount() + 1));
.set(AiAnalysisErrors::getAiAnalysisErrorHandlingStatus, "1"));
} }
} }
} }
} catch (Exception e) { } catch (Exception e) {
throw new RuntimeException(e); log.error("处理社区异常消息异常:{}", e);
} }
} }