docs: #361 calling UploadArtifactToExternalServer

This commit is contained in:
Hamid Reza Mohammadi 2023-01-16 21:28:28 +03:30
parent 20af6ea1ca
commit 087bc7e671
12 changed files with 166 additions and 1 deletions

View File

@ -13607,6 +13607,14 @@
<param name="resourcePrefix"></param>
<returns></returns>
</member>
<member name="M:RMuseum.Services.Implementation.ArtifactService.UploadArtifactToExternalServer(RMuseum.Models.Artifact.RArtifactMasterRecord,RMuseum.DbContext.RMuseumDbContext)">
<summary>
upload artifact to external server
</summary>
<param name="book"></param>
<param name="context"></param>
<returns></returns>
</member>
<member name="M:RMuseum.Services.Implementation.ArtifactService.RescheduleJobs(RMuseum.Models.ImportJob.JobType)">
<summary>
reschedule jobs

View File

@ -152,6 +152,19 @@ namespace RMuseum.Services.Implementation
await context.Artifacts.AddAsync(book);
await context.SaveChangesAsync();
var resFTPUpload = await UploadArtifactToExternalServer(book, context);
if (!string.IsNullOrEmpty(resFTPUpload.ExceptionString))
{
job.EndTime = DateTime.Now;
job.Status = ImportJobStatus.Failed;
job.Exception = $"UploadArtifactToExternalServer: {resFTPUpload.ExceptionString}";
job.ArtifactId = book.Id;
job.EndTime = DateTime.Now;
context.Update(job);
await context.SaveChangesAsync();
return;
}
job.ProgressPercent = 100;
job.Status = ImportJobStatus.Succeeded;
job.ArtifactId = book.Id;

View File

@ -641,6 +641,19 @@ namespace RMuseum.Services.Implementation
await context.Artifacts.AddAsync(book);
await context.SaveChangesAsync();
var resFTPUpload = await UploadArtifactToExternalServer(book, context);
if (!string.IsNullOrEmpty(resFTPUpload.ExceptionString))
{
job.EndTime = DateTime.Now;
job.Status = ImportJobStatus.Failed;
job.Exception = $"UploadArtifactToExternalServer: {resFTPUpload.ExceptionString}";
job.ArtifactId = book.Id;
job.EndTime = DateTime.Now;
context.Update(job);
await context.SaveChangesAsync();
return;
}
job.ProgressPercent = 100;
job.Status = ImportJobStatus.Succeeded;
job.ArtifactId = book.Id;

View File

@ -433,6 +433,19 @@ namespace RMuseum.Services.Implementation
await context.Artifacts.AddAsync(book);
await context.SaveChangesAsync();
var resFTPUpload = await UploadArtifactToExternalServer(book, context);
if (!string.IsNullOrEmpty(resFTPUpload.ExceptionString))
{
job.EndTime = DateTime.Now;
job.Status = ImportJobStatus.Failed;
job.Exception = $"UploadArtifactToExternalServer: {resFTPUpload.ExceptionString}";
job.ArtifactId = book.Id;
job.EndTime = DateTime.Now;
context.Update(job);
await context.SaveChangesAsync();
return;
}
job.ProgressPercent = 100;
job.Status = ImportJobStatus.Succeeded;
job.ArtifactId = book.Id;

View File

@ -328,6 +328,19 @@ namespace RMuseum.Services.Implementation
await context.Artifacts.AddAsync(book);
await context.SaveChangesAsync();
var resFTPUpload = await UploadArtifactToExternalServer(book, context);
if (!string.IsNullOrEmpty(resFTPUpload.ExceptionString))
{
job.EndTime = DateTime.Now;
job.Status = ImportJobStatus.Failed;
job.Exception = $"UploadArtifactToExternalServer: {resFTPUpload.ExceptionString}";
job.ArtifactId = book.Id;
job.EndTime = DateTime.Now;
context.Update(job);
await context.SaveChangesAsync();
return;
}
job.ProgressPercent = 100;
job.Status = ImportJobStatus.Succeeded;
job.ArtifactId = book.Id;

View File

@ -213,6 +213,20 @@ namespace RMuseum.Services.Implementation
await context.Artifacts.AddAsync(book);
await context.SaveChangesAsync();
var resFTPUpload = await UploadArtifactToExternalServer(book, context);
if (!string.IsNullOrEmpty(resFTPUpload.ExceptionString))
{
job.EndTime = DateTime.Now;
job.Status = ImportJobStatus.Failed;
job.Exception = $"UploadArtifactToExternalServer: {resFTPUpload.ExceptionString}";
job.ArtifactId = book.Id;
job.EndTime = DateTime.Now;
context.Update(job);
await context.SaveChangesAsync();
return;
}
job.ProgressPercent = 100;
job.Status = ImportJobStatus.Succeeded;
job.ArtifactId = book.Id;

View File

@ -466,6 +466,19 @@ namespace RMuseum.Services.Implementation
await context.Artifacts.AddAsync(book);
await context.SaveChangesAsync();
var resFTPUpload = await UploadArtifactToExternalServer(book, context);
if (!string.IsNullOrEmpty(resFTPUpload.ExceptionString))
{
job.EndTime = DateTime.Now;
job.Status = ImportJobStatus.Failed;
job.Exception = $"UploadArtifactToExternalServer: {resFTPUpload.ExceptionString}";
job.ArtifactId = book.Id;
job.EndTime = DateTime.Now;
context.Update(job);
await context.SaveChangesAsync();
return;
}
job.ProgressPercent = 100;
job.Status = ImportJobStatus.Succeeded;
job.ArtifactId = book.Id;

View File

@ -478,6 +478,19 @@ namespace RMuseum.Services.Implementation
await context.Artifacts.AddAsync(book);
await context.SaveChangesAsync();
var resFTPUpload = await UploadArtifactToExternalServer(book, context);
if (!string.IsNullOrEmpty(resFTPUpload.ExceptionString))
{
job.EndTime = DateTime.Now;
job.Status = ImportJobStatus.Failed;
job.Exception = $"UploadArtifactToExternalServer: {resFTPUpload.ExceptionString}";
job.ArtifactId = book.Id;
job.EndTime = DateTime.Now;
context.Update(job);
await context.SaveChangesAsync();
return;
}
job.ProgressPercent = 100;
job.Status = ImportJobStatus.Succeeded;
job.ArtifactId = book.Id;

View File

@ -446,6 +446,19 @@ namespace RMuseum.Services.Implementation
await context.Artifacts.AddAsync(book);
await context.SaveChangesAsync();
var resFTPUpload = await UploadArtifactToExternalServer(book, context);
if (!string.IsNullOrEmpty(resFTPUpload.ExceptionString))
{
job.EndTime = DateTime.Now;
job.Status = ImportJobStatus.Failed;
job.Exception = $"UploadArtifactToExternalServer: {resFTPUpload.ExceptionString}";
job.ArtifactId = book.Id;
job.EndTime = DateTime.Now;
context.Update(job);
await context.SaveChangesAsync();
return;
}
job.ProgressPercent = 100;
job.Status = ImportJobStatus.Succeeded;
job.ArtifactId = book.Id;

View File

@ -138,6 +138,19 @@ namespace RMuseum.Services.Implementation
await context.Artifacts.AddAsync(book);
await context.SaveChangesAsync();
var resFTPUpload = await UploadArtifactToExternalServer(book, context);
if (!string.IsNullOrEmpty(resFTPUpload.ExceptionString))
{
job.EndTime = DateTime.Now;
job.Status = ImportJobStatus.Failed;
job.Exception = $"UploadArtifactToExternalServer: {resFTPUpload.ExceptionString}";
job.ArtifactId = book.Id;
job.EndTime = DateTime.Now;
context.Update(job);
await context.SaveChangesAsync();
return;
}
job.ProgressPercent = 100;
job.Status = ImportJobStatus.Succeeded;
job.ArtifactId = book.Id;
@ -230,12 +243,25 @@ namespace RMuseum.Services.Implementation
pages.InsertRange(0, book.Items);
book.Items = pages.ToArray();//TODO: check if this is correct
book.Items = pages.ToArray();
book.ItemCount = pages.Count;
context.Update(book);
await context.SaveChangesAsync();
var resFTPUpload = await UploadArtifactToExternalServer(book, context);
if (!string.IsNullOrEmpty(resFTPUpload.ExceptionString))
{
job.EndTime = DateTime.Now;
job.Status = ImportJobStatus.Failed;
job.Exception = $"UploadArtifactToExternalServer: {resFTPUpload.ExceptionString}";
job.ArtifactId = book.Id;
job.EndTime = DateTime.Now;
context.Update(job);
await context.SaveChangesAsync();
return;
}
job.ProgressPercent = 100;
job.Status = ImportJobStatus.Succeeded;
job.ArtifactId = book.Id;

View File

@ -432,6 +432,19 @@ namespace RMuseum.Services.Implementation
await context.Artifacts.AddAsync(book);
await context.SaveChangesAsync();
var resFTPUpload = await UploadArtifactToExternalServer(book, context);
if (!string.IsNullOrEmpty(resFTPUpload.ExceptionString))
{
job.EndTime = DateTime.Now;
job.Status = ImportJobStatus.Failed;
job.Exception = $"UploadArtifactToExternalServer: {resFTPUpload.ExceptionString}";
job.ArtifactId = book.Id;
job.EndTime = DateTime.Now;
context.Update(job);
await context.SaveChangesAsync();
return;
}
job.ProgressPercent = 100;
job.Status = ImportJobStatus.Succeeded;
job.ArtifactId = book.Id;

View File

@ -423,6 +423,19 @@ namespace RMuseum.Services.Implementation
await context.Artifacts.AddAsync(book);
await context.SaveChangesAsync();
var resFTPUpload = await UploadArtifactToExternalServer(book, context);
if(!string.IsNullOrEmpty(resFTPUpload.ExceptionString))
{
job.EndTime = DateTime.Now;
job.Status = ImportJobStatus.Failed;
job.Exception = $"UploadArtifactToExternalServer: {resFTPUpload.ExceptionString}";
job.ArtifactId = book.Id;
job.EndTime = DateTime.Now;
context.Update(job);
await context.SaveChangesAsync();
return;
}
job.ProgressPercent = 100;
job.Status = ImportJobStatus.Succeeded;
job.ArtifactId = book.Id;