diff --git a/Src/Dlhis.ScheduledTask/CommonJobs/DelApiLogTaskJob.cs b/Src/Dlhis.ScheduledTask/CommonJobs/DelApiLogTaskJob.cs index 50126b15..d623561b 100644 --- a/Src/Dlhis.ScheduledTask/CommonJobs/DelApiLogTaskJob.cs +++ b/Src/Dlhis.ScheduledTask/CommonJobs/DelApiLogTaskJob.cs @@ -7,25 +7,35 @@ namespace Dlhis.ScheduledTask.CommonJobs; public class DelApiLogTaskJob { private readonly IDbContext _dbContext; + private readonly Logger _logger; - public DelApiLogTaskJob(IDbContext dbContext) + public DelApiLogTaskJob(IDbContext dbContext, Logger logger) { _dbContext = dbContext; + _logger = logger; } public async Task RunAsync() { - DateTime now = DateTime.Now; - DateTime todayStart = now.Date; - DateTime threeDaysAgoStart = todayStart.AddDays(-3); + try + { + DateTime now = DateTime.Now; + DateTime todayStart = now.Date; + DateTime threeDaysAgoStart = todayStart.AddDays(-3); - var logs = await _dbContext.ChangeDb("log") - .Queryable() - .Where(x => x._ts<= threeDaysAgoStart) - .OrderBy(x =>x._ts,OrderByType.Asc) - .ToListAsync(); + var logs = await _dbContext.ChangeDb("log") + .Queryable() + .Where(x => x._ts <= threeDaysAgoStart) + .OrderBy(x => x._ts, OrderByType.Asc) + .ToListAsync(); - await _dbContext.ChangeDb("log").DeleteReallyAsync(logs); + await _dbContext.ChangeDb("log").DeleteReallyAsync(logs); + } + catch (Exception ex) + { + _logger.LogError(ex, "删除日志异常:{message}", ex.Message); + } + } }