on.nemtina/DD.WellWorkover.Cloud
1
0
Fork 0
forked from ddrilling/AsbCloudServer
Code Pull Requests Activity

ReportService.DeleteAllOldReportsAsync(..) optimize EF queries

Browse Source
This commit is contained in:
ngfrolov 2023-11-10 16:34:15 +05:00
parent 3451d7ca98
commit c34d6d39f5
Signed by: ng.frolov
GPG Key ID: E99907A0357B29A7
2 changed files with 6 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
AsbCloudInfrastructure/Background/WorkToDeleteOldReports.cs
View File

@ -28,7 +28,7 @@ namespace AsbCloudInfrastructure.Background
protected override async Task Action(string id, IServiceProvider services, Action<string, double?> onProgressCallback, CancellationToken token) protected override async Task Action(string id, IServiceProvider services, Action<string, double?> onProgressCallback, CancellationToken token)
{ {
var reportService = services.GetRequiredService<IReportService>(); var reportService = services.GetRequiredService<IReportService>();
await reportService.DeleteAllOldReportsAsync(new TimeSpan(30, 0, 0, 0), token); await reportService.DeleteAllOldReportsAsync(TimeSpan.FromDays(30), token);
} }
} }
} }

14
AsbCloudInfrastructure/Services/ReportService.cs
View File

@ -192,17 +192,13 @@ namespace AsbCloudInfrastructure.Services
public async Task<int> DeleteAllOldReportsAsync(TimeSpan lifetime, CancellationToken token) public async Task<int> DeleteAllOldReportsAsync(TimeSpan lifetime, CancellationToken token)
{ {
var lifeTimeStartDate = DateTime.UtcNow.Date.Add(-lifetime); var lifeTimeStartDate = DateTime.UtcNow.Date - lifetime;
var fileIds = db.ReportProperties var fileIds = await db.ReportProperties
.Where(r => r.File.UploadDate.Date < lifeTimeStartDate) .Where(r => r.File.UploadDate.Date < lifeTimeStartDate)
.Select(r => r.IdFile); .Select(r => r.IdFile)
.ToArrayAsync(token);
if (fileIds.Any()) return await fileService.DeleteAsync(fileIds, token);
{
return await fileService.DeleteAsync(fileIds, token);
}
return 0;
} }
} }
} }