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:
lxu75
2025-03-06 19:07:22 +08:00
parent ca4cfb3b8c
commit d36ded1b3b
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/MessageProcessJob.java
View File

@@ -17,13 +17,13 @@ public class MessageProcessJob {
/**
* 邀约消息推送
*/
@XxlJob("processMessageByTask")
@XxlJob("communityMessageByTask")
public ResultMsg processMessageByTask() {
try {
log.info("processMessageByTask 开始执行定时任务补偿处理消息");
log.info("communityMessageByTask 开始执行定时任务补偿处理消息");
mqMessageRecordService.processMessageByTask();
} catch (Exception e) {
log.error("processMessageByTask 定时任务补偿处理消息异常",e.getMessage());
log.error("communityMessageByTask 定时任务补偿处理消息异常",e.getMessage());
throw new RuntimeException(e);
}
return ResultMsg.ok();

2
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CommunityMessageConsumer.java
View File

@@ -20,7 +20,7 @@ public class CommunityMessageConsumer implements RocketMQListener<MessageExt>{
@Override
public void onMessage(MessageExt messageExt) {
log.info("Received message: " + messageExt);
log.info("Received 社区舆情分析 message: " + messageExt);
mqMessageRecordService.processMessageByMQ(new String(messageExt.getBody()));
}
}