| | | 1 | | using Newtonsoft.Json; |
| | | 2 | | using Services.HangfireService.Models; |
| | | 3 | | |
| | | 4 | | namespace OzonOrdersWeb.WebServices.Hangfire; |
| | | 5 | | |
| | | 6 | | /// <summary>Строка грида очереди Hangfire: аргументы уже сериализованы, длительность — в миллисекундах.</summary> |
| | 2 | 7 | | public sealed record HangfireJobGridRow( |
| | 0 | 8 | | string? Id, |
| | 0 | 9 | | string? Method, |
| | 0 | 10 | | string? State, |
| | 0 | 11 | | string? ServerId, |
| | 0 | 12 | | DateTime? EnqueuedAt, |
| | 0 | 13 | | DateTime? StartedAt, |
| | 0 | 14 | | DateTime? SucceededAt, |
| | 0 | 15 | | DateTime? DeletedAt, |
| | 2 | 16 | | long? DurationMs, |
| | 1 | 17 | | string? Args, |
| | 3 | 18 | | string? Result); |
| | | 19 | | |
| | | 20 | | /// <summary>Вкладки очереди Hangfire (В очереди / Выполняются / Выполненные / Удалённые) → строки гридов.</summary> |
| | | 21 | | public static class HangfireJobGridRows |
| | | 22 | | { |
| | | 23 | | public const string Enqueued = "enqueued"; |
| | | 24 | | public const string Processing = "processing"; |
| | | 25 | | public const string Succeeded = "succeeded"; |
| | | 26 | | public const string Deleted = "deleted"; |
| | | 27 | | |
| | | 28 | | /// <summary> |
| | | 29 | | /// Для выполняющихся длительность считается от StartedAt до <paramref name="nowUtc"/>; для выполненных — из Hangfir |
| | | 30 | | /// </summary> |
| | | 31 | | public static List<HangfireJobGridRow> Build(string kind, IEnumerable<JobDto>? jobs, DateTime nowUtc) => |
| | | 32 | | (jobs ?? []).Select(j => new HangfireJobGridRow( |
| | | 33 | | j.Id, |
| | | 34 | | j.MethodName, |
| | | 35 | | j.State, |
| | | 36 | | j.ServerId, |
| | | 37 | | j.EnqueuedAt, |
| | | 38 | | j.StartedAt, |
| | | 39 | | j.SucceededAt, |
| | | 40 | | j.DeletedAt, |
| | | 41 | | kind == Processing |
| | | 42 | | ? (long)Math.Max(0, (nowUtc - (j.StartedAt ?? nowUtc)).TotalMilliseconds) |
| | | 43 | | : j.Duration, |
| | | 44 | | j.Args != null ? JsonConvert.SerializeObject(j.Args, Formatting.Indented) : null, |
| | | 45 | | string.IsNullOrEmpty(j.Result) ? null : j.Result)) |
| | | 46 | | .ToList(); |
| | | 47 | | } |