From cc22f4fe3877c13b771ffd5a42699dfeaaef5e30 Mon Sep 17 00:00:00 2001
From: yangyang01000846 <15195822163@163.com>
Date: Mon, 19 Jan 2026 15:59:05 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=EF=BC=9A=E7=A7=9F=E6=88=B7?=
 =?UTF-8?q?=E6=A1=B6=E7=94=9F=E6=88=90=E6=96=87=E4=BB=B6=E7=94=9F=E5=91=BD?=
 =?UTF-8?q?=E5=91=A8=E6=9C=9F=E8=A7=84=E5=88=99?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../sdm/data/service/minio/MinioService.java    | 17 +++++++++++++++--
 1 file changed, 15 insertions(+), 2 deletions(-)

diff --git a/data/src/main/java/com/sdm/data/service/minio/MinioService.java b/data/src/main/java/com/sdm/data/service/minio/MinioService.java
index 28f6867b..b27174e0 100644
--- a/data/src/main/java/com/sdm/data/service/minio/MinioService.java
+++ b/data/src/main/java/com/sdm/data/service/minio/MinioService.java
@@ -68,7 +68,18 @@ public class MinioService implements IMinioService {
         } catch (Exception e) {
             log.error("桶{}初始化失败", minioConfig.getSecretBusinessBucket(), e);
         }
-        createBucketLifecycle(minioConfig.getSpdmBucket(),minioConfig.getLifecycleConfig());
+        // 设置各个桶标签
+        try {
+            List<Bucket> buckets = minioClient.listBuckets();
+            for (Bucket bucket : buckets) {
+                if(!Objects.isNull(bucket)
+                        &&org.apache.commons.lang3.StringUtils.isNotBlank(bucket.name())) {
+                    createBucketLifecycle(bucket.name(),minioConfig.getLifecycleConfig());
+                }
+            }
+        }catch (Exception ex){
+            log.error("data启动初始化桶的生命周期规则失败：{}", ex.getMessage());
+        }
     }
 
 
@@ -110,7 +121,7 @@ public class MinioService implements IMinioService {
             if (!found) {
                 log.info("系统初始化：创建缺失的租户桶 -> {}", bucketName);
                 minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
-                // TODO: 如果需要，可以在这里设置生命周期策略 (Lifecycle Config)
+                createBucketLifecycle(bucketName,minioConfig.getLifecycleConfig());
             }
             existingBucketsCache.add(bucketName);
         } catch (Exception e) {
@@ -150,6 +161,7 @@ public class MinioService implements IMinioService {
                 if (!found) {
                     log.info("运行时检测到新租户桶不存在，正在创建: {}", bucketName);
                     minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
+                    createBucketLifecycle(bucketName,minioConfig.getLifecycleConfig());
                 }
                 existingBucketsCache.add(bucketName);
             } catch (Exception e) {
@@ -545,6 +557,7 @@ public class MinioService implements IMinioService {
             minioClient.makeBucket(MakeBucketArgs.builder()
                     .bucket(bucketName)
                     .build());
+            createBucketLifecycle(bucketName,minioConfig.getLifecycleConfig());
         }
     }