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

log表记录调整

Browse Source
This commit is contained in:
lxu75
2025-03-11 16:46:12 +08:00
parent fc75e7af8f
commit 0e3de9db24
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -123,7 +123,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
.orElse(Collections.emptyList()).stream() .orElse(Collections.emptyList()).stream()
.filter(contentNode -> NodeTypeEnum.TEXT.getCode().equals(contentNode.getNodeType())) .filter(contentNode -> NodeTypeEnum.TEXT.getCode().equals(contentNode.getNodeType()))
.map(CommunityTargetDTO.ContentNode::getNodeContent) .map(CommunityTargetDTO.ContentNode::getNodeContent)
.collect(Collectors.joining("")); .collect(Collectors.joining(" "));
//构建舆情分析请求对象 //构建舆情分析请求对象
DifyCommunityTargetDTO difyCommunityTargetDTO = new DifyCommunityTargetDTO(); DifyCommunityTargetDTO difyCommunityTargetDTO = new DifyCommunityTargetDTO();
@@ -161,7 +161,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
syncUpdateDiFyResponse(difResult, aiAnalysisRequestId); syncUpdateDiFyResponse(difResult, aiAnalysisRequestId);
} }
} catch (Exception e) { } catch (Exception e) {
log.error("请求DiFy异常:{}", e.getMessage()); log.error("舆情自动化异常:{}", e.getMessage());
//保存错误日志 //保存错误日志
aiAnalysisErrorsMapper.insert(AiAnalysisErrors.builder() aiAnalysisErrorsMapper.insert(AiAnalysisErrors.builder()
.aiAnalysisRequestId(aiAnalysisRequestId) .aiAnalysisRequestId(aiAnalysisRequestId)
@@ -182,7 +182,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
@Async @Async
protected void syncUpdateDiFyResponse(JSONObject difResult, String aiAnalysisRequestId) { protected void syncUpdateDiFyResponse(JSONObject difResult, String aiAnalysisRequestId) {
aiAnalysisRequestLogsMapper.update(new AiAnalysisRequestLogs(), aiAnalysisRequestLogsMapper.update(new AiAnalysisRequestLogs(),
new UpdateWrapper<AiAnalysisRequestLogs>().set("dify_response", difResult) new UpdateWrapper<AiAnalysisRequestLogs>().set("dify_response", difResult.toJSONString())
.eq("ai_analysis_request_id", aiAnalysisRequestId)); .eq("ai_analysis_request_id", aiAnalysisRequestId));
} }