fix 删除日志优化
This commit is contained in:
@@ -24,7 +24,7 @@ namespace Dlhis.Common.Services
|
||||
var logs = await _dbContext.ChangeDb("log").Queryable<ApiLogEntity>()
|
||||
.WhereIF(request.Search.IsPresent(), x => x.Message.Contains(request.Search))
|
||||
.WhereIF(request.Level.HasValue, x => x.Level == request.Level)
|
||||
.OrderBy(x => x.Timestamp,OrderByType.Desc)
|
||||
.OrderBy(x => x.Timestamp, OrderByType.Desc)
|
||||
.Select<ApiLogResponse>()
|
||||
.ToPageListAsync(request);
|
||||
|
||||
|
||||
@@ -9,7 +9,7 @@ namespace Dlhis.Entity.Common;
|
||||
/// api日志表
|
||||
/// </summary>
|
||||
[SugarTable(TableName = "Logs", TableDescription = "api日志表")]
|
||||
public class ApiLogEntity
|
||||
public class ApiLogEntity : SugarBaseEntity
|
||||
{
|
||||
/// <summary>
|
||||
/// 时间
|
||||
|
||||
@@ -26,10 +26,19 @@ namespace Dlhis.ScheduledTask.CommonJobs;
|
||||
var logs = await _dbContext.ChangeDb("log")
|
||||
.Queryable<ApiLogEntity>()
|
||||
.Where(x => x._ts <= threeDaysAgoStart)
|
||||
.OrderBy(x => x._ts, OrderByType.Asc)
|
||||
.Select(x => x.Id)
|
||||
.ToListAsync();
|
||||
|
||||
await _dbContext.ChangeDb("log").DeleteReallyAsync(logs);
|
||||
var lst = new List<ApiLogEntity>();
|
||||
foreach (var id in logs)
|
||||
{
|
||||
var entity = new ApiLogEntity
|
||||
{
|
||||
Id = id,
|
||||
};
|
||||
lst.Add(entity);
|
||||
}
|
||||
await _dbContext.ChangeDb("log").DeleteReallyAsync(lst);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
|
||||
Reference in New Issue
Block a user