admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改点踩参数

Browse Source
This commit is contained in:
zren25
2025-03-14 13:33:18 +08:00
parent f1a19d2289
commit 2127e3e2d5
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpushIsLikeConsumer.java
View File

@@ -23,14 +23,15 @@ public class CorpushIsLikeConsumer implements RocketMQListener<MessageExt>{
private TmCorpusReportService tmCorpusReportService; private TmCorpusReportService tmCorpusReportService;
@Override @Override
public void onMessage(MessageExt messageExt) { public void onMessage(MessageExt messageExt) {
log.info("CorpushIsLikeConsumer message: " + messageExt);
String message = new String(messageExt.getBody()); String message = new String(messageExt.getBody());
log.info("CorpushIsLikeConsumer message: " + message);
try { try {
// 保存报告 // 保存报告
JSONObject execDifyFlow = JSONObject.parseObject(message); JSONObject execDifyFlow = JSONObject.parseObject(message);
Integer like = execDifyFlow.getInteger("isLike"); Integer like = execDifyFlow.getInteger("isLike");
tmCorpusReportService.saveTmCorpusReport(TmCorpusReport.builder() tmCorpusReportService.saveTmCorpusReport(TmCorpusReport.builder()
.aiAnalysisRequestId(execDifyFlow.getString("aiAnalysisRequestId")) .aiAnalysisRequestId(execDifyFlow.getString("analysisRecordId"))
.isLike(like) .isLike(like)
.updateBy("LTO") .updateBy("LTO")
.updateTime(new Date()) .updateTime(new Date())