From 81ad774dfc09bf5c449c479766b55fb3414ea5eb Mon Sep 17 00:00:00 2001 From: EchoForge7 <168069374+EchoForge7@users.noreply.github.com> Date: Tue, 11 Nov 2025 18:17:03 +0800 Subject: [PATCH] feat: support configurable Period for LogEventDelWorker via options --- .../Worker/LogEventDelWorker.cs | 15 ++++++--------- 1 file changed, 6 insertions(+), 9 deletions(-) diff --git a/src/AElfScanServer.Worker.Core/Worker/LogEventDelWorker.cs b/src/AElfScanServer.Worker.Core/Worker/LogEventDelWorker.cs index 2c018502..22be4236 100644 --- a/src/AElfScanServer.Worker.Core/Worker/LogEventDelWorker.cs +++ b/src/AElfScanServer.Worker.Core/Worker/LogEventDelWorker.cs @@ -1,30 +1,27 @@ using System.Threading.Tasks; +using AElfScanServer.Worker.Core.Options; using AElfScanServer.Worker.Core.Service; using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.Logging; +using Microsoft.Extensions.Options; using Volo.Abp.BackgroundWorkers; using Volo.Abp.Threading; - namespace AElfScanServer.Worker.Core.Worker; - public class LogEventDelWorker : AsyncPeriodicBackgroundWorkerBase { private readonly ITransactionService _transactionService; - private readonly ILogger _logger; - - + private const string WorkerName = "LogEventDelWorker"; public LogEventDelWorker(AbpAsyncTimer timer, IServiceScopeFactory serviceScopeFactory, - ILogger logger, ITransactionService transactionService) : base(timer, + ILogger logger, ITransactionService transactionService, IOptionsMonitor workerOptions) : base(timer, serviceScopeFactory) { - timer.Period = 1000 * 60 * 15; + timer.Period = workerOptions.CurrentValue.GetWorkerPeriodMinutes(WorkerName) * 60 * 1000; _logger = logger; _transactionService = transactionService; } - protected override async Task DoWorkAsync(PeriodicBackgroundWorkerContext workerContext) { await _transactionService.DelLogEventTask(); } -} \ No newline at end of file +}