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

docs: #302 api for handling saved duplicated poems

Browse Source
This commit is contained in:
Hamid Reza Mohammadi 2022-03-28 13:01:25 +04:30
parent 333f6f0b68
commit 40575e6fa6
4 changed files with 152 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
RMuseum/Controllers/GanjoorController.cs
View File

@ -2673,6 +2673,24 @@ namespace RMuseum.Controllers
return Ok(res.Result);
}
/// <summary>
/// start removing category duplicates
/// </summary>
/// <param name="srcCatId"></param>
/// <param name="destCatId"></param>
/// <returns></returns>
[HttpPut("duplicates/finish/{srcCatId}/{destCatId}")]
[Authorize(Policy = RMuseumSecurableItem.GanjoorEntityShortName + ":" + SecurableItem.ModifyOperationShortName)]
[ProducesResponseType((int)HttpStatusCode.OK)]
[ProducesResponseType((int)HttpStatusCode.BadRequest, Type = typeof(string))]
public IActionResult StartRemovingCategoryDuplicates(int srcCatId, int destCatId)
{
var res = _ganjoorService.StartRemovingCategoryDuplicates(srcCatId, destCatId);
if (!string.IsNullOrEmpty(res.ExceptionString))
return BadRequest(res.ExceptionString);
return Ok();
}
/// <summary>
/// readonly mode
/// </summary>

24
RMuseum/RMuseum.xml
View File

@ -1648,6 +1648,14 @@
<param name="catId"></param>
<returns></returns>
</member>
<member name="M:RMuseum.Controllers.GanjoorController.StartRemovingCategoryDuplicates(System.Int32,System.Int32)">
<summary>
start removing category duplicates
</summary>
<param name="srcCatId"></param>
<param name="destCatId"></param>
<returns></returns>
</member>
<member name="P:RMuseum.Controllers.GanjoorController.ReadOnlyMode">
<summary>
readonly mode
@ -11411,6 +11419,14 @@
<param name="catId"></param>
<returns></returns>
</member>
<member name="M:RMuseum.Services.IGanjoorService.StartRemovingCategoryDuplicates(System.Int32,System.Int32)">
<summary>
start removing category duplicates
</summary>
<param name="catId"></param>
<param name="destCatId"></param>
<returns></returns>
</member>
<member name="T:RMuseum.Services.IGanjoorTranslationService">
<summary>
translation service implementation
@ -12860,6 +12876,14 @@
<param name="destCatId"></param>
<returns></returns>
</member>
<member name="M:RMuseum.Services.Implementation.GanjoorService.StartRemovingCategoryDuplicates(System.Int32,System.Int32)">
<summary>
start removing category duplicates
</summary>
<param name="catId"></param>
<param name="destCatId"></param>
<returns></returns>
</member>
<member name="M:RMuseum.Services.Implementation.GanjoorService.FindCategoryPoemsRhythms(System.Int32,System.Boolean,System.String)">
<summary>
find category poem rhymes

8
RMuseum/Services/IGanjoorService.cs
View File

@ -869,5 +869,13 @@ namespace RMuseum.Services
/// <param name="catId"></param>
/// <returns></returns>
Task<RServiceResult<GanjoorDuplicateViewModel[]>> GetCategoryDuplicates(int catId);
/// <summary>
/// start removing category duplicates
/// </summary>
/// <param name="catId"></param>
/// <param name="destCatId"></param>
/// <returns></returns>
RServiceResult<bool> StartRemovingCategoryDuplicates(int catId, int destCatId);
}
}

102
RMuseum/Services/Implementation/GanjoorService-Partials/GanjoorService-DuplicateFinder.cs
View File

@ -53,6 +53,108 @@ namespace RMuseum.Services.Implementation
return new RServiceResult<bool>(false, exp.ToString());
}
}
/// <summary>
/// start removing category duplicates
/// </summary>
/// <param name="catId"></param>
/// <param name="destCatId"></param>
/// <returns></returns>
public RServiceResult<bool> StartRemovingCategoryDuplicates(int catId, int destCatId)
{
try
{
_backgroundTaskQueue.QueueBackgroundWorkItem
(
async token =>
{
using (RMuseumDbContext context = new RMuseumDbContext(new DbContextOptions<RMuseumDbContext>())) //this is long running job, so _context might be already been freed/collected by GC
{
LongRunningJobProgressServiceEF jobProgressServiceEF = new LongRunningJobProgressServiceEF(context);
var job = (await jobProgressServiceEF.NewJob($"RemoveCategoryDuplicates {catId}", "Query data")).Result;
try
{
var dups = await context.GanjoorDuplicates.Where(p => p.SrcCatId == catId && p.DestPoemId != null).OrderBy(p => p.SrcPoemId).ToListAsync();
var poems = await context.GanjoorPoems.Where(p => p.CatId == catId).OrderBy(p => p.Id).ToListAsync();
if (poems.Count != dups.Count)
{
await jobProgressServiceEF.UpdateJob(job.Id, 100, "", false, "poems.Count != dups.Count");
return;
}
foreach (var poem in poems)
{
if (!dups.Where(d => d.SrcPoemId == poem.Id).Any())
{
await jobProgressServiceEF.UpdateJob(job.Id, 100, "", false, $"poem ID = {poem.Id}, missing destination");
return;
}
}
foreach (var dup in dups)
{
var srcPoem = poems.Where(p => p.Id == dup.SrcPoemId).Single();
var destPage = await context.GanjoorPages.Where(p => p.Id == dup.DestPoemId).SingleAsync();
destPage.RedirectFromFullUrl = srcPoem.FullUrl;
context.Update(destPage);
var comments = await context.GanjoorComments.Where(c => c.PoemId == dup.SrcPoemId).ToListAsync();
foreach (var comment in comments)
{
comment.PoemId = (int)dup.DestPoemId;
}
context.UpdateRange(comments);
var songs = await context.GanjoorPoemMusicTracks.Where(m => m.PoemId == dup.SrcPoemId).ToListAsync();
foreach (var song in songs)
{
var alreadyAdded = await context.GanjoorPoemMusicTracks.Where(m => m.PoemId == dup.DestPoemId && m.TrackUrl == song.TrackUrl).FirstOrDefaultAsync();
if(alreadyAdded != null)
{
song.PoemId = (int)dup.DestPoemId;
}
}
context.UpdateRange(songs);
var similars = await context.GanjoorCachedRelatedPoems.Where(s => s.FullUrl == srcPoem.FullUrl).ToListAsync();
context.RemoveRange(similars);
var corrections = await context.GanjoorPoemCorrections.Include(c => c.VerseOrderText).Where(c => c.PoemId == srcPoem.Id).ToListAsync();
context.RemoveRange(corrections);
var page = await context.GanjoorPages.Where(p => p.Id == srcPoem.Id && p.GanjoorPageType == GanjoorPageType.PoemPage).SingleAsync();
context.Remove(page);
await jobProgressServiceEF.UpdateJob(job.Id, 0, srcPoem.FullTitle);
}
context.RemoveRange(dups);
context.RemoveRange(poems);
await jobProgressServiceEF.UpdateJob(job.Id, 1, "Removing Category and poems");
var catPage = await context.GanjoorPages.Where(p => p.GanjoorPageType == GanjoorPageType.CatPage && p.CatId == catId).SingleAsync();
var destCatPage = await context.GanjoorPages.Where(p => p.GanjoorPageType == GanjoorPageType.CatPage && p.CatId == destCatId).SingleAsync();
destCatPage.RedirectFromFullUrl = catPage.FullUrl;
context.Update(destCatPage);
context.Remove(catPage);
await jobProgressServiceEF.UpdateJob(job.Id, 100, "", true);
}
catch (Exception exp)
{
await jobProgressServiceEF.UpdateJob(job.Id, 100, "", false, exp.ToString());
}
}
});
return new RServiceResult<bool>(true);
}
catch (Exception exp)
{
return new RServiceResult<bool>(false, exp.ToString());
}
}
private async Task<RServiceResult<bool>> _FindCategoryPoemsDuplicates(RMuseumDbContext context, int srcCatId, int destCatId)
{
try