From fc75e7af8f4d757d68f4e7873e06f1baeefcde05 Mon Sep 17 00:00:00 2001
From: lxu75 <liang.xu.4@volvocars.com>
Date: Tue, 11 Mar 2025 15:19:49 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E5=AD=97=E6=AE=B5=E8=BF=94?=
 =?UTF-8?q?=E5=9B=9E?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../analytic/center/dto/resp/DifyCommunityTargetResult.java | 4 ++++
 .../ai/analytic/center/entity/AiAnalysisRequestLogs.java    | 3 ---
 .../center/service/impl/MqMessageRecordServiceImpl.java     | 6 +++++-
 3 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/resp/DifyCommunityTargetResult.java b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/resp/DifyCommunityTargetResult.java
index ceb0aad..0906cf1 100644
--- a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/resp/DifyCommunityTargetResult.java
+++ b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/resp/DifyCommunityTargetResult.java
@@ -10,4 +10,8 @@ public class DifyCommunityTargetResult {
     private String commentAnswer;
 
     private String targetType;
+
+    private String keyWords;
+
+    private String targetTag;
 }
diff --git a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/entity/AiAnalysisRequestLogs.java b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/entity/AiAnalysisRequestLogs.java
index 0475193..eb42f09 100644
--- a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/entity/AiAnalysisRequestLogs.java
+++ b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/entity/AiAnalysisRequestLogs.java
@@ -31,9 +31,6 @@ public class AiAnalysisRequestLogs {
     @TableField("dify_request")
     private String difyRequest; // JSON 字符串
 
-    @TableField("business_response")
-    private String businessResponse; // JSON 字符串
-
     @TableField("dify_response")
     private String difyResponse;
 
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
index 63798ee..ba2b2ba 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
@@ -146,10 +146,14 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
                 String targetId = difResultJSONObject.getString("targetId");
                 String targetType = difResultJSONObject.getString("targetType");
                 String commentAnswer = difResultJSONObject.getString("commentAnswer");
+                String keyWords = difResultJSONObject.getString("keyWords");
+                String targetTag = difResultJSONObject.getString("targetTag");
 
                 difyCommunityTargetResult.setTargetType(targetType);
                 difyCommunityTargetResult.setTargetId(targetId);
                 difyCommunityTargetResult.setCommentAnswer(commentAnswer);
+                difyCommunityTargetResult.setTargetTag(targetTag);
+                difyCommunityTargetResult.setKeyWords(keyWords);
                 //返回结果推送到社区的MQ
                 rocketMQTemplate.syncSend(topic, JSON.toJSONString(difyCommunityTargetResult));
                 log.info("舆情分析发送回调MQ完成: {}", JSON.toJSONString(difyCommunityTargetResult));
@@ -178,7 +182,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
     @Async
     protected void syncUpdateDiFyResponse(JSONObject difResult, String aiAnalysisRequestId) {
         aiAnalysisRequestLogsMapper.update(new AiAnalysisRequestLogs(),
-                new UpdateWrapper<AiAnalysisRequestLogs>().set("business_response", difResult)
+                new UpdateWrapper<AiAnalysisRequestLogs>().set("dify_response", difResult)
                         .eq("ai_analysis_request_id", aiAnalysisRequestId));
     }