blob: a603410d00c8e6d3fc7222ab293c43632e960b1d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
using System;
using System.Collections.Generic;
using System.Data.Entity;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Tango.BL;
using Tango.Core;
using Tango.Core.DI;
using Tango.Integration.ExternalBridge;
using Tango.PPC.Common.ExternalBridge;
using Tango.PPC.Shared.Statistics;
namespace Tango.PPC.Common.Statistics
{
[TangoCreateWhenRegistered]
public class DefaultStatisticsService : ExtendedObject, IStatisticsService, IExternalBridgeRequestHandler
{
public bool Enabled { get; set; } = true;
public DefaultStatisticsService(IPPCExternalBridgeService externalBridge)
{
try
{
externalBridge.RegisterRequestHandler(this);
}
catch (Exception ex)
{
LogManager.Log(ex, "Error initializing the statistics service.");
Enabled = false;
}
}
[ExternalBridgeRequestHandlerMethod(typeof(GetStatisticsRequiredFiltersRequest), RequestHandlerLoggingMode.LogRequestName)]
public async Task OnGetStatisticsRequiredFiltersRequest(GetStatisticsRequiredFiltersRequest request, String token, ExternalBridgeReceiver receiver)
{
this.ThrowIfDisabled();
var response = new GetStatisticsRequiredFiltersResponse();
using (ObservablesContext db = ObservablesContext.CreateDefault())
{
var jobNames = await db.JobRuns.Select(x => x.JobName).ToListAsync();
var threadNames = await db.Rmls.Select(x => x.DisplayName).ToListAsync();
response.FiltersData.Jobs = jobNames;
response.FiltersData.Rmls = threadNames;
}
await receiver.SendGenericResponse(response, token);
}
[ExternalBridgeRequestHandlerMethod(typeof(GetStatisticsRequest), RequestHandlerLoggingMode.LogRequestName)]
public async Task OnGetStatisticsRequest(GetStatisticsRequest request, String token, ExternalBridgeReceiver receiver)
{
this.ThrowIfDisabled();
var response = new GetStatisticsResponse();
using (ObservablesContext db = ObservablesContext.CreateDefault())
{
var filters = request.Filters;
var db_JobRuns = db.JobRuns.Where(x => (x.StartDate <= filters.EndDateUTC && x.StartDate >= filters.StartDateUTC));
int[] jobRunStatusArr = filters.EndStatuses.Distinct().ToArray();
if (jobRunStatusArr.Length > 0)
{
db_JobRuns = db_JobRuns.Where(x => jobRunStatusArr.Contains(x.Status));
}
if (!filters.IncludeHeadCleaning)
{
db_JobRuns = db_JobRuns.Where(x => !x.IsHeadCleaning);
}
List<String> rmlGuids = filters.Threads;
if (filters.Threads.Count > 0)
{
db_JobRuns = db_JobRuns.Where(x => rmlGuids.Contains(x.RmlGuid));
}
if (filters.JobName.IsNotNullOrEmpty())
{
db_JobRuns = db_JobRuns.Where(x => x.JobName.ToLower().StartsWith(filters.JobName.ToLower()));
}
db_JobRuns = db_JobRuns.Where(x => x.JobLength < filters.MinLength && x.JobLength >= filters.MaxLength);
var runs_db = await db_JobRuns.ToListAsync();
runs_db.ForEach(x => x.LiquidQuantityString = null);
}
await receiver.SendGenericResponse(response, token);
}
public void OnReceiverDisconnected(ExternalBridgeReceiver receiver)
{
}
}
}
|
