From 7db0e97a45fe9f6d21504f5f23d81f9c1b0c6ee4 Mon Sep 17 00:00:00 2001 From: wangqx Date: Mon, 13 Oct 2025 10:22:55 +0800 Subject: [PATCH] =?UTF-8?q?[fix]=E4=BF=AE=E6=94=B9=E8=A7=86=E9=A2=91?= =?UTF-8?q?=E7=9A=84=E6=B6=88=E8=B4=B9=E8=80=85=EF=BC=8C=E5=A2=9E=E5=8A=A0?= =?UTF-8?q?=E9=94=99=E8=AF=AF=E6=B6=88=E6=81=AF=E7=9A=84=E5=88=A4=E6=96=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../content/consumer/VlogUploadMessageConsumer.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/ruoyi-modules/ruoyi-content/src/main/java/com/wzj/soopin/content/consumer/VlogUploadMessageConsumer.java b/ruoyi-modules/ruoyi-content/src/main/java/com/wzj/soopin/content/consumer/VlogUploadMessageConsumer.java index 7e1b4b3e2..7ef58def5 100644 --- a/ruoyi-modules/ruoyi-content/src/main/java/com/wzj/soopin/content/consumer/VlogUploadMessageConsumer.java +++ b/ruoyi-modules/ruoyi-content/src/main/java/com/wzj/soopin/content/consumer/VlogUploadMessageConsumer.java @@ -50,6 +50,8 @@ public class VlogUploadMessageConsumer implements RocketMQListener { String message = new String(messageExt.getBody()); log.info("接收到RocketMQ消息: {}, msgId: {}", message, messageExt.getMsgId()); + + try { MQMessage mqMessage = JsonUtils.parseObject(message, MQMessage.class); @@ -85,7 +87,8 @@ public class VlogUploadMessageConsumer implements RocketMQListener { Vlog vlog = vlogService.getById((String) mqMessage.getData()); //获取文件内容 if (ObjectUtil.isNull(vlog)) { - return false; + log.debug("视频数据不存在"); + return true; } String fileId = vlog.getFileId(); //检查该文件是否为oss文件，如果不是说明已经上传过了 @@ -93,6 +96,9 @@ public class VlogUploadMessageConsumer implements RocketMQListener { return true; } //从oss下载文件 + if(fileId==null){ + return false; + } SysOssVo sysOss = ossService.getById(Long.parseLong(fileId)); if (ObjectUtil.isNull(sysOss)) {