fix 删除日志优化

This commit is contained in:
cheche
2024-03-20 09:55:13 +08:00
parent 3a65d95701
commit aba4fa7ee9
3 changed files with 14 additions and 5 deletions

View File

@@ -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);

View File

@@ -9,7 +9,7 @@ namespace Dlhis.Entity.Common;
/// api日志表
/// </summary>
[SugarTable(TableName = "Logs", TableDescription = "api日志表")]
public class ApiLogEntity
public class ApiLogEntity : SugarBaseEntity
{
/// <summary>
/// 时间

View File

@@ -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)
{