Compare commits

...

3 Commits

Author SHA1 Message Date
ChenYi
5b0a85b882 还原数据初始化 2025-08-20 11:26:52 +08:00
ChenYi
66ecb33906 更新 2025-08-20 11:26:09 +08:00
ChenYi
8051171b82 修复bug 2025-08-20 11:26:00 +08:00
4 changed files with 33 additions and 31 deletions

@ -1 +1 @@
Subproject commit 2ed918f8dc2c40f679726fff1d71aea6603362ae Subproject commit 05c64c7c04909ce504f79c092b104a6b40de1338

View File

@ -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

View File

@ -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",

View File

@ -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)