jinko.yikatong/Src/Dlhis.Middle/BackgroundServices/HealthCheckBackgroundService.cs

using Dlhis.Middle.Entities;
using Dlhis.Middle.Services;
using Kurisu.AspNetCore.DataAccess.SqlSugar.Services;

namespace Dlhis.Middle.BackgroundServices;

public class HealthCheckBackgroundService : BackgroundService
{
    private readonly IHealthCheckService _healthCheckService;
    private readonly IServiceProvider _serviceProvider;
    private bool _init;

    public HealthCheckBackgroundService(IHealthCheckService healthCheckService, IServiceProvider serviceProvider)
    {
        _healthCheckService = healthCheckService;
        _serviceProvider = serviceProvider;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            if (await _healthCheckService.DoHealthCheckAsync())
            {
                if (!_init)
                {
                    using var scope = _serviceProvider.CreateScope();
                    
                    var db = scope.ServiceProvider.GetService<IDbContext>();

                    db.Client.DbMaintenance.CreateDatabase();
                    db.Client.CodeFirst.InitTables<LocalBalanceRecordEntity, LocalGainfoEntity, LocalGainfoMealEntity, LocalBusinessPlaceEntity>();
                    db.Client.CodeFirst.InitTables<LocalBusinessShiftEntity, LocalDeviceRegistryEntity, LocalDeviceEntity, LocalBusinessPlaceShiftRelationshipEntity, LocalBusinessShiftMealRelationshipEntity>();
                    db.Client.CodeFirst.InitTables<LocalCanteenSettingEntity, LocalDepartmentEntity>();
                    
                    var factories = scope.ServiceProvider.GetService<ISettingService>().GetFactories();
                    var ds = scope.ServiceProvider.GetService<IDataDownloadService>();
                    await ds.InitAsync(factories);
                }
            }
            
            _init = true;
        }
    }
}