anas/divan
1
0
Fork 0
Code Issues 12 Pull Requests Actions Packages Projects Releases Wiki Activity

#409 QueuedPDFBook model + Processed field

Browse Source
This commit is contained in:
Hamid Reza Mohammadi 2023-09-01 11:57:27 +03:30
parent a3612e571a
commit 59d3d7232c
5 changed files with 22 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
RMuseum/Models/PDFLibrary/QueuedPDFBook.cs
View File

@ -61,5 +61,10 @@ namespace RMuseum.Models.PDFLibrary
/// original file url
/// </summary>
public string OriginalFileUrl { get; set; }
/// <summary>
/// processed
/// </summary>
public bool Processed { get; set; }
}
}

5
RMuseum/RMuseum.xml
View File

@ -13026,6 +13026,11 @@
original file url
</summary>
</member>
<member name="P:RMuseum.Models.PDFLibrary.QueuedPDFBook.Processed">
<summary>
processed
</summary>
</member>
<member name="T:RMuseum.Models.PDFLibrary.ViewModels.AuthorRoleCount">
<summary>
Author Role Count

11
RMuseum/Services/Implementation/PDFLibraryService-Partials/PDFLibraryService-QueuedPDFBooks.cs
View File

@ -66,6 +66,12 @@ namespace RMuseum.Services.Implementation
{
try
{
var processed = await _context.QueuedPDFBooks.Where(t => t.Processed).ToListAsync();
if(processed.Count > 0)
{
_context.RemoveRange(processed);
await _context.SaveChangesAsync();
}
var qSoha = await _context.QueuedPDFBooks.Where(t => t.OriginalSourceUrl.Contains("https://sohalibrary.com")).OrderBy(t => t.DownloadOrder).ToListAsync();
var qElit = await _context.QueuedPDFBooks.Where(t => !t.OriginalSourceUrl.Contains("https://sohalibrary.com")).OrderBy(t => t.DownloadOrder).ToListAsync();
@ -114,10 +120,13 @@ namespace RMuseum.Services.Implementation
{
using (RMuseumDbContext context = new RMuseumDbContext(new DbContextOptions<RMuseumDbContext>()))
{
var q = await context.QueuedPDFBooks.AsNoTracking().OrderBy(i => i.DownloadOrder).ToListAsync();
var q = await context.QueuedPDFBooks.Where(i => i.Processed == false).OrderBy(i => i.DownloadOrder).ToListAsync();
foreach (var item in q)
{
await StartImportingKnownSourceAsync(item.OriginalSourceUrl);
item.Processed = true;
context.Update(item);
await context.SaveChangesAsync();
}
}
}

1
RMuseum/Services/Implementation/PDFLibraryService-Partials/PDFLibraryService-SohaLibrary.cs
View File

@ -519,6 +519,7 @@ namespace RMuseum.Services.Implementation
OriginalSourceName = model.OriginalSourceName,
OriginalSourceUrl = model.OriginalSourceUrl,
OriginalFileUrl = model.OriginalFileUrl,
Processed = false,
}
);
await context.SaveChangesAsync();

1
RMuseum/Services/Implementation/PDFLibraryService-Partials/PDFLibraryService-eliteraturebook.cs
View File

@ -562,6 +562,7 @@ namespace RMuseum.Services.Implementation
OriginalSourceName = model.OriginalSourceName,
OriginalSourceUrl = model.OriginalSourceUrl,
OriginalFileUrl = model.OriginalFileUrl,
Processed = false,
}
);
await context.SaveChangesAsync();