From 558ffc4bcaf7aa5c683e7c9ce01e971feb9e4d95 Mon Sep 17 00:00:00 2001
From: dengzedong <dengzedong@email>
Date: 星期一, 14 十月 2024 14:11:48 +0800
Subject: [PATCH] 模型打包租户隔离 备份文件租户隔离

---
 iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/influxdb/common/config/InfluxDBInstance.java |    9 ++++++---
 1 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/influxdb/common/config/InfluxDBInstance.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/influxdb/common/config/InfluxDBInstance.java
index fa23641..a46e8af 100644
--- a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/influxdb/common/config/InfluxDBInstance.java
+++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/influxdb/common/config/InfluxDBInstance.java
@@ -1,5 +1,6 @@
 package com.iailab.module.data.influxdb.common.config;
 
+import com.iailab.framework.tenant.core.context.TenantContextHolder;
 import com.influxdb.client.InfluxDBClient;
 import com.influxdb.client.InfluxDBClientFactory;
 import org.slf4j.Logger;
@@ -18,14 +19,13 @@
     @Value("${influx-db.org}")
     public String org;
 
-    @Value("${influx-db.bucket}")
-    public String bucket;
-
     @Value("${influx-db.token}")
     public String token;
 
     @Value("${influx-db.url}")
     public String url;
+
+    private final static String BUCKET_NAME = "tenant_";
 
     private Logger logger = LoggerFactory.getLogger(getClass());
 
@@ -43,5 +43,8 @@
         return client;
     }
 
+    public String getBucket() {
+        return BUCKET_NAME + TenantContextHolder.getRequiredTenantId();
+    }
 
 }

--
Gitblit v1.9.3