From 6c337303f1048d5563dec4169249a0870ecaf84e Mon Sep 17 00:00:00 2001
From: lxu75 <liang.xu.4@volvocars.com>
Date: Fri, 7 Mar 2025 16:45:19 +0800
Subject: [PATCH] =?UTF-8?q?=E8=88=86=E6=83=85=E8=87=AA=E5=8A=A8=E5=8C=96?=
 =?UTF-8?q?=E4=BB=A3=E7=A0=81=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../analytic/center/controller/TestController.java   | 12 ++++++++++++
 .../service/impl/MqMessageRecordServiceImpl.java     |  2 +-
 2 files changed, 13 insertions(+), 1 deletion(-)

diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java
index 4fa4448..8e90664 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java
@@ -14,6 +14,7 @@ import com.volvo.common.core.util.ResultMsg;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.core.RocketMQTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -41,6 +42,9 @@ public class TestController {
     @Autowired
     private MqMessageRecordService mqMessageRecordService;
 
+    @Autowired
+    private RocketMQTemplate rocketMQTemplate;
+
 /*
     @PostMapping("/runWorkflows2")
     @ApiOperation(value = "测试Dify")
@@ -88,5 +92,13 @@ public class TestController {
         mqMessageRecordService.processMessageByTask();
         return ResultMsg.ok("");
     }
+
+
+    @PostMapping("/mockMq")
+    @ApiOperation(value = "补偿处理消息")
+    public ResultMsg<Object> mockMq( String message) {
+        rocketMQTemplate.syncSend("COMMUNITY_POST_TO_AI_TOPIC", JSON.toJSONString(message));
+        return ResultMsg.ok("ok");
+    }
 }
 
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 1f09a48..06dff77 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
@@ -149,7 +149,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
                 difyCommunityTargetResult.setTargetId(targetId);
                 difyCommunityTargetResult.setCommentAnswer(commentAnswer);
                 //返回结果推送到社区的MQ
-                rocketMQTemplate.syncSend("", JSON.toJSONString(difyCommunityTargetResult));
+                rocketMQTemplate.syncSend(topic, JSON.toJSONString(difyCommunityTargetResult));
                 log.info("舆情分析发送回调MQ完成: {}", JSON.toJSONString(difyCommunityTargetResult));
                 //异步更新请求日志表的difyResponse字段
                 syncUpdateDiFyResponse(difResult, aiAnalysisRequestId);