From c2b97024dcdf5882e22152bc57a4db3c11ebce9d Mon Sep 17 00:00:00 2001 From: liguoyang Date: Mon, 12 May 2025 17:10:25 +0800 Subject: [PATCH] =?UTF-8?q?fix=20=E5=A2=9E=E5=8A=A0=E6=97=B6=E9=97=B4?= =?UTF-8?q?=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Jobs/ArchiveDeviceUploadLogJob.cs | 17 +++++++++++++++-- 1 file changed, 15 insertions(+), 2 deletions(-) diff --git a/Src/Dlhis.ScheduledTask/Jobs/ArchiveDeviceUploadLogJob.cs b/Src/Dlhis.ScheduledTask/Jobs/ArchiveDeviceUploadLogJob.cs index 7aaf90b3..648c7ea3 100644 --- a/Src/Dlhis.ScheduledTask/Jobs/ArchiveDeviceUploadLogJob.cs +++ b/Src/Dlhis.ScheduledTask/Jobs/ArchiveDeviceUploadLogJob.cs @@ -6,7 +6,7 @@ namespace Dlhis.ScheduledTask.Jobs; /// /// 归档设备通行记录 /// -[RecurringJob(nameof(ArchiveDeviceUploadLogJob), "0 0/5 * * * ?", Name = "归档设备通行记录")] +[RecurringJob(nameof(ArchiveDeviceUploadLogJob), "0 0 20 * * ? ", Name = "归档设备通行记录")] public class ArchiveDeviceUploadLogJob : BaseJob { public ArchiveDeviceUploadLogJob(IServiceProvider serviceProvider) : base(serviceProvider) @@ -21,6 +21,7 @@ public class ArchiveDeviceUploadLogJob : BaseJob var data = await DbContext.Queryable().Where(x => x.RaiseDateTime < before60Days).OrderBy(x => x.Id).ToPageListAsync(1, limit); + var now = DateTime.Now; do { if (data.Any()) @@ -47,6 +48,18 @@ public class ArchiveDeviceUploadLogJob : BaseJob data = await DbContext.Queryable().Where(x => x.RaiseDateTime < before60Days).OrderBy(x => x.Id).ToPageListAsync(1, limit); } - } while (data.Count == limit); + + now = DateTime.Now; + } while (data.Count == limit && TimeSetting(now)); + } + + private bool TimeSetting(DateTime d) + { + if (d.Hour is >= 20 or <= 7) + { + return true; + } + + return false; } } \ No newline at end of file