abu/wzj-boot
3
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[fix]修改视频的消费者，增加错误消息的判断

Browse Source
This commit is contained in:
wangqx 2025-10-13 10:22:55 +08:00
parent 8cff58e360
commit 7db0e97a45
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
ruoyi-modules/ruoyi-content/src/main/java/com/wzj/soopin/content/consumer/VlogUploadMessageConsumer.java
View File

@ -50,6 +50,8 @@ public class VlogUploadMessageConsumer implements RocketMQListener<MessageExt> {
String message = new String(messageExt.getBody()); String message = new String(messageExt.getBody());
log.info("接收到RocketMQ消息: {}, msgId: {}", message, messageExt.getMsgId()); log.info("接收到RocketMQ消息: {}, msgId: {}", message, messageExt.getMsgId());
try { try {
MQMessage mqMessage = JsonUtils.parseObject(message, MQMessage.class); MQMessage mqMessage = JsonUtils.parseObject(message, MQMessage.class);
@ -85,7 +87,8 @@ public class VlogUploadMessageConsumer implements RocketMQListener<MessageExt> {
Vlog vlog = vlogService.getById((String) mqMessage.getData()); Vlog vlog = vlogService.getById((String) mqMessage.getData());
//获取文件内容 //获取文件内容
if (ObjectUtil.isNull(vlog)) { if (ObjectUtil.isNull(vlog)) {
return false; log.debug("视频数据不存在");
return true;
} }
String fileId = vlog.getFileId(); String fileId = vlog.getFileId();
//检查该文件是否为oss文件，如果不是说明已经上传过了 //检查该文件是否为oss文件，如果不是说明已经上传过了
@ -93,6 +96,9 @@ public class VlogUploadMessageConsumer implements RocketMQListener<MessageExt> {
return true; return true;
} }
//从oss下载文件 //从oss下载文件
if(fileId==null){
return false;
}
SysOssVo sysOss = ossService.getById(Long.parseLong(fileId)); SysOssVo sysOss = ossService.getById(Long.parseLong(fileId));
if (ObjectUtil.isNull(sysOss)) { if (ObjectUtil.isNull(sysOss)) {