Total Dye Time & Meters on FSE.

1 files changed, 28 insertions, 0 deletions

diff --git a/Software/Visual_Studio/PPC/Tango.PPC.Common/SystemInfo/DefaultSystemInfoService.cs b/Software/Visual_Studio/PPC/Tango.PPC.Common/SystemInfo/DefaultSystemInfoService.cs
index 0c818483c..3c3a0247b 100644
--- a/Software/Visual_Studio/PPC/Tango.PPC.Common/SystemInfo/DefaultSystemInfoService.cs
+++ b/Software/Visual_Studio/PPC/Tango.PPC.Common/SystemInfo/DefaultSystemInfoService.cs
@@ -1,10 +1,12 @@
 using Microsoft.WindowsAPICodePack.Net;
 using System;
 using System.Collections.Generic;
+using System.Data.Entity;
 using System.Diagnostics;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
+using Tango.BL;
 using Tango.Core;
 using Tango.Core.DI;
 using Tango.Integration.ExternalBridge;
@@ -130,6 +132,32 @@ namespace Tango.PPC.Common.SystemInfo
             }, token);
         }
 
+        [ExternalBridgeRequestHandlerMethod(typeof(GetMachineCountersRequest), RequestHandlerLoggingMode.LogRequestName)]
+        public async Task OnGetMachineCountersRequest(GetMachineCountersRequest request, String token, ExternalBridgeReceiver receiver)
+        {
+            var counters = await GetCounters();
+
+            var response = new GetMachineCountersResponse();
+            response.TotalDyeTime = counters.Item1;
+            response.TotalDyeMeters = counters.Item2;
+
+            await receiver.SendGenericResponse(response, token);
+        }
+
+        private async Task<Tuple<TimeSpan, int>> GetCounters()
+        {
+            using (ObservablesContext db = ObservablesContext.CreateDefault())
+            {
+                var jobRuns = await db.JobRuns.Select(x => new { x.StartDate, x.EndDate, x.EndPosition }).ToListAsync();
+
+                TimeSpan totalDyeTime = TimeSpan.FromHours(jobRuns.Select(x => x.EndDate - x.StartDate).Sum(x => x.TotalHours));
+
+                int meters = (int)jobRuns.Select(x => x.EndPosition).Sum();
+
+                return new Tuple<TimeSpan, int>(totalDyeTime, meters);
+            }
+        }
+
         public void OnReceiverDisconnected(ExternalBridgeReceiver receiver)
         {