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));
     }