docs: #293 moving UpdatePageAsync to a separate file to make ir LONG-RUNNING-JOB friendly
This commit is contained in:
Hamid Reza Mohammadi
parent
2b8ec79a97
commit
b2f71a73b1
@ -12579,6 +12579,9 @@
|
||||
<summary>
|
||||
IGanjoorService implementation
|
||||
</summary>
|
||||
<summary>
|
||||
IGanjoorService implementation
|
||||
</summary>
|
||||
</member>
|
||||
<member name="M:RMuseum.Services.Implementation.GanjoorService.SwitchCoupletBookmark(System.Guid,System.Int32,System.Int32)">
|
||||
<summary>
|
||||
@ -12975,6 +12978,15 @@
|
||||
</summary>
|
||||
<returns></returns>
|
||||
</member>
|
||||
<member name="M:RMuseum.Services.Implementation.GanjoorService.UpdatePageAsync(System.Int32,System.Guid,RMuseum.Models.Ganjoor.ViewModels.GanjoorModifyPageViewModel)">
|
||||
<summary>
|
||||
modify page
|
||||
</summary>
|
||||
<param name="id"></param>
|
||||
<param name="editingUserId"></param>
|
||||
<param name="pageData"></param>
|
||||
<returns></returns>
|
||||
</member>
|
||||
<member name="M:RMuseum.Services.Implementation.GanjoorService.GetPoets(System.Boolean,System.Boolean)">
|
||||
<summary>
|
||||
Get List of poets
|
||||
@ -13329,15 +13341,6 @@
|
||||
<param name="catId"></param>
|
||||
<returns></returns>
|
||||
</member>
|
||||
<member name="M:RMuseum.Services.Implementation.GanjoorService.UpdatePageAsync(System.Int32,System.Guid,RMuseum.Models.Ganjoor.ViewModels.GanjoorModifyPageViewModel)">
|
||||
<summary>
|
||||
modify page
|
||||
</summary>
|
||||
<param name="id"></param>
|
||||
<param name="editingUserId"></param>
|
||||
<param name="pageData"></param>
|
||||
<returns></returns>
|
||||
</member>
|
||||
<member name="M:RMuseum.Services.Implementation.GanjoorService.GetOlderVersionsOfPage(System.Int32)">
|
||||
<summary>
|
||||
return page modifications history
|
||||
|
||||
@ -0,0 +1,331 @@
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using RMuseum.DbContext;
|
||||
using RMuseum.Models.Ganjoor;
|
||||
using RMuseum.Models.Ganjoor.ViewModels;
|
||||
using RSecurityBackend.Models.Generic;
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Data;
|
||||
using System.Linq;
|
||||
using System.Threading.Tasks;
|
||||
using RSecurityBackend.Services.Implementation;
|
||||
|
||||
namespace RMuseum.Services.Implementation
|
||||
{
|
||||
/// <summary>
|
||||
/// IGanjoorService implementation
|
||||
/// </summary>
|
||||
public partial class GanjoorService : IGanjoorService
|
||||
{
|
||||
/// <summary>
|
||||
/// modify page
|
||||
/// </summary>
|
||||
/// <param name="id"></param>
|
||||
/// <param name="editingUserId"></param>
|
||||
/// <param name="pageData"></param>
|
||||
/// <returns></returns>
|
||||
public async Task<RServiceResult<GanjoorPageCompleteViewModel>> UpdatePageAsync(int id, Guid editingUserId, GanjoorModifyPageViewModel pageData)
|
||||
{
|
||||
try
|
||||
{
|
||||
var dbPage = await _context.GanjoorPages.Where(p => p.Id == id).SingleOrDefaultAsync();
|
||||
if (dbPage == null)
|
||||
return new RServiceResult<GanjoorPageCompleteViewModel>(null);//not found
|
||||
|
||||
|
||||
|
||||
GanjoorPageSnapshot snapshot = new GanjoorPageSnapshot()
|
||||
{
|
||||
GanjoorPageId = id,
|
||||
MadeObsoleteByUserId = editingUserId,
|
||||
RecordDate = DateTime.Now,
|
||||
Note = pageData.Note,
|
||||
Title = dbPage.Title,
|
||||
UrlSlug = dbPage.UrlSlug,
|
||||
HtmlText = dbPage.HtmlText,
|
||||
};
|
||||
|
||||
GanjoorPoem dbPoem = null;
|
||||
|
||||
if (dbPage.GanjoorPageType == GanjoorPageType.PoemPage)
|
||||
{
|
||||
dbPoem = await _context.GanjoorPoems.Include(p => p.GanjoorMetre).Where(p => p.Id == id).SingleOrDefaultAsync();
|
||||
|
||||
snapshot.SourceName = dbPoem.SourceName;
|
||||
snapshot.SourceUrlSlug = dbPoem.SourceUrlSlug;
|
||||
snapshot.Rhythm = dbPoem.GanjoorMetre == null ? null : dbPoem.GanjoorMetre.Rhythm;
|
||||
snapshot.RhymeLetters = dbPoem.RhymeLetters;
|
||||
snapshot.OldTag = dbPoem.OldTag;
|
||||
snapshot.OldTagPageUrl = dbPoem.OldTagPageUrl;
|
||||
}
|
||||
|
||||
_context.GanjoorPageSnapshots.Add(snapshot);
|
||||
await _context.SaveChangesAsync();
|
||||
|
||||
dbPage.HtmlText = pageData.HtmlText;
|
||||
dbPage.NoIndex = pageData.NoIndex;
|
||||
dbPage.RedirectFromFullUrl = string.IsNullOrEmpty(pageData.RedirectFromFullUrl) ? null : pageData.RedirectFromFullUrl;
|
||||
bool messWithTitles = dbPage.Title != pageData.Title;
|
||||
bool messWithUrls = dbPage.UrlSlug != pageData.UrlSlug;
|
||||
|
||||
if (dbPage.GanjoorPageType == GanjoorPageType.CatPage || dbPage.GanjoorPageType == GanjoorPageType.PoetPage)
|
||||
{
|
||||
GanjoorCat cat = await _context.GanjoorCategories.Where(c => c.Id == dbPage.CatId).SingleAsync();
|
||||
cat.Published = pageData.Published;
|
||||
cat.MixedModeOrder = pageData.MixedModeOrder;
|
||||
cat.TableOfContentsStyle = pageData.TableOfContentsStyle;
|
||||
cat.CatType = pageData.CatType;
|
||||
cat.Description = pageData.Description;
|
||||
cat.DescriptionHtml = pageData.DescriptionHtml;
|
||||
|
||||
_context.GanjoorCategories.Update(cat);
|
||||
await _context.SaveChangesAsync();
|
||||
|
||||
if (dbPage.GanjoorPageType == GanjoorPageType.PoetPage)
|
||||
{
|
||||
var poet = await _context.GanjoorPoets.Where(p => p.Id == dbPage.PoetId).SingleAsync();
|
||||
poet.Description = cat.Description;
|
||||
_context.Update(poet);
|
||||
await _context.SaveChangesAsync();
|
||||
}
|
||||
}
|
||||
|
||||
if (messWithTitles || messWithUrls)
|
||||
{
|
||||
|
||||
dbPage.Title = pageData.Title;
|
||||
dbPage.UrlSlug = pageData.UrlSlug;
|
||||
|
||||
if (dbPage.ParentId != null)
|
||||
{
|
||||
GanjoorPage parent = await _context.GanjoorPages.AsNoTracking().Where(p => p.Id == dbPage.ParentId).SingleAsync();
|
||||
if (messWithUrls)
|
||||
{
|
||||
dbPage.FullUrl = parent.FullUrl + "/" + pageData.UrlSlug;
|
||||
}
|
||||
if (messWithTitles)
|
||||
{
|
||||
dbPage.FullTitle = parent.FullTitle + " » " + pageData.Title;
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
if (messWithUrls)
|
||||
{
|
||||
dbPage.FullUrl = "/" + pageData.UrlSlug;
|
||||
}
|
||||
|
||||
if (messWithTitles)
|
||||
{
|
||||
dbPage.FullTitle = pageData.Title;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
switch (dbPage.GanjoorPageType)
|
||||
{
|
||||
case GanjoorPageType.CatPage:
|
||||
{
|
||||
GanjoorCat cat = await _context.GanjoorCategories.Where(c => c.Id == dbPage.CatId).SingleAsync();
|
||||
if (messWithTitles)
|
||||
cat.Title = dbPage.Title;
|
||||
if (messWithUrls)
|
||||
{
|
||||
cat.UrlSlug = dbPage.UrlSlug;
|
||||
cat.FullUrl = dbPage.FullUrl;
|
||||
}
|
||||
|
||||
_context.GanjoorCategories.Update(cat);
|
||||
await _context.SaveChangesAsync();
|
||||
}
|
||||
break;
|
||||
}
|
||||
_backgroundTaskQueue.QueueBackgroundWorkItem
|
||||
(
|
||||
async token =>
|
||||
{
|
||||
using (RMuseumDbContext inlineContext = new RMuseumDbContext(new DbContextOptions<RMuseumDbContext>())) //this is long running job, so _context might be already been freed/collected by GC
|
||||
{
|
||||
LongRunningJobProgressServiceEF jobProgressServiceEF = new LongRunningJobProgressServiceEF(inlineContext);
|
||||
var job = (await jobProgressServiceEF.NewJob($"Updating PageChildren for {dbPage.Id}", "Updating")).Result;
|
||||
try
|
||||
{
|
||||
|
||||
|
||||
await _UpdatePageChildrenTitleAndUrl(inlineContext, dbPage, messWithTitles, messWithUrls);
|
||||
|
||||
await jobProgressServiceEF.UpdateJob(job.Id, 100, "", true);
|
||||
}
|
||||
catch (Exception expUpdateBatch)
|
||||
{
|
||||
await jobProgressServiceEF.UpdateJob(job.Id, 100, "", false, expUpdateBatch.ToString());
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
);
|
||||
|
||||
}
|
||||
|
||||
if (dbPage.GanjoorPageType == GanjoorPageType.PoetPage && (messWithTitles || messWithUrls))
|
||||
{
|
||||
if (messWithTitles)
|
||||
{
|
||||
GanjoorPoet poet = await _context.GanjoorPoets.Where(p => p.Id == dbPage.PoetId).SingleAsync();
|
||||
poet.Nickname = dbPage.Title;
|
||||
//poet.Description = dbPage.HtmlText; -- description might become html free
|
||||
_context.GanjoorPoets.Update(poet);
|
||||
}
|
||||
|
||||
|
||||
GanjoorCat cat = await _context.GanjoorCategories.Where(c => c.Id == dbPage.CatId).SingleAsync();
|
||||
if (messWithTitles)
|
||||
{
|
||||
cat.Title = dbPage.Title;
|
||||
}
|
||||
if (messWithUrls)
|
||||
{
|
||||
cat.UrlSlug = dbPage.UrlSlug;
|
||||
cat.FullUrl = dbPage.FullUrl;
|
||||
}
|
||||
|
||||
|
||||
_context.GanjoorCategories.Update(cat);
|
||||
|
||||
await _context.SaveChangesAsync();
|
||||
|
||||
CleanPoetCache((int)dbPage.PoetId);
|
||||
}
|
||||
|
||||
_context.GanjoorPages.Update(dbPage);
|
||||
|
||||
if (dbPoem != null)
|
||||
{
|
||||
dbPoem.SourceName = pageData.SourceName;
|
||||
dbPoem.SourceUrlSlug = pageData.SourceUrlSlug;
|
||||
int? oldMetreId = dbPoem.GanjoorMetreId;
|
||||
string oldRhymeLetters = dbPoem.RhymeLetters;
|
||||
if (string.IsNullOrEmpty(pageData.Rhythm))
|
||||
{
|
||||
dbPoem.GanjoorMetreId = null;
|
||||
}
|
||||
else
|
||||
{
|
||||
var metre = await _context.GanjoorMetres.Where(m => m.Rhythm == pageData.Rhythm).SingleOrDefaultAsync();
|
||||
if (metre == null)
|
||||
{
|
||||
metre = new GanjoorMetre()
|
||||
{
|
||||
Rhythm = pageData.Rhythm,
|
||||
VerseCount = 0
|
||||
};
|
||||
_context.GanjoorMetres.Add(metre);
|
||||
await _context.SaveChangesAsync();
|
||||
}
|
||||
dbPoem.GanjoorMetreId = metre.Id;
|
||||
}
|
||||
dbPoem.RhymeLetters = pageData.RhymeLetters;
|
||||
dbPoem.OldTag = pageData.OldTag;
|
||||
dbPoem.OldTagPageUrl = pageData.OldTagPageUrl;
|
||||
dbPoem.MixedModeOrder = pageData.MixedModeOrder;
|
||||
dbPoem.Language = pageData.Language;
|
||||
dbPoem.Published = pageData.Published;
|
||||
|
||||
|
||||
dbPoem.HtmlText = pageData.HtmlText;
|
||||
dbPoem.Title = pageData.Title;
|
||||
dbPoem.UrlSlug = pageData.UrlSlug;
|
||||
dbPoem.FullUrl = dbPage.FullUrl;
|
||||
dbPoem.FullTitle = dbPoem.FullTitle;
|
||||
|
||||
List<GanjoorVerse> verses = _extractVersesFromPoemHtmlText(id, pageData.HtmlText);
|
||||
|
||||
dbPoem.PlainText = PreparePlainText(verses);
|
||||
|
||||
_context.GanjoorPoems.Update(dbPoem);
|
||||
|
||||
|
||||
var oldVerses = await _context.GanjoorVerses.Where(v => v.PoemId == id).ToListAsync();
|
||||
|
||||
if (oldVerses.Count <= verses.Count)
|
||||
{
|
||||
for (int v = 0; v < oldVerses.Count; v++)
|
||||
{
|
||||
oldVerses[v].Text = verses[v].Text;
|
||||
oldVerses[v].VersePosition = verses[v].VersePosition;
|
||||
oldVerses[v].VOrder = verses[v].VOrder;
|
||||
_context.GanjoorVerses.Update(oldVerses[v]);
|
||||
}
|
||||
|
||||
for (int v = oldVerses.Count; v < verses.Count; v++)
|
||||
{
|
||||
_context.GanjoorVerses.Add(verses[v]);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
for (int v = 0; v < verses.Count; v++)
|
||||
{
|
||||
oldVerses[v].Text = verses[v].Text;
|
||||
oldVerses[v].VersePosition = verses[v].VersePosition;
|
||||
oldVerses[v].VOrder = verses[v].VOrder;
|
||||
_context.GanjoorVerses.Update(oldVerses[v]);
|
||||
}
|
||||
|
||||
for (int v = verses.Count; v < oldVerses.Count; v++)
|
||||
{
|
||||
_context.GanjoorVerses.Remove(oldVerses[v]);
|
||||
}
|
||||
}
|
||||
|
||||
await _FillPoemCoupletIndices(_context, id);
|
||||
|
||||
var excerptsInRelatedCaches = await _context.GanjoorCachedRelatedPoems.Where(p => p.FullUrl == dbPoem.FullUrl).ToListAsync();
|
||||
if (excerptsInRelatedCaches.Count > 0)
|
||||
{
|
||||
var newExcerpt = GetPoemHtmlExcerpt(dbPoem.HtmlText);
|
||||
foreach (var excerptsInRelatedCache in excerptsInRelatedCaches)
|
||||
{
|
||||
excerptsInRelatedCache.HtmlExcerpt = newExcerpt;
|
||||
}
|
||||
_context.GanjoorCachedRelatedPoems.UpdateRange(excerptsInRelatedCaches);
|
||||
}
|
||||
|
||||
if (oldMetreId != dbPoem.GanjoorMetreId || oldRhymeLetters != dbPoem.RhymeLetters)
|
||||
{
|
||||
await _context.SaveChangesAsync();
|
||||
|
||||
_backgroundTaskQueue.QueueBackgroundWorkItem
|
||||
(
|
||||
async token =>
|
||||
{
|
||||
using (RMuseumDbContext inlineContext = new RMuseumDbContext(new DbContextOptions<RMuseumDbContext>())) //this is long running job, so _context might be already been freed/collected by GC
|
||||
{
|
||||
if (oldMetreId != null && !string.IsNullOrEmpty(oldRhymeLetters))
|
||||
{
|
||||
await _UpdateRelatedPoems(inlineContext, (int)oldMetreId, oldRhymeLetters);
|
||||
await inlineContext.SaveChangesAsync();
|
||||
}
|
||||
|
||||
if (dbPoem.GanjoorMetreId != null && !string.IsNullOrEmpty(dbPoem.RhymeLetters))
|
||||
{
|
||||
await _UpdateRelatedPoems(inlineContext, (int)dbPoem.GanjoorMetreId, dbPoem.RhymeLetters);
|
||||
await inlineContext.SaveChangesAsync();
|
||||
}
|
||||
}
|
||||
});
|
||||
}
|
||||
}
|
||||
await _context.SaveChangesAsync();
|
||||
CacheCleanForPageByUrl(dbPage.FullUrl);
|
||||
|
||||
|
||||
return await GetPageByUrl(dbPage.FullUrl);
|
||||
}
|
||||
catch (Exception exp)
|
||||
{
|
||||
return new RServiceResult<GanjoorPageCompleteViewModel>(null, exp.ToString());
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -2442,317 +2442,6 @@ namespace RMuseum.Services.Implementation
|
||||
await context.SaveChangesAsync();
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// modify page
|
||||
/// </summary>
|
||||
/// <param name="id"></param>
|
||||
/// <param name="editingUserId"></param>
|
||||
/// <param name="pageData"></param>
|
||||
/// <returns></returns>
|
||||
public async Task<RServiceResult<GanjoorPageCompleteViewModel>> UpdatePageAsync(int id, Guid editingUserId, GanjoorModifyPageViewModel pageData)
|
||||
{
|
||||
try
|
||||
{
|
||||
var dbPage = await _context.GanjoorPages.Where(p => p.Id == id).SingleOrDefaultAsync();
|
||||
if (dbPage == null)
|
||||
return new RServiceResult<GanjoorPageCompleteViewModel>(null);//not found
|
||||
|
||||
|
||||
|
||||
GanjoorPageSnapshot snapshot = new GanjoorPageSnapshot()
|
||||
{
|
||||
GanjoorPageId = id,
|
||||
MadeObsoleteByUserId = editingUserId,
|
||||
RecordDate = DateTime.Now,
|
||||
Note = pageData.Note,
|
||||
Title = dbPage.Title,
|
||||
UrlSlug = dbPage.UrlSlug,
|
||||
HtmlText = dbPage.HtmlText,
|
||||
};
|
||||
|
||||
GanjoorPoem dbPoem = null;
|
||||
|
||||
if (dbPage.GanjoorPageType == GanjoorPageType.PoemPage)
|
||||
{
|
||||
dbPoem = await _context.GanjoorPoems.Include(p => p.GanjoorMetre).Where(p => p.Id == id).SingleOrDefaultAsync();
|
||||
|
||||
snapshot.SourceName = dbPoem.SourceName;
|
||||
snapshot.SourceUrlSlug = dbPoem.SourceUrlSlug;
|
||||
snapshot.Rhythm = dbPoem.GanjoorMetre == null ? null : dbPoem.GanjoorMetre.Rhythm;
|
||||
snapshot.RhymeLetters = dbPoem.RhymeLetters;
|
||||
snapshot.OldTag = dbPoem.OldTag;
|
||||
snapshot.OldTagPageUrl = dbPoem.OldTagPageUrl;
|
||||
}
|
||||
|
||||
_context.GanjoorPageSnapshots.Add(snapshot);
|
||||
await _context.SaveChangesAsync();
|
||||
|
||||
dbPage.HtmlText = pageData.HtmlText;
|
||||
dbPage.NoIndex = pageData.NoIndex;
|
||||
dbPage.RedirectFromFullUrl = string.IsNullOrEmpty(pageData.RedirectFromFullUrl) ? null : pageData.RedirectFromFullUrl;
|
||||
bool messWithTitles = dbPage.Title != pageData.Title;
|
||||
bool messWithUrls = dbPage.UrlSlug != pageData.UrlSlug;
|
||||
|
||||
if(dbPage.GanjoorPageType == GanjoorPageType.CatPage || dbPage.GanjoorPageType == GanjoorPageType.PoetPage)
|
||||
{
|
||||
GanjoorCat cat = await _context.GanjoorCategories.Where(c => c.Id == dbPage.CatId).SingleAsync();
|
||||
cat.Published = pageData.Published;
|
||||
cat.MixedModeOrder = pageData.MixedModeOrder;
|
||||
cat.TableOfContentsStyle = pageData.TableOfContentsStyle;
|
||||
cat.CatType = pageData.CatType;
|
||||
cat.Description = pageData.Description;
|
||||
cat.DescriptionHtml = pageData.DescriptionHtml;
|
||||
|
||||
_context.GanjoorCategories.Update(cat);
|
||||
await _context.SaveChangesAsync();
|
||||
|
||||
if (dbPage.GanjoorPageType == GanjoorPageType.PoetPage)
|
||||
{
|
||||
var poet = await _context.GanjoorPoets.Where(p => p.Id == dbPage.PoetId).SingleAsync();
|
||||
poet.Description = cat.Description;
|
||||
_context.Update(poet);
|
||||
await _context.SaveChangesAsync();
|
||||
}
|
||||
}
|
||||
|
||||
if (messWithTitles || messWithUrls)
|
||||
{
|
||||
|
||||
dbPage.Title = pageData.Title;
|
||||
dbPage.UrlSlug = pageData.UrlSlug;
|
||||
|
||||
if (dbPage.ParentId != null)
|
||||
{
|
||||
GanjoorPage parent = await _context.GanjoorPages.AsNoTracking().Where(p => p.Id == dbPage.ParentId).SingleAsync();
|
||||
if (messWithUrls)
|
||||
{
|
||||
dbPage.FullUrl = parent.FullUrl + "/" + pageData.UrlSlug;
|
||||
}
|
||||
if (messWithTitles)
|
||||
{
|
||||
dbPage.FullTitle = parent.FullTitle + " » " + pageData.Title;
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
if (messWithUrls)
|
||||
{
|
||||
dbPage.FullUrl = "/" + pageData.UrlSlug;
|
||||
}
|
||||
|
||||
if (messWithTitles)
|
||||
{
|
||||
dbPage.FullTitle = pageData.Title;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
switch (dbPage.GanjoorPageType)
|
||||
{
|
||||
case GanjoorPageType.CatPage:
|
||||
{
|
||||
GanjoorCat cat = await _context.GanjoorCategories.Where(c => c.Id == dbPage.CatId).SingleAsync();
|
||||
if (messWithTitles)
|
||||
cat.Title = dbPage.Title;
|
||||
if (messWithUrls)
|
||||
{
|
||||
cat.UrlSlug = dbPage.UrlSlug;
|
||||
cat.FullUrl = dbPage.FullUrl;
|
||||
}
|
||||
|
||||
_context.GanjoorCategories.Update(cat);
|
||||
await _context.SaveChangesAsync();
|
||||
}
|
||||
break;
|
||||
}
|
||||
_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($"Updating PageChildren for {dbPage.Id}", "Updating")).Result;
|
||||
try
|
||||
{
|
||||
|
||||
|
||||
await _UpdatePageChildrenTitleAndUrl(context, dbPage, messWithTitles, messWithUrls);
|
||||
|
||||
await jobProgressServiceEF.UpdateJob(job.Id, 100, "", true);
|
||||
}
|
||||
catch (Exception expUpdateBatch)
|
||||
{
|
||||
await jobProgressServiceEF.UpdateJob(job.Id, 100, "", false, expUpdateBatch.ToString());
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
);
|
||||
|
||||
}
|
||||
|
||||
if (dbPage.GanjoorPageType == GanjoorPageType.PoetPage && (messWithTitles || messWithUrls))
|
||||
{
|
||||
if (messWithTitles)
|
||||
{
|
||||
GanjoorPoet poet = await _context.GanjoorPoets.Where(p => p.Id == dbPage.PoetId).SingleAsync();
|
||||
poet.Nickname = dbPage.Title;
|
||||
//poet.Description = dbPage.HtmlText; -- description might become html free
|
||||
_context.GanjoorPoets.Update(poet);
|
||||
}
|
||||
|
||||
|
||||
GanjoorCat cat = await _context.GanjoorCategories.Where(c => c.Id == dbPage.CatId).SingleAsync();
|
||||
if (messWithTitles)
|
||||
{
|
||||
cat.Title = dbPage.Title;
|
||||
}
|
||||
if (messWithUrls)
|
||||
{
|
||||
cat.UrlSlug = dbPage.UrlSlug;
|
||||
cat.FullUrl = dbPage.FullUrl;
|
||||
}
|
||||
|
||||
|
||||
_context.GanjoorCategories.Update(cat);
|
||||
|
||||
await _context.SaveChangesAsync();
|
||||
|
||||
CleanPoetCache((int)dbPage.PoetId);
|
||||
}
|
||||
|
||||
_context.GanjoorPages.Update(dbPage);
|
||||
|
||||
if (dbPoem != null)
|
||||
{
|
||||
dbPoem.SourceName = pageData.SourceName;
|
||||
dbPoem.SourceUrlSlug = pageData.SourceUrlSlug;
|
||||
int? oldMetreId = dbPoem.GanjoorMetreId;
|
||||
string oldRhymeLetters = dbPoem.RhymeLetters;
|
||||
if (string.IsNullOrEmpty(pageData.Rhythm))
|
||||
{
|
||||
dbPoem.GanjoorMetreId = null;
|
||||
}
|
||||
else
|
||||
{
|
||||
var metre = await _context.GanjoorMetres.Where(m => m.Rhythm == pageData.Rhythm).SingleOrDefaultAsync();
|
||||
if (metre == null)
|
||||
{
|
||||
metre = new GanjoorMetre()
|
||||
{
|
||||
Rhythm = pageData.Rhythm,
|
||||
VerseCount = 0
|
||||
};
|
||||
_context.GanjoorMetres.Add(metre);
|
||||
await _context.SaveChangesAsync();
|
||||
}
|
||||
dbPoem.GanjoorMetreId = metre.Id;
|
||||
}
|
||||
dbPoem.RhymeLetters = pageData.RhymeLetters;
|
||||
dbPoem.OldTag = pageData.OldTag;
|
||||
dbPoem.OldTagPageUrl = pageData.OldTagPageUrl;
|
||||
dbPoem.MixedModeOrder = pageData.MixedModeOrder;
|
||||
dbPoem.Language = pageData.Language;
|
||||
dbPoem.Published = pageData.Published;
|
||||
|
||||
|
||||
dbPoem.HtmlText = pageData.HtmlText;
|
||||
dbPoem.Title = pageData.Title;
|
||||
dbPoem.UrlSlug = pageData.UrlSlug;
|
||||
dbPoem.FullUrl = dbPage.FullUrl;
|
||||
dbPoem.FullTitle = dbPoem.FullTitle;
|
||||
|
||||
List<GanjoorVerse> verses = _extractVersesFromPoemHtmlText(id, pageData.HtmlText);
|
||||
|
||||
dbPoem.PlainText = PreparePlainText(verses);
|
||||
|
||||
_context.GanjoorPoems.Update(dbPoem);
|
||||
|
||||
|
||||
var oldVerses = await _context.GanjoorVerses.Where(v => v.PoemId == id).ToListAsync();
|
||||
|
||||
if (oldVerses.Count <= verses.Count)
|
||||
{
|
||||
for (int v = 0; v < oldVerses.Count; v++)
|
||||
{
|
||||
oldVerses[v].Text = verses[v].Text;
|
||||
oldVerses[v].VersePosition = verses[v].VersePosition;
|
||||
oldVerses[v].VOrder = verses[v].VOrder;
|
||||
_context.GanjoorVerses.Update(oldVerses[v]);
|
||||
}
|
||||
|
||||
for (int v = oldVerses.Count; v < verses.Count; v++)
|
||||
{
|
||||
_context.GanjoorVerses.Add(verses[v]);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
for (int v = 0; v < verses.Count; v++)
|
||||
{
|
||||
oldVerses[v].Text = verses[v].Text;
|
||||
oldVerses[v].VersePosition = verses[v].VersePosition;
|
||||
oldVerses[v].VOrder = verses[v].VOrder;
|
||||
_context.GanjoorVerses.Update(oldVerses[v]);
|
||||
}
|
||||
|
||||
for (int v = verses.Count; v < oldVerses.Count; v++)
|
||||
{
|
||||
_context.GanjoorVerses.Remove(oldVerses[v]);
|
||||
}
|
||||
}
|
||||
|
||||
await _FillPoemCoupletIndices(_context, id);
|
||||
|
||||
var excerptsInRelatedCaches = await _context.GanjoorCachedRelatedPoems.Where(p => p.FullUrl == dbPoem.FullUrl).ToListAsync();
|
||||
if (excerptsInRelatedCaches.Count > 0)
|
||||
{
|
||||
var newExcerpt = GetPoemHtmlExcerpt(dbPoem.HtmlText);
|
||||
foreach (var excerptsInRelatedCache in excerptsInRelatedCaches)
|
||||
{
|
||||
excerptsInRelatedCache.HtmlExcerpt = newExcerpt;
|
||||
}
|
||||
_context.GanjoorCachedRelatedPoems.UpdateRange(excerptsInRelatedCaches);
|
||||
}
|
||||
|
||||
if (oldMetreId != dbPoem.GanjoorMetreId || oldRhymeLetters != dbPoem.RhymeLetters)
|
||||
{
|
||||
await _context.SaveChangesAsync();
|
||||
|
||||
_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
|
||||
{
|
||||
if (oldMetreId != null && !string.IsNullOrEmpty(oldRhymeLetters))
|
||||
{
|
||||
await _UpdateRelatedPoems(context, (int)oldMetreId, oldRhymeLetters);
|
||||
await context.SaveChangesAsync();
|
||||
}
|
||||
|
||||
if (dbPoem.GanjoorMetreId != null && !string.IsNullOrEmpty(dbPoem.RhymeLetters))
|
||||
{
|
||||
await _UpdateRelatedPoems(context, (int)dbPoem.GanjoorMetreId, dbPoem.RhymeLetters);
|
||||
await context.SaveChangesAsync();
|
||||
}
|
||||
}
|
||||
});
|
||||
}
|
||||
}
|
||||
await _context.SaveChangesAsync();
|
||||
CacheCleanForPageByUrl(dbPage.FullUrl);
|
||||
|
||||
|
||||
return await GetPageByUrl(dbPage.FullUrl);
|
||||
}
|
||||
catch (Exception exp)
|
||||
{
|
||||
return new RServiceResult<GanjoorPageCompleteViewModel>(null, exp.ToString());
|
||||
}
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// return page modifications history
|
||||
/// </summary>
|
||||
|
||||
Loading…
Reference in New Issue
Block a user