diff --git a/src/SJZY.Track.Application/BackgroundServices/OrderPullStatusScanner.cs b/src/SJZY.Track.Application/BackgroundServices/OrderPullStatusScanner.cs index e2fb7bd0..6875fd82 100644 --- a/src/SJZY.Track.Application/BackgroundServices/OrderPullStatusScanner.cs +++ b/src/SJZY.Track.Application/BackgroundServices/OrderPullStatusScanner.cs @@ -23,14 +23,17 @@ public class OrderPullStatusScanner : BackgroundService protected override async Task ExecuteAsync(CancellationToken stoppingToken) { - var stopwatch = Stopwatch.StartNew(); - var count1 = await _orderRepository.UpdatePullStatusBySilenceAsync(); - // real del - var count2 = await _orderRepository.ClearPullStatusAsync(); - stopwatch.Stop(); - LogHelper.Info( - $"{nameof(OrderPullStatusScanner)}本次扫描更新了{count1}条,删除了{count2}条订单拉取状态,耗时{stopwatch.ElapsedMilliseconds}ms"); + while (true) + { + await Task.Delay(TimeSpan.FromSeconds(_options.CurrentValue.OrderPullStatusScanInterval), stoppingToken); - await Task.Delay(TimeSpan.FromSeconds(_options.CurrentValue.OrderPullStatusScanInterval), stoppingToken); + var stopwatch = Stopwatch.StartNew(); + var count1 = await _orderRepository.UpdatePullStatusBySilenceAsync(); + // real del + var count2 = await _orderRepository.ClearPullStatusAsync(); + stopwatch.Stop(); + LogHelper.Info( + $"{nameof(OrderPullStatusScanner)}本次扫描更新了{count1}条,删除了{count2}条订单拉取状态,耗时{stopwatch.ElapsedMilliseconds}ms"); + } } }