From f03dc678cf65592490cb588be433f636ce711382 Mon Sep 17 00:00:00 2001
From: sion123 <450702724@qq.com>
Date: Wed, 4 Mar 2026 02:26:53 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mq/consumer/MemberUserCreateConsumer.java      | 14 +++++++++++++-
 1 file changed, 13 insertions(+), 1 deletion(-)

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