diff --git a/Src/Dlhis.Middle/BackgroundServices/BalanceRecordUploadBackgroundService.cs b/Src/Dlhis.Middle/BackgroundServices/BalanceRecordUploadBackgroundService.cs index 470a15ce..db795431 100644 --- a/Src/Dlhis.Middle/BackgroundServices/BalanceRecordUploadBackgroundService.cs +++ b/Src/Dlhis.Middle/BackgroundServices/BalanceRecordUploadBackgroundService.cs @@ -48,7 +48,7 @@ public class BalanceRecordUploadBackgroundService : BackgroundService var balanceRecords = await db.Queryable() .Where(x => x.TenantId == factory) .Where(x => !x.IsSync).ToListAsync(stoppingToken); - + if (balanceRecords.Any()) { _logger.LogInformation("上传离线订单"); @@ -104,24 +104,12 @@ public class BalanceRecordUploadBackgroundService : BackgroundService try { - if (now is { Hour: 4, Minute: 1 } + if (now is { Hour: 5, Minute: 1 } && !_healthCheckService.GetIsOffline() && !await db.Queryable().Where(x => !x.IsSync).AnyAsync()) { await ds.InitAsync(factories); } - else if (now is { Hour: 15, Minute: 1 } - && !_healthCheckService.GetIsOffline() - && !await db.Queryable().Where(x => !x.IsSync).AnyAsync()) - { - await ds.InitAsync(factories); - } - else if (now is { Hour: 20, Minute: 1 } - && !_healthCheckService.GetIsOffline() - && !await db.Queryable().Where(x => !x.IsSync).AnyAsync()) - { - await ds.InitAsync(factories); - } } catch (Exception e) { diff --git a/Src/Dlhis.Middle/Program.cs b/Src/Dlhis.Middle/Program.cs index b07548a2..6bd8e0db 100644 --- a/Src/Dlhis.Middle/Program.cs +++ b/Src/Dlhis.Middle/Program.cs @@ -39,20 +39,20 @@ public class Startup : DefaultStartup { base.Configure(app, env); - var healthCheckService = app.ApplicationServices.GetService(); - if (healthCheckService.DoHealthCheckAsync().GetAwaiter().GetResult()) - { - using var scope = app.ApplicationServices.CreateScope(); - var db = scope.ServiceProvider.GetService(); - - db.Client.DbMaintenance.CreateDatabase(); - db.Client.CodeFirst.InitTables(); - db.Client.CodeFirst.InitTables(); - db.Client.CodeFirst.InitTables(); - - var factories = scope.ServiceProvider.GetService().GetFactories(); - var ds = scope.ServiceProvider.GetService(); - ds.InitAsync(factories).Wait(); - } + // var healthCheckService = app.ApplicationServices.GetService(); + // if (healthCheckService.DoHealthCheckAsync().GetAwaiter().GetResult()) + // { + // using var scope = app.ApplicationServices.CreateScope(); + // var db = scope.ServiceProvider.GetService(); + // + // db.Client.DbMaintenance.CreateDatabase(); + // db.Client.CodeFirst.InitTables(); + // db.Client.CodeFirst.InitTables(); + // db.Client.CodeFirst.InitTables(); + // + // var factories = scope.ServiceProvider.GetService().GetFactories(); + // var ds = scope.ServiceProvider.GetService(); + // ds.InitAsync(factories).Wait(); + // } } } \ No newline at end of file