forked from ddrilling/AsbCloudServer
99 lines
3.5 KiB
C#
99 lines
3.5 KiB
C#
using AsbCloudApp.Data;
|
||
using System;
|
||
using System.Threading;
|
||
using System.Threading.Tasks;
|
||
|
||
namespace AsbCloudInfrastructure.Background;
|
||
|
||
/// <summary>
|
||
/// Класс разовой работы.
|
||
/// Разовая работа приоритетнее периодической.
|
||
/// </summary>
|
||
public abstract class Work : BackgroundWorkDto
|
||
{
|
||
private sealed class WorkBase : Work
|
||
{
|
||
private Func<string, IServiceProvider, Action<string, double?>, CancellationToken, Task> ActionAsync { get; }
|
||
public WorkBase(string id, Func<string, IServiceProvider, Action<string, double?>, CancellationToken, Task> actionAsync)
|
||
: base(id)
|
||
{
|
||
ActionAsync = actionAsync;
|
||
}
|
||
|
||
protected override Task Action(string id, IServiceProvider services, Action<string, double?> onProgressCallback, CancellationToken token)
|
||
=> ActionAsync(id, services, onProgressCallback, token);
|
||
}
|
||
|
||
/// <summary>
|
||
/// Делегат обработки ошибки.
|
||
/// Не должен выполняться долго.
|
||
/// </summary>
|
||
public Func<string, Exception, CancellationToken, Task>? OnErrorAsync { get; set; }
|
||
|
||
/// <summary>
|
||
/// макс продолжительность обработки исключения
|
||
/// </summary>
|
||
public TimeSpan OnErrorHandlerTimeout { get; set; } = TimeSpan.FromSeconds(5);
|
||
|
||
/// <summary>
|
||
/// Базовая работа
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
public Work(string id)
|
||
{
|
||
Id = id;
|
||
}
|
||
|
||
/// <summary>
|
||
/// Создать работу на основе делегата
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <param name="actionAsync"></param>
|
||
/// <returns></returns>
|
||
[Obsolete("Use implement Work class")]
|
||
public static Work CreateByDelegate(string id, Func<string, IServiceProvider, Action<string, double?>, CancellationToken, Task> actionAsync)
|
||
{
|
||
return new WorkBase(id, actionAsync);
|
||
}
|
||
|
||
/// <summary>
|
||
/// Запустить работу
|
||
/// </summary>
|
||
/// <param name="services"></param>
|
||
/// <param name="token"></param>
|
||
/// <returns>True - success, False = fail</returns>
|
||
public async Task<bool> Start(IServiceProvider services, CancellationToken token)
|
||
{
|
||
SetStatusStart();
|
||
try
|
||
{
|
||
var task = Action(Id, services, UpdateStatus, token);
|
||
await task.WaitAsync(Timeout, token);
|
||
SetStatusComplete();
|
||
return true;
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
SetLastError(exception.Message);
|
||
if (OnErrorAsync is not null)
|
||
{
|
||
var task = Task.Run(
|
||
async () => await OnErrorAsync(Id, exception, token),
|
||
token);
|
||
await task.WaitAsync(OnErrorHandlerTimeout, token);
|
||
}
|
||
}
|
||
return false;
|
||
}
|
||
|
||
/// <summary>
|
||
/// делегат фоновой работы
|
||
/// </summary>
|
||
/// <param name="id">Идентификатор работы</param>
|
||
/// <param name="services">Поставщик сервисов</param>
|
||
/// <param name="onProgressCallback">on progress callback. String - new state text. double? - optional progress 0-100%</param>
|
||
/// <param name="token"></param>
|
||
/// <returns></returns>
|
||
protected abstract Task Action(string id, IServiceProvider services, Action<string, double?> onProgressCallback, CancellationToken token);
|
||
}
|