Compare commits
3 Commits
ce768e005c
...
5b0a85b882
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
5b0a85b882 | ||
|
|
66ecb33906 | ||
|
|
8051171b82 |
@ -1 +1 @@
|
|||||||
Subproject commit 2ed918f8dc2c40f679726fff1d71aea6603362ae
|
Subproject commit 05c64c7c04909ce504f79c092b104a6b40de1338
|
||||||
@ -1,4 +1,5 @@
|
|||||||
using Microsoft.Extensions.Configuration;
|
using Microsoft.Extensions.Configuration;
|
||||||
|
using static Volo.Abp.Identity.Settings.IdentitySettingNames;
|
||||||
|
|
||||||
namespace JiShe.IoT;
|
namespace JiShe.IoT;
|
||||||
|
|
||||||
@ -8,6 +9,7 @@ public class Program
|
|||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
|
//string text = Convert.ToBase64String(Encoding.UTF8.GetBytes("admin:admin123"));
|
||||||
Log.Information("JiShe.IoT.HttpApi.Host.");
|
Log.Information("JiShe.IoT.HttpApi.Host.");
|
||||||
var builder = WebApplication.CreateBuilder(args);
|
var builder = WebApplication.CreateBuilder(args);
|
||||||
builder.Host
|
builder.Host
|
||||||
|
|||||||
@ -32,8 +32,8 @@
|
|||||||
"TaskThreadCount": -1
|
"TaskThreadCount": -1
|
||||||
},
|
},
|
||||||
"Pulsar": {
|
"Pulsar": {
|
||||||
"ServiceUrl": "pulsar://47.110.60.222:9093",
|
"ServiceUrl": "pulsar://47.110.53.196:9093",
|
||||||
"WebUrl": "http://47.110.60.222:9094",
|
"WebUrl": "http://47.110.53.196:9094",
|
||||||
"UserName": "admin",
|
"UserName": "admin",
|
||||||
"TenantName": "1YMVZZkAkRArjxSD8457",
|
"TenantName": "1YMVZZkAkRArjxSD8457",
|
||||||
"Namespace": "OneNET",
|
"Namespace": "OneNET",
|
||||||
|
|||||||
@ -40,41 +40,41 @@ namespace JiShe.IoT.Data
|
|||||||
|
|
||||||
Logger.LogInformation("Started database migrations...");
|
Logger.LogInformation("Started database migrations...");
|
||||||
|
|
||||||
//await MigrateDatabaseSchemaAsync();
|
await MigrateDatabaseSchemaAsync();
|
||||||
//await SeedDataAsync();
|
await SeedDataAsync();
|
||||||
await InitIoTDBTable();
|
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>();
|
var migratedDatabaseSchemas = new HashSet<string>();
|
||||||
//foreach (var tenant in tenants)
|
foreach (var tenant in tenants)
|
||||||
//{
|
{
|
||||||
// using (_currentTenant.Change(tenant.Id))
|
using (_currentTenant.Change(tenant.Id))
|
||||||
// {
|
{
|
||||||
// if (tenant.ConnectionStrings.Any())
|
if (tenant.ConnectionStrings.Any())
|
||||||
// {
|
{
|
||||||
// var tenantConnectionStrings = tenant.ConnectionStrings
|
var tenantConnectionStrings = tenant.ConnectionStrings
|
||||||
// .Select(x => x.Value)
|
.Select(x => x.Value)
|
||||||
// .ToList();
|
.ToList();
|
||||||
|
|
||||||
// if (!migratedDatabaseSchemas.IsSupersetOf(tenantConnectionStrings))
|
if (!migratedDatabaseSchemas.IsSupersetOf(tenantConnectionStrings))
|
||||||
// {
|
{
|
||||||
// await MigrateDatabaseSchemaAsync(tenant);
|
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("Successfully completed all database migrations.");
|
||||||
//Logger.LogInformation("You can safely end this process...");
|
Logger.LogInformation("You can safely end this process...");
|
||||||
}
|
}
|
||||||
|
|
||||||
private async Task MigrateDatabaseSchemaAsync(Tenant tenant = null)
|
private async Task MigrateDatabaseSchemaAsync(Tenant tenant = null)
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user