From 6c337303f1048d5563dec4169249a0870ecaf84e Mon Sep 17 00:00:00 2001 From: lxu75 Date: Fri, 7 Mar 2025 16:45:19 +0800 Subject: [PATCH 1/2] =?UTF-8?q?=E8=88=86=E6=83=85=E8=87=AA=E5=8A=A8?= =?UTF-8?q?=E5=8C=96=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 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 Date: Mon, 10 Mar 2025 15:26:59 +0800 Subject: [PATCH 2/2] =?UTF-8?q?fix=20=E8=88=86=E6=83=85=E8=87=AA=E5=8A=A8?= =?UTF-8?q?=E5=8C=96=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../volvo/ai/analytic/center/dto/req/DifyImageWorkFlow.java | 2 +- .../ai/analytic/center/service/impl/DiFyServiceImpl.java | 2 +- .../center/service/impl/MqMessageRecordServiceImpl.java | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/DifyImageWorkFlow.java b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/DifyImageWorkFlow.java index 240b05d..1e8abfb 100644 --- a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/DifyImageWorkFlow.java +++ b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/DifyImageWorkFlow.java @@ -9,5 +9,5 @@ public class DifyImageWorkFlow { private String type = "image"; - private String url; + private String imageUrl; } diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java index a09185e..1eef397 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java @@ -24,7 +24,7 @@ public class DiFyServiceImpl implements DiFyService{ map.put("inputs",diFyReq.getInputs()); map.put("response_mode","blocking"); map.put("user",diFyReq.getUser()); - + log.info("请求DiFy入参:{}",diFyReq.getInputs()); JSONObject difyResult = diFyFeign.runWorkflows("Bearer "+diFyReq.getFlowId(),map); log.info("请求DiFy响应结果:{}",difyResult.toJSONString()); JSONObject data = difyResult.getJSONObject("data"); 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 06dff77..802ac92 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 @@ -104,12 +104,12 @@ public class MqMessageRecordServiceImpl extends ServiceImpl