From d78b5a2c4fa691df7471f7ec1a52b6d38d96bedb Mon Sep 17 00:00:00 2001 From: dengjunjie <dengjunjie@hnkhzn.com> Date: 星期一, 13 一月 2025 23:51:15 +0800 Subject: [PATCH] Merge branch 'master' of http://115.159.85.185:8098/r/MeiRuiAn/HuaiAn --- 代码管理/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/HostedService/WarehouseHostedService.cs | 46 ++++++++++++++++++++++++++++++---------------- 1 files changed, 30 insertions(+), 16 deletions(-) diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/HostedService/WarehouseHostedService.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/HostedService/WarehouseHostedService.cs" index 390d476..bfebe8b 100644 --- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/HostedService/WarehouseHostedService.cs" +++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/HostedService/WarehouseHostedService.cs" @@ -21,30 +21,44 @@ public Task StartAsync(CancellationToken cancellationToken) { - string connStr = AppSettings.GetValue("WMSConnectionStrings"); - if (string.IsNullOrEmpty(connStr)) + try { - throw new Exception("WMS杩炴帴瀛楃涓查敊璇�"); + string connStr = AppSettings.GetValue("WMSConnectionStrings"); + if (string.IsNullOrEmpty(connStr)) + { + throw new Exception("WMS杩炴帴瀛楃涓查敊璇�"); + } + SqlSugarClient sugarClient = new(new ConnectionConfig() + { + ConnectionString = connStr, + IsAutoCloseConnection = true, + DbType = DbType.SqlServer + }); + + List<Dt_Warehouse> warehouses = sugarClient.Queryable<Dt_Warehouse>().ToList(); + + _dbContext.Db.Deleteable<Dt_Warehouse>().ExecuteCommand(); + + _dbContext.Db.Insertable(warehouses).ExecuteCommand(); + + List<Dt_ApiInfo> apiInfos = _dbContext.Db.Queryable<Dt_ApiInfo>().ToList(); + + List<Dt_WarehouseDevice> warehouseDevices = _dbContext.Db.Queryable<Dt_WarehouseDevice>().ToList(); + + _cacheService.AddOrUpdate(nameof(Dt_WarehouseDevice), warehouseDevices); + + _cacheService.AddOrUpdate(nameof(apiInfos), apiInfos); } - SqlSugarClient sugarClient = new(new ConnectionConfig() + catch (Exception ex) { - ConnectionString = connStr, - IsAutoCloseConnection = true, - DbType = DbType.SqlServer - }); - - List<Dt_Warehouse> warehouses = sugarClient.Queryable<Dt_Warehouse>().ToList(); - - _dbContext.Db.Deleteable<Dt_Warehouse>().ExecuteCommand(); - - _dbContext.Db.Insertable(warehouses).ExecuteCommand(); - + Console.WriteLine(ex.ToString()); + } return Task.CompletedTask; } public Task StopAsync(CancellationToken cancellationToken) { - throw new NotImplementedException(); + return Task.CompletedTask; } } } -- Gitblit v1.9.3