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-11 15:19:49 +08:00
parent 4522e25d57
commit fc75e7af8f
3 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/resp/DifyCommunityTargetResult.java
View File

@@ -10,4 +10,8 @@ public class DifyCommunityTargetResult {
private String commentAnswer; private String commentAnswer;
private String targetType; private String targetType;
private String keyWords;
private String targetTag;
} }

3
ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/entity/AiAnalysisRequestLogs.java
View File

@@ -31,9 +31,6 @@ public class AiAnalysisRequestLogs {
@TableField("dify_request") @TableField("dify_request")
private String difyRequest; // JSON 字符串 private String difyRequest; // JSON 字符串
@TableField("business_response")
private String businessResponse; // JSON 字符串
@TableField("dify_response") @TableField("dify_response")
private String difyResponse; private String difyResponse;

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

@@ -146,10 +146,14 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
String targetId = difResultJSONObject.getString("targetId"); String targetId = difResultJSONObject.getString("targetId");
String targetType = difResultJSONObject.getString("targetType"); String targetType = difResultJSONObject.getString("targetType");
String commentAnswer = difResultJSONObject.getString("commentAnswer"); String commentAnswer = difResultJSONObject.getString("commentAnswer");
String keyWords = difResultJSONObject.getString("keyWords");
String targetTag = difResultJSONObject.getString("targetTag");
difyCommunityTargetResult.setTargetType(targetType); difyCommunityTargetResult.setTargetType(targetType);
difyCommunityTargetResult.setTargetId(targetId); difyCommunityTargetResult.setTargetId(targetId);
difyCommunityTargetResult.setCommentAnswer(commentAnswer); difyCommunityTargetResult.setCommentAnswer(commentAnswer);
difyCommunityTargetResult.setTargetTag(targetTag);
difyCommunityTargetResult.setKeyWords(keyWords);
//返回结果推送到社区的MQ //返回结果推送到社区的MQ
rocketMQTemplate.syncSend(topic, JSON.toJSONString(difyCommunityTargetResult)); rocketMQTemplate.syncSend(topic, JSON.toJSONString(difyCommunityTargetResult));
log.info("舆情分析发送回调MQ完成: {}", JSON.toJSONString(difyCommunityTargetResult)); log.info("舆情分析发送回调MQ完成: {}", JSON.toJSONString(difyCommunityTargetResult));
@@ -178,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("business_response", difResult) new UpdateWrapper<AiAnalysisRequestLogs>().set("dify_response", difResult)
.eq("ai_analysis_request_id", aiAnalysisRequestId)); .eq("ai_analysis_request_id", aiAnalysisRequestId));
} }