diff --git a/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/member/mq/consumer/MemberUserCreateConsumer.java b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/member/mq/consumer/MemberUserCreateConsumer.java index 44252eabf2..021a3585d1 100644 --- a/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/member/mq/consumer/MemberUserCreateConsumer.java +++ b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/member/mq/consumer/MemberUserCreateConsumer.java @@ -1,6 +1,7 @@ package cn.iocoder.yudao.module.tik.member.mq.consumer; import cn.iocoder.yudao.module.member.api.message.user.MemberUserCreateMessage; +import cn.iocoder.yudao.module.tik.file.service.TikOssInitService; import cn.iocoder.yudao.module.tik.muye.memberuserprofile.service.MemberUserProfileService; import lombok.extern.slf4j.Slf4j; import org.springframework.context.event.EventListener; @@ -11,7 +12,7 @@ import jakarta.annotation.Resource; /** * 会员用户创建事件监听器 * - * 功能:用户注册后自动初始化档案和配额 + * 功能:用户注册后自动初始化档案、配额和OSS目录 * 触发时机:用户注册时(MemberUserServiceImpl.createUser()) * * @author 芋道源码 @@ -23,6 +24,9 @@ public class MemberUserCreateConsumer { @Resource private MemberUserProfileService memberUserProfileService; + @Resource + private TikOssInitService tikOssInitService; + /** * 监听用户创建事件(注册时触发) * 同步执行,确保登录后立即可用 @@ -38,6 +42,14 @@ public class MemberUserCreateConsumer { // 初始化会员档案(包含存储配额) memberUserProfileService.createIfAbsent(userId); log.info("[onMessage][用户({})档案初始化成功]", userId); + + // 初始化OSS目录 + try { + tikOssInitService.initOssDirectory(userId); + log.info("[onMessage][用户({})OSS目录初始化成功]", userId); + } catch (Exception e) { + log.warn("[onMessage][用户({})OSS目录初始化失败,后续使用时会自动重试: {}]", userId, e.getMessage()); + } } }