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())