From 2127e3e2d5f9bedde55dd8c719c3c2b739983257 Mon Sep 17 00:00:00 2001 From: zren25 Date: Fri, 14 Mar 2025 13:33:18 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E7=82=B9=E8=B8=A9=E5=8F=82?= =?UTF-8?q?=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../volvo/ai/analytic/center/mq/CorpushIsLikeConsumer.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpushIsLikeConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpushIsLikeConsumer.java index b48d512..348d441 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpushIsLikeConsumer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpushIsLikeConsumer.java @@ -23,14 +23,15 @@ public class CorpushIsLikeConsumer implements RocketMQListener{ private TmCorpusReportService tmCorpusReportService; @Override public void onMessage(MessageExt messageExt) { - log.info("CorpushIsLikeConsumer message: " + messageExt); + String message = new String(messageExt.getBody()); + log.info("CorpushIsLikeConsumer message: " + message); try { // 保存报告 JSONObject execDifyFlow = JSONObject.parseObject(message); Integer like = execDifyFlow.getInteger("isLike"); tmCorpusReportService.saveTmCorpusReport(TmCorpusReport.builder() - .aiAnalysisRequestId(execDifyFlow.getString("aiAnalysisRequestId")) + .aiAnalysisRequestId(execDifyFlow.getString("analysisRecordId")) .isLike(like) .updateBy("LTO") .updateTime(new Date())