feat: 优化

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());
+        }
     }
 }