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

fix(content):优化vlog上传消息消费逻辑

Browse Source 
- 移除无用的MinIO工具类导入
- 移除无用的全局常量和服务异常导入
- 修改日志级别从debug到error并添加具体数据标识-保留核心业务逻辑和必要工具类引用
This commit is contained in:
huk 2025-10-13 16:44:46 +08:00
parent 7db0e97a45
commit 7995e5c2cd
2 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ruoyi-admin/src/main/resources/application.yml
View File

@ -42,12 +42,14 @@ logging:
level: level:
org.dromara: @logging.level@ org.dromara: @logging.level@
com.wzj.soopin: @logging.level@ com.wzj.soopin: @logging.level@
org.apache.http.wire: @logging.level@
org.springframework: @logging.level@ org.springframework: @logging.level@
org.mybatis.spring: @logging.level@ org.mybatis.spring: @logging.level@
com.baomidou: @logging.level@ com.baomidou: @logging.level@
org.apache.fury: @logging.level@ org.apache.fury: @logging.level@
org.redisson: @logging.level@ org.redisson: @logging.level@
com.zaxxer.hikari.pool: @logging.level@ com.zaxxer.hikari.pool: @logging.level@
software.amazon.awssdk.transfer: @logging.level@
com.baomidou.mybatisplus.extension.plugins.inner.TenantLineInnerInterceptor: @logging.level@ com.baomidou.mybatisplus.extension.plugins.inner.TenantLineInnerInterceptor: @logging.level@
config: classpath:logback-plus.xml config: classpath:logback-plus.xml

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

@ -3,17 +3,13 @@ package com.wzj.soopin.content.consumer;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import com.wzj.soopin.content.domain.po.Vlog; import com.wzj.soopin.content.domain.po.Vlog;
import com.wzj.soopin.content.service.VlogService; import com.wzj.soopin.content.service.VlogService;
import com.wzj.soopin.content.utils.MinIOUtils;
import com.wzj.soopin.content.utils.QcCloud; import com.wzj.soopin.content.utils.QcCloud;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.common.message.MessageExt; import org.apache.rocketmq.common.message.MessageExt;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener; import org.apache.rocketmq.spring.core.RocketMQListener;
import org.dromara.common.core.constant.GlobalConstants;
import org.dromara.common.core.exception.ServiceException; import org.dromara.common.core.exception.ServiceException;
import org.dromara.common.core.service.OssService;
import org.dromara.common.core.utils.SpringUtils;
import org.dromara.common.json.utils.JsonUtils; import org.dromara.common.json.utils.JsonUtils;
import org.dromara.common.mq.config.RocketMQConfig; import org.dromara.common.mq.config.RocketMQConfig;
import org.dromara.common.mq.domain.MQMessage; import org.dromara.common.mq.domain.MQMessage;
@ -87,7 +83,7 @@ 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)) {
log.debug("视频数据不存在"); log.error("视频数据:{}不存在", mqMessage.getData());
return true; return true;
} }
String fileId = vlog.getFileId(); String fileId = vlog.getFileId();