admin/JiShe.IOT.Admin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

还原数据初始化

Browse Source
This commit is contained in:
ChenYi 2025-08-20 11:26:52 +08:00
parent 66ecb33906
commit 5b0a85b882
1 changed files with 26 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
src/JiShe.IoT.Domain/Data/IoTDbMigrationService.cs
View File

@ -40,41 +40,41 @@ namespace JiShe.IoT.Data
Logger.LogInformation("Started database migrations...");
//await MigrateDatabaseSchemaAsync();
//await SeedDataAsync();
await MigrateDatabaseSchemaAsync();
await SeedDataAsync();
await InitIoTDBTable();
//Logger.LogInformation($"Successfully completed host database migrations.");
Logger.LogInformation($"Successfully completed host database migrations.");
//var tenants = await _tenantRepository.GetListAsync(includeDetails: true);
var tenants = await _tenantRepository.GetListAsync(includeDetails: true);
//var migratedDatabaseSchemas = new HashSet<string>();
//foreach (var tenant in tenants)
//{
// using (_currentTenant.Change(tenant.Id))
// {
// if (tenant.ConnectionStrings.Any())
// {
// var tenantConnectionStrings = tenant.ConnectionStrings
// .Select(x => x.Value)
// .ToList();
var migratedDatabaseSchemas = new HashSet<string>();
foreach (var tenant in tenants)
{
using (_currentTenant.Change(tenant.Id))
{
if (tenant.ConnectionStrings.Any())
{
var tenantConnectionStrings = tenant.ConnectionStrings
.Select(x => x.Value)
.ToList();
// if (!migratedDatabaseSchemas.IsSupersetOf(tenantConnectionStrings))
// {
// await MigrateDatabaseSchemaAsync(tenant);
if (!migratedDatabaseSchemas.IsSupersetOf(tenantConnectionStrings))
{
await MigrateDatabaseSchemaAsync(tenant);
// migratedDatabaseSchemas.AddIfNotContains(tenantConnectionStrings);
// }
// }
migratedDatabaseSchemas.AddIfNotContains(tenantConnectionStrings);
}
}
// await SeedDataAsync(tenant);
// }
await SeedDataAsync(tenant);
}
// Logger.LogInformation($"Successfully completed {tenant.Name} tenant database migrations.");
//}
Logger.LogInformation($"Successfully completed {tenant.Name} tenant database migrations.");
}
//Logger.LogInformation("Successfully completed all database migrations.");
//Logger.LogInformation("You can safely end this process...");
Logger.LogInformation("Successfully completed all database migrations.");
Logger.LogInformation("You can safely end this process...");
}
private async Task MigrateDatabaseSchemaAsync(Tenant tenant = null)