diff --git a/src/BuildFlow.Host/appsettings.json b/src/BuildFlow.Host/appsettings.json index 66de9cd..d1e8c22 100644 --- a/src/BuildFlow.Host/appsettings.json +++ b/src/BuildFlow.Host/appsettings.json @@ -18,7 +18,10 @@ }, "AllowedHosts": "*", "ConnectionStrings": { - "Default": "Host=43.134.235.58;Port=15432;Username=rag;Password=REDACTED_PG_PASSWORD", + "Default": "Host=43.134.235.58;Port=15432;Database=rag;Username=rag;Password=REDACTED_PG_PASSWORD", + "File": "Host=43.134.235.58;Port=15432;Database=file_system;Username=rag;Password=REDACTED_PG_PASSWORD", + "Im": "Host=43.134.235.58;Port=15432;Database=im_system;Username=rag;Password=REDACTED_PG_PASSWORD", + "Workflow": "Host=43.134.235.58;Port=15432;Database=workflow;Username=rag;Password=REDACTED_PG_PASSWORD", "MongoDb": "mongodb://rag:CHANGE_ME@43.134.235.58:27017/im_system?authSource=admin", "Redis": "43.134.235.58:16379,password=REDACTED_REDIS_PASSWORD,abortConnect=false" }, diff --git a/src/modules/file/Infrastructure/FileInfrastructureModule.cs b/src/modules/file/Infrastructure/FileInfrastructureModule.cs index 1c855f9..77b7442 100644 --- a/src/modules/file/Infrastructure/FileInfrastructureModule.cs +++ b/src/modules/file/Infrastructure/FileInfrastructureModule.cs @@ -21,11 +21,9 @@ public class FileInfrastructureModule : AbpModule var services = context.Services; var config = services.GetConfiguration(); - // DbContext 挂载审计拦截器,统一从 Default 连接串派生(替换 Database 名) - var baseConn = config.GetConnectionString("Default")!; - var fsConn = $"{baseConn};Database=file_system"; + // DbContext 挂载审计拦截器;连接串由 Host appsettings 的 ConnectionStrings:File 提供 services.AddDbContext((sp, options) => - options.UseNpgsql(fsConn) + options.UseNpgsql(config.GetConnectionString("File")!) .AddInterceptors(sp.GetRequiredService())); // Scoped 生命周期:每个 HTTP 请求创建一个拦截器实例,确保 ICurrentUserContext 正确获取当前用户 diff --git a/src/modules/im/Infrastructure/IMInfrastructureModule.cs b/src/modules/im/Infrastructure/IMInfrastructureModule.cs index 16e3680..dd2f487 100644 --- a/src/modules/im/Infrastructure/IMInfrastructureModule.cs +++ b/src/modules/im/Infrastructure/IMInfrastructureModule.cs @@ -23,11 +23,9 @@ public class IMInfrastructureModule : AbpModule var services = context.Services; var config = services.GetConfiguration(); - // PostgreSQL:会话/参与者/群组/群成员。统一从 Default 连接串派生(替换 Database 名) - var baseConn = config.GetConnectionString("Default")!; - var imConn = $"{baseConn};Database=im_system"; + // PostgreSQL:会话/参与者/群组/群成员。连接串由 Host appsettings 的 ConnectionStrings:Im 提供 services.AddDbContext((sp, options) => - options.UseNpgsql(imConn) + options.UseNpgsql(config.GetConnectionString("Im")!) .AddInterceptors(sp.GetRequiredService())); services.AddScoped(); diff --git a/src/modules/rag/Infrastructure/RAGInfrastructureModule.cs b/src/modules/rag/Infrastructure/RAGInfrastructureModule.cs index cbcf539..7624d71 100644 --- a/src/modules/rag/Infrastructure/RAGInfrastructureModule.cs +++ b/src/modules/rag/Infrastructure/RAGInfrastructureModule.cs @@ -26,12 +26,9 @@ public class RAGInfrastructureModule : AbpModule var services = context.Services; var config = services.GetConfiguration(); - // DbContext 挂载审计拦截器,拦截器从 DI 容器解析 ICurrentUserContext - // 统一从 Default 连接串派生(替换 Database 名),改一处连接信息全模块生效 - var baseConn = config.GetConnectionString("Default")!; - var ragConn = $"{baseConn};Database=rag"; + // DbContext 挂载审计拦截器;连接串由 Host appsettings 的 ConnectionStrings:Default 提供 services.AddDbContext((sp, options) => - options.UseNpgsql(ragConn, o => o.UseVector()) + options.UseNpgsql(config.GetConnectionString("Default")!, o => o.UseVector()) .AddInterceptors(sp.GetRequiredService())); // Scoped 生命周期:每个 HTTP 请求创建一个拦截器实例,确保 ICurrentUserContext 正确获取当前用户 diff --git a/src/modules/workflow/Infrastructure/WorkflowInfrastructureModule.cs b/src/modules/workflow/Infrastructure/WorkflowInfrastructureModule.cs index 39c8953..d2bdb74 100644 --- a/src/modules/workflow/Infrastructure/WorkflowInfrastructureModule.cs +++ b/src/modules/workflow/Infrastructure/WorkflowInfrastructureModule.cs @@ -19,12 +19,10 @@ public class WorkflowInfrastructureModule : AbpModule var services = context.Services; var config = services.GetConfiguration(); - // 统一从 Default 连接串派生(替换 Database 名) - var baseConn = config.GetConnectionString("Default")!; - var wfConn = $"{baseConn};Database=workflow"; + // 连接串由 Host appsettings 的 ConnectionStrings:Workflow 提供 services.AddDbContext((sp, options) => { - options.UseNpgsql(wfConn, npgsql => + options.UseNpgsql(config.GetConnectionString("Workflow")!, npgsql => { npgsql.MigrationsAssembly(typeof(WorkflowDbContext).Assembly.FullName); });