1

hutongqing

2025-01-24 2aef482fa7431fb47eef94081ff23ec220f89820

 WIDESEAWCS_Server/WIDESEAWCS_QuartzJob/QuartzExtensions/QuartzJobDataTableHostedService.cs

@@ -31,6 +31,9 @@

namespace WIDESEAWCS_QuartzJob.QuartzExtensions
{
    /// <summary>
    /// 自动建表
    /// </summary>
    public sealed class QuartzJobDataTableHostedService : IHostedService
    {
        private readonly DBContext _dbContext;
@@ -38,6 +41,9 @@
        private readonly string _webRootPath;
        private readonly IServiceProvider _serviceProvider;

        /// <summary>
        /// 自动建表
        /// </summary>
        public QuartzJobDataTableHostedService(
            IServiceProvider serviceProvider,
            IWebHostEnvironment webHostEnvironment,
@@ -51,17 +57,23 @@
            _dbContext = dbContext;
        }

        /// <summary>
        /// 自动建表
        /// </summary>
        public async Task StartAsync(CancellationToken cancellationToken)
        {
            _logger.LogInformation("开始创建定时器调度数据表");
            await DoWork();
        }

        /// <summary>
        /// 自动建表
        /// </summary>
        private async Task DoWork()
        {
            try
            {
                await QuartzJobCreateDataTabel.SeedAsync(_dbContext);
                await QuartzJobCreateDataTabel.SeedAsync(_dbContext, _webRootPath);
            }
            catch (Exception ex)
            {
@@ -70,6 +82,9 @@
            }
        }

        /// <summary>
        /// 自动建表
        /// </summary>
        public Task StopAsync(CancellationToken cancellationToken)
        {
            _logger.LogInformation("定时器调度数据表结束");