| | | 1 | | using Hangfire; |
| | | 2 | | using Hangfire.Storage; |
| | | 3 | | using Services.HangfireService.Models; |
| | | 4 | | |
| | | 5 | | namespace Services.HangfireService; |
| | | 6 | | |
| | | 7 | | public class HangfireService : IHangfireService |
| | | 8 | | { |
| | | 9 | | private readonly IMonitoringApi _monitoringApi; |
| | | 10 | | private const int MaxRecords = 1000; // Максимальное количество записей для выборки |
| | | 11 | | |
| | 0 | 12 | | public HangfireService() |
| | | 13 | | { |
| | 0 | 14 | | _monitoringApi = JobStorage.Current.GetMonitoringApi(); |
| | 0 | 15 | | } |
| | | 16 | | |
| | | 17 | | public IEnumerable<string> GetAvailableQueues() |
| | | 18 | | { |
| | 0 | 19 | | return _monitoringApi.Queues().Select(q => q.Name); |
| | | 20 | | } |
| | | 21 | | |
| | | 22 | | public List<JobDto> GetEnqueuedJobs(string queueName) |
| | | 23 | | { |
| | 0 | 24 | | var enqueuedJobs = _monitoringApi.EnqueuedJobs(queueName, 0, MaxRecords); |
| | 0 | 25 | | var result = new List<JobDto>(); |
| | | 26 | | |
| | 0 | 27 | | foreach (var job in enqueuedJobs) |
| | | 28 | | { |
| | 0 | 29 | | var jobId = job.Key; |
| | 0 | 30 | | var stateData = JobStorage.Current.GetConnection().GetStateData(jobId); |
| | | 31 | | |
| | 0 | 32 | | if (stateData != null && stateData.Name == "Deleted") |
| | | 33 | | continue; |
| | | 34 | | |
| | 0 | 35 | | result.Add(new JobDto |
| | 0 | 36 | | { |
| | 0 | 37 | | Id = jobId, |
| | 0 | 38 | | MethodName = job.Value.Job?.Method?.Name, |
| | 0 | 39 | | EnqueuedAt = job.Value.EnqueuedAt, |
| | 0 | 40 | | Args = job.Value.Job?.Args, |
| | 0 | 41 | | State = "Enqueued" |
| | 0 | 42 | | }); |
| | | 43 | | } |
| | | 44 | | |
| | 0 | 45 | | return result |
| | 0 | 46 | | .OrderByDescending(j => j.EnqueuedAt) |
| | 0 | 47 | | .Take(MaxRecords) |
| | 0 | 48 | | .ToList(); |
| | | 49 | | } |
| | | 50 | | |
| | | 51 | | public List<JobDto> GetProcessingJobs(string queueName) |
| | | 52 | | { |
| | 0 | 53 | | var processingJobs = _monitoringApi.ProcessingJobs(0, MaxRecords) |
| | 0 | 54 | | .Select(job => new JobDto |
| | 0 | 55 | | { |
| | 0 | 56 | | Id = job.Key, |
| | 0 | 57 | | MethodName = job.Value.Job?.Method?.Name ?? "Unknown", |
| | 0 | 58 | | StartedAt = job.Value.StartedAt, |
| | 0 | 59 | | ServerId = job.Value.ServerId, |
| | 0 | 60 | | Args = job.Value.Job?.Args, |
| | 0 | 61 | | State = "Processing", |
| | 0 | 62 | | Queue = job.Value.Job?.Queue |
| | 0 | 63 | | }) |
| | 0 | 64 | | .OrderByDescending(j => j.StartedAt) |
| | 0 | 65 | | .Take(MaxRecords) |
| | 0 | 66 | | .ToList(); |
| | | 67 | | |
| | 0 | 68 | | return processingJobs; |
| | | 69 | | } |
| | | 70 | | |
| | | 71 | | public List<JobDto> GetSucceededJobs() |
| | | 72 | | { |
| | 0 | 73 | | var failedJobs = _monitoringApi.FailedJobs(0, MaxRecords) |
| | 0 | 74 | | .Select(j => new JobDto |
| | 0 | 75 | | { |
| | 0 | 76 | | Id = j.Key, |
| | 0 | 77 | | MethodName = j.Value.Job?.Method?.Name, |
| | 0 | 78 | | SucceededAt = j.Value.FailedAt, |
| | 0 | 79 | | Duration = 0, |
| | 0 | 80 | | Result = j.Value.ExceptionMessage, |
| | 0 | 81 | | Args = j.Value.Job?.Args, |
| | 0 | 82 | | State = "Failed" |
| | 0 | 83 | | }); |
| | | 84 | | |
| | 0 | 85 | | var succeededJobs = _monitoringApi.SucceededJobs(0, MaxRecords) |
| | 0 | 86 | | .Select(j => new JobDto |
| | 0 | 87 | | { |
| | 0 | 88 | | Id = j.Key, |
| | 0 | 89 | | MethodName = j.Value.Job?.Method?.Name, |
| | 0 | 90 | | SucceededAt = j.Value.SucceededAt, |
| | 0 | 91 | | Duration = j.Value.TotalDuration, |
| | 0 | 92 | | Result = (string)j.Value.Result, |
| | 0 | 93 | | Args = j.Value.Job?.Args, |
| | 0 | 94 | | State = "Succeeded" |
| | 0 | 95 | | }); |
| | | 96 | | |
| | 0 | 97 | | return succeededJobs |
| | 0 | 98 | | .Concat(failedJobs) |
| | 0 | 99 | | .OrderByDescending(j => j.SucceededAt) |
| | 0 | 100 | | .Take(MaxRecords) |
| | 0 | 101 | | .ToList(); |
| | | 102 | | } |
| | | 103 | | |
| | | 104 | | public List<JobDto> GetDeletedJobs() |
| | | 105 | | { |
| | 0 | 106 | | var deletedJobs = _monitoringApi.DeletedJobs(0, MaxRecords) |
| | 0 | 107 | | .Select(job => |
| | 0 | 108 | | { |
| | 0 | 109 | | var jobData = JobStorage.Current.GetConnection().GetJobData(job.Key); |
| | 0 | 110 | | return new JobDto |
| | 0 | 111 | | { |
| | 0 | 112 | | Id = job.Key, |
| | 0 | 113 | | MethodName = jobData?.Job?.Method?.Name, |
| | 0 | 114 | | DeletedAt = job.Value.DeletedAt, |
| | 0 | 115 | | Args = jobData?.Job?.Args, |
| | 0 | 116 | | State = "Deleted", |
| | 0 | 117 | | Result = job.Value.LoadException?.Message, |
| | 0 | 118 | | }; |
| | 0 | 119 | | }) |
| | 0 | 120 | | .OrderByDescending(j => j.DeletedAt) |
| | 0 | 121 | | .Take(MaxRecords) |
| | 0 | 122 | | .ToList(); |
| | | 123 | | |
| | 0 | 124 | | return deletedJobs; |
| | | 125 | | } |
| | | 126 | | } |