From bcfaaf57b60a63acacf0651f5a69b45304abc132 Mon Sep 17 00:00:00 2001
From: Roy <Roy.mail.net@gmail.com>
Date: Thu, 3 Nov 2022 09:16:24 +0200
Subject: FSE Statistics module starter.

---
 .../Statistics/DefaultStatisticsService.cs         | 103 +++++++++++++++++++++
 .../Statistics/IStatisticsService.cs               |  13 +++
 .../PPC/Tango.PPC.Common/Tango.PPC.Common.csproj   |   4 +-
 3 files changed, 119 insertions(+), 1 deletion(-)
 create mode 100644 Software/Visual_Studio/PPC/Tango.PPC.Common/Statistics/DefaultStatisticsService.cs
 create mode 100644 Software/Visual_Studio/PPC/Tango.PPC.Common/Statistics/IStatisticsService.cs

(limited to 'Software/Visual_Studio/PPC/Tango.PPC.Common')

diff --git a/Software/Visual_Studio/PPC/Tango.PPC.Common/Statistics/DefaultStatisticsService.cs b/Software/Visual_Studio/PPC/Tango.PPC.Common/Statistics/DefaultStatisticsService.cs
new file mode 100644
index 000000000..a603410d0
--- /dev/null
+++ b/Software/Visual_Studio/PPC/Tango.PPC.Common/Statistics/DefaultStatisticsService.cs
@@ -0,0 +1,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)
+        {
+
+        }
+    }
+}
diff --git a/Software/Visual_Studio/PPC/Tango.PPC.Common/Statistics/IStatisticsService.cs b/Software/Visual_Studio/PPC/Tango.PPC.Common/Statistics/IStatisticsService.cs
new file mode 100644
index 000000000..553264d42
--- /dev/null
+++ b/Software/Visual_Studio/PPC/Tango.PPC.Common/Statistics/IStatisticsService.cs
@@ -0,0 +1,13 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Tango.PPC.Common.Statistics
+{
+    public interface IStatisticsService : IPPCService
+    {
+
+    }
+}
diff --git a/Software/Visual_Studio/PPC/Tango.PPC.Common/Tango.PPC.Common.csproj b/Software/Visual_Studio/PPC/Tango.PPC.Common/Tango.PPC.Common.csproj
index 0adce35a0..d0476647b 100644
--- a/Software/Visual_Studio/PPC/Tango.PPC.Common/Tango.PPC.Common.csproj
+++ b/Software/Visual_Studio/PPC/Tango.PPC.Common/Tango.PPC.Common.csproj
@@ -198,6 +198,8 @@
     <Compile Include="RemoteNotifications\IRemoteNotificationsService.cs" />
     <Compile Include="SQL\DefaultRemoteSqlService.cs" />
     <Compile Include="SQL\IRemoteSqlService.cs" />
+    <Compile Include="Statistics\DefaultStatisticsService.cs" />
+    <Compile Include="Statistics\IStatisticsService.cs" />
     <Compile Include="Synchronization\DefaultMachineDataSynchronizer.cs" />
     <Compile Include="Synchronization\IMachineDataSynchronizer.cs" />
     <Compile Include="Synchronization\SynchronizationEndedEventArgs.cs" />
@@ -587,7 +589,7 @@
   </Target>
   <ProjectExtensions>
     <VisualStudio>
-      <UserProperties BuildVersion_AssemblyInfoFilename="Properties\AssemblyInfo.cs" BuildVersion_UpdateAssemblyVersion="True" BuildVersion_BuildVersioningStyle="None.None.Increment.TimeStamp" BuildVersion_UseGlobalSettings="False" BuildVersion_StartDate="2000/1/1" />
+      <UserProperties BuildVersion_StartDate="2000/1/1" BuildVersion_UseGlobalSettings="False" BuildVersion_BuildVersioningStyle="None.None.Increment.TimeStamp" BuildVersion_UpdateAssemblyVersion="True" BuildVersion_AssemblyInfoFilename="Properties\AssemblyInfo.cs" />
     </VisualStudio>
   </ProjectExtensions>
 </Project>
\ No newline at end of file
-- 
cgit v1.3.1