You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
29 lines
1.4 KiB
29 lines
1.4 KiB
5 days ago
|
namespace Admin.NET.Core;
|
||
|
|
||
|
/// <summary>
|
||
|
/// 清理日志作业任务
|
||
|
/// </summary>
|
||
|
[JobDetail("job_log", Description = "清理操作日志", GroupName = "default", Concurrent = false)]
|
||
|
[Daily(TriggerId = "trigger_log", Description = "清理操作日志")]
|
||
|
public class LogJob : IJob
|
||
|
{
|
||
|
private readonly IServiceProvider _serviceProvider;
|
||
|
|
||
|
public LogJob(IServiceProvider serviceProvider)
|
||
|
{
|
||
|
_serviceProvider = serviceProvider;
|
||
|
}
|
||
|
|
||
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
||
|
{
|
||
|
using var serviceScope = _serviceProvider.CreateScope();
|
||
|
var logVisRep = serviceScope.ServiceProvider.GetService<SqlSugarRepository<SysLogVis>>();
|
||
|
var logOpRep = serviceScope.ServiceProvider.GetService<SqlSugarRepository<SysLogOp>>();
|
||
|
var logDiffRep = serviceScope.ServiceProvider.GetService<SqlSugarRepository<SysLogDiff>>();
|
||
|
|
||
|
var daysAgo = 30; // 删除30天以前
|
||
|
await logVisRep.AsDeleteable().Where(u => (DateTime)u.CreateTime < DateTime.Now.AddDays(-daysAgo)).ExecuteCommandAsync(stoppingToken); // 删除访问日志
|
||
|
await logOpRep.AsDeleteable().Where(u => (DateTime)u.CreateTime < DateTime.Now.AddDays(-daysAgo)).ExecuteCommandAsync(stoppingToken); // 删除操作日志
|
||
|
await logDiffRep.AsDeleteable().Where(u => (DateTime)u.CreateTime < DateTime.Now.AddDays(-daysAgo)).ExecuteCommandAsync(stoppingToken); // 删除差异日志
|
||
|
}
|
||
|
}
|