diff --git a/AsbCloudApp/Services/IReportService.cs b/AsbCloudApp/Services/IReportService.cs
index 1f4a7d35..de8896b9 100644
--- a/AsbCloudApp/Services/IReportService.cs
+++ b/AsbCloudApp/Services/IReportService.cs
@@ -57,5 +57,13 @@ namespace AsbCloudApp.Services
///
///
Task> GetAllReportsByWellAsync(int idWell, CancellationToken token);
+
+ ///
+ /// Удаление отчетов, с момента загрузки которых прошло n дней
+ ///
+ /// период, за который отчеты хранятся на сервере и при превышении которого удаляются
+ ///
+ ///
+ Task DeleteAllOldReportsAsync(int days, CancellationToken token);
}
}
diff --git a/AsbCloudInfrastructure/Repository/FileRepository.cs b/AsbCloudInfrastructure/Repository/FileRepository.cs
index e75e7691..cafc5649 100644
--- a/AsbCloudInfrastructure/Repository/FileRepository.cs
+++ b/AsbCloudInfrastructure/Repository/FileRepository.cs
@@ -147,17 +147,17 @@ namespace AsbCloudInfrastructure.Repository
public async Task> DeleteAsync(IEnumerable ids, CancellationToken token)
{
var query = dbSetConfigured
- .Where(f => ids.Contains(f.Id) && f.IsDeleted);
+ .Where(f => ids.Contains(f.Id));
- var files = await query.ToListAsync(token);
+ var files = await query.ToListAsync(token);
- var filesDtos = files.Select(x => Convert(x));
+ var filesDtos = files.Select(x => Convert(x));
- db.Files.RemoveRange(query);
- await db.SaveChangesAsync(token).ConfigureAwait(false);
+ db.Files.RemoveRange(query);
+ await db.SaveChangesAsync(token).ConfigureAwait(false);
- return filesDtos;
- }
+ return filesDtos;
+ }
public async Task GetByMarkId(int idMark, CancellationToken token)
{
diff --git a/AsbCloudInfrastructure/Services/ReportService.cs b/AsbCloudInfrastructure/Services/ReportService.cs
index ed24bc3e..ce9e57c9 100644
--- a/AsbCloudInfrastructure/Services/ReportService.cs
+++ b/AsbCloudInfrastructure/Services/ReportService.cs
@@ -18,22 +18,39 @@ namespace AsbCloudInfrastructure.Services
public class ReportService : IReportService
{
+ public class WorkToDeleteOldReports : Work
+ {
+ public WorkToDeleteOldReports()
+ : base("work to delete reports older than 30 days")
+ {
+ Timeout = TimeSpan.FromMinutes(10);
+ }
+
+ protected override async Task Action(string id, IServiceProvider services, Action onProgressCallback, CancellationToken token)
+ {
+ var reportService = services.GetRequiredService();
+ await reportService.DeleteAllOldReportsAsync(-30, token);
+ }
+ }
private readonly IAsbCloudDbContext db;
private readonly ITelemetryService telemetryService;
+ private readonly FileService fileService;
private readonly IWellService wellService;
private readonly BackgroundWorker backgroundWorkerService;
public int ReportCategoryId { get; private set; }
public ReportService(IAsbCloudDbContext db,
- ITelemetryService telemetryService,
- IWellService wellService,
+ ITelemetryService telemetryService,
+ IWellService wellService,
+ FileService fileService,
BackgroundWorker backgroundWorkerService)
{
this.db = db;
this.wellService = wellService;
this.backgroundWorkerService = backgroundWorkerService;
this.telemetryService = telemetryService;
+ this.fileService = fileService;
ReportCategoryId = db.FileCategories
.AsNoTracking()
.First(c => c.Name.Equals("Рапорт"))
@@ -69,7 +86,7 @@ namespace AsbCloudInfrastructure.Services
progressHandler.Invoke(arg, id);
};
generator.Make(reportFileName);
-
+
var fileInfo = (await fileService.MoveAsync(idWell, idUser, ReportCategoryId, reportFileName, reportFileName, token))!;
progressHandler.Invoke(new
@@ -186,6 +203,24 @@ namespace AsbCloudInfrastructure.Services
return generator;
}
+
+ public async Task DeleteAllOldReportsAsync(int days, CancellationToken token)
+ {
+ var reports = db.ReportProperties
+ .Include(r => r.File)
+ .Where(r => r.File.UploadDate.Date < DateTime.UtcNow.Date.AddDays(days))
+ .AsNoTracking();
+
+ var files = await reports.Select(r => r.IdFile).ToListAsync(token);
+ if (files.Any())
+ {
+ await fileService.DeleteAsync(files, token);
+ }
+
+ db.ReportProperties.RemoveRange(reports);
+
+ return await db.SaveChangesAsync(token);
+ }
}
}
diff --git a/AsbCloudInfrastructure/Startup.cs b/AsbCloudInfrastructure/Startup.cs
index 8661c651..be1c461b 100644
--- a/AsbCloudInfrastructure/Startup.cs
+++ b/AsbCloudInfrastructure/Startup.cs
@@ -29,6 +29,7 @@ namespace AsbCloudInfrastructure
_ = provider.GetRequiredService>();
var backgroundWorker = provider.GetRequiredService();
+ backgroundWorker.Add(TimeSpan.FromDays(1));
backgroundWorker.Add(TimeSpan.FromMinutes(30));
backgroundWorker.Add(TimeSpan.FromMinutes(15));
backgroundWorker.Add(TimeSpan.FromMinutes(30));