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-07-01 15:47:50 +08:00
parent 46bae0e9ed
commit 743af2a4d4
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
JiShe.ServicePro

@ -1 +1 @@
Subproject commit b558ed2c47d6d0279cc944c4ec8922a43bdd1e9d Subproject commit 4d8e8f01ec67375b2106691ae76dd9463e8f7b20

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

@ -1,4 +1,5 @@
using JiShe.ServicePro.ApacheIoTDB.Provider.ISessionPools; using JiShe.ServicePro.ApacheIoTDB.Provider.ISessionPools;
using JiShe.ServicePro.ApacheIoTDB.Provider.SessionPools;
namespace JiShe.IoT.Data namespace JiShe.IoT.Data
{ {
@ -10,14 +11,14 @@ namespace JiShe.IoT.Data
private readonly IEnumerable<IIoTDbSchemaMigrator> _dbSchemaMigrators; private readonly IEnumerable<IIoTDbSchemaMigrator> _dbSchemaMigrators;
private readonly ITenantRepository _tenantRepository; private readonly ITenantRepository _tenantRepository;
private readonly ICurrentTenant _currentTenant; private readonly ICurrentTenant _currentTenant;
private readonly IIoTDBSessionPoolProvider _ioTDBSessionPoolProvider; private readonly ITableSessionPoolProvider _ioTDBSessionPoolProvider;
public IoTDbMigrationService( public IoTDbMigrationService(
IDataSeeder dataSeeder, IDataSeeder dataSeeder,
IEnumerable<IIoTDbSchemaMigrator> dbSchemaMigrators, IEnumerable<IIoTDbSchemaMigrator> dbSchemaMigrators,
ITenantRepository tenantRepository, ITenantRepository tenantRepository,
ICurrentTenant currentTenant, ICurrentTenant currentTenant,
IIoTDBSessionPoolProvider ioTDBSessionPoolProvider) ITableSessionPoolProvider ioTDBSessionPoolProvider)
{ {
_dataSeeder = dataSeeder; _dataSeeder = dataSeeder;
_dbSchemaMigrators = dbSchemaMigrators; _dbSchemaMigrators = dbSchemaMigrators;
@ -94,7 +95,7 @@ namespace JiShe.IoT.Data
private async Task InitIoTDBTable() private async Task InitIoTDBTable()
{ {
//³õʼ»¯IoTDB±íÄ£ÐÍ //³õʼ»¯IoTDB±íÄ£ÐÍ
await _ioTDBSessionPoolProvider.GetSessionPool(true).InitTableSessionModelAsync(); await _ioTDBSessionPoolProvider.InitTableSessionModelAsync();
} }
private async Task SeedDataAsync(Tenant tenant = null) private async Task SeedDataAsync(Tenant tenant = null)