diff --git a/src/SJZY.Track.Application/Hangfire/WarningNotifyAggregator.cs b/src/SJZY.Track.Application/Hangfire/WarningNotifyAggregator.cs index e71eb5fa..25267a78 100644 --- a/src/SJZY.Track.Application/Hangfire/WarningNotifyAggregator.cs +++ b/src/SJZY.Track.Application/Hangfire/WarningNotifyAggregator.cs @@ -45,12 +45,12 @@ public sealed class WarningNotifyAggregator : ITransientDependency // 4.绑定这个任务id(可能是多个)和jobId用户跟踪任务状态 public async Task<(List NotifyConfigs, HashSet taskIds)> ScanNotifyAndAggregateAsync() { - // 构建查询游标 - var options = _optionsMonitor.CurrentValue; - var cursor = DateTime.Now.Subtract(TimeSpan.FromHours(options.ScanWarningNotifyTaskHourInterval)); + // 构建查询游标 todo:全量查询需要优化 + // var options = _optionsMonitor.CurrentValue; + // var cursor = DateTime.Now.Subtract(TimeSpan.FromHours(options.ScanWarningNotifyTaskHourInterval)); // 1.扫描出可能进行的任务 - var tasks = await _warningTaskRepository.ScanNotifyTaskAsync(cursor); + var tasks = await _warningTaskRepository.ScanNotifyTaskAsync(); // 2.可行性过滤 var filtered = await FilterAsync(tasks);