refactor get operator performance

Author: StuartFerguson

EstateReportingAPI.BusinessLogic/ReportingManager.cs

@@ -571,45 +571,6 @@ private Decimal SafeDivide(Decimal number, Int32 divisor)
 
             return number / divisor;
         }
-
-        public async Task<TodaysSales> GetOperatorPerformance(Guid estateId, DateTime comparisonDate, List<Int32> operatorReportingIds, CancellationToken cancellationToken){
-            using ResolvedDbContext<EstateManagementContext>? resolvedContext = this.Resolver.Resolve(EstateManagementDatabaseName, estateId.ToString());
-            await using EstateManagementContext context = resolvedContext.Context;
-
-            // First we need to get a value of todays sales
-            var todaysSalesQuery = (from t in context.TodayTransactions
-                where t.IsAuthorised && t.TransactionType == "Sale"
-                                     && t.TransactionDate == DateTime.Now.Date
-                                     && t.TransactionTime <= DateTime.Now.TimeOfDay
-                select t);
-
-            var comparisonSalesQuery = (from t in context.TransactionHistory
-                where t.IsAuthorised && t.TransactionType == "Sale"
-                                     && t.TransactionDate == comparisonDate
-                                     && t.TransactionTime <= DateTime.Now.TimeOfDay
-                select t);
-
-
-            if (operatorReportingIds.Any())
-            {
-                todaysSalesQuery = todaysSalesQuery.Where(t => operatorReportingIds.Contains(t.OperatorReportingId));
-                comparisonSalesQuery = comparisonSalesQuery.Where(t => operatorReportingIds.Contains(t.OperatorReportingId));
-            }
-
-            TodaysSales response = new TodaysSales
-            {
-                ComparisonSalesCount = comparisonSalesQuery.Count(),
-                ComparisonSalesValue = comparisonSalesQuery.Sum(t => t.TransactionAmount),
-                TodaysSalesCount = todaysSalesQuery.Count(),
-                TodaysSalesValue = todaysSalesQuery.Sum(t => t.TransactionAmount),
-            };
-            response.ComparisonAverageSalesValue =
-                SafeDivide(response.ComparisonSalesValue, response.ComparisonSalesCount);
-            response.TodaysAverageSalesValue =
-                SafeDivide(response.TodaysSalesValue, response.TodaysSalesCount);
-
-            return response;
-        }
 
         public async Task<List<Merchant>> GetMerchants(Guid estateId,
                                                        CancellationToken cancellationToken) {

EstateReportingAPI.BusinessLogic/ReportingManagerExtensions.cs

@@ -31,12 +31,28 @@ public static IQueryable<TodayTransaction> ApplyProductFilter(this IQueryable<To
 
     public static IQueryable<TransactionHistory> ApplyProductFilter(this IQueryable<TransactionHistory> query, List<int> productReportingIds)
     {
-        if (merchantReportingIds == null || productReportingIds.Count == 0)
+        if (productReportingIds == null || productReportingIds.Count == 0)
             return query;
 
         return query.Where(t => productReportingIds.Contains(t.ContractProductReportingId)).AsQueryable();
     }
 
+    public static IQueryable<TodayTransaction> ApplyOperatorFilter(this IQueryable<TodayTransaction> query, List<int> operatorReportingIds)
+    {
+        if (operatorReportingIds == null || operatorReportingIds.Count == 0)
+            return query;
+
+        return query.Where(t => operatorReportingIds.Contains(t.OperatorReportingId)).AsQueryable();
+    }
+
+    public static IQueryable<TransactionHistory> ApplyOperatorFilter(this IQueryable<TransactionHistory> query, List<int> operatorReportingIds)
+    {
+        if (operatorReportingIds == null || operatorReportingIds.Count == 0)
+            return query;
+
+        return query.Where(t => operatorReportingIds.Contains(t.OperatorReportingId)).AsQueryable();
+    }
+
     public static IQueryable<DatabaseProjections.FeeTransactionProjection> ApplyMerchantFilter(this IQueryable<DatabaseProjections.FeeTransactionProjection> query,
                                                                                                EstateManagementContext context,
                                                                                                List<int> merchantIds)

EstateReportingAPI.BusinessLogic/ReportingManagerRefactored.cs

@@ -169,6 +169,33 @@ public async Task<TodaysSales> GetProductPerformance(Guid estateId, DateTime com
             return response;
         }
 
+        public async Task<TodaysSales> GetOperatorPerformance(Guid estateId, DateTime comparisonDate, List<Int32> operatorReportingIds, CancellationToken cancellationToken)
+        {
+            using ResolvedDbContext<EstateManagementContext>? resolvedContext = this.Resolver.Resolve(EstateManagementDatabaseName, estateId.ToString());
+            await using EstateManagementContext context = resolvedContext.Context;
+
+            // First we need to get a value of todays sales
+            IQueryable<TodayTransaction> todaysSalesQuery = BuildTodaySalesQuery(context);
+            IQueryable<TransactionHistory> comparisonSalesQuery = BuildComparisonSalesQuery(context, comparisonDate);
+
+            todaysSalesQuery = todaysSalesQuery.ApplyOperatorFilter(operatorReportingIds);
+            comparisonSalesQuery = comparisonSalesQuery.ApplyOperatorFilter(operatorReportingIds);
+
+            TodaysSales response = new TodaysSales
+            {
+                ComparisonSalesCount = await comparisonSalesQuery.CountAsync(cancellationToken),
+                ComparisonSalesValue = await comparisonSalesQuery.SumAsync(t => t.TransactionAmount, cancellationToken),
+                TodaysSalesCount = await todaysSalesQuery.CountAsync(cancellationToken),
+                TodaysSalesValue = await todaysSalesQuery.SumAsync(t => t.TransactionAmount, cancellationToken),
+            };
+            response.ComparisonAverageSalesValue =
+                SafeDivide(response.ComparisonSalesValue, response.ComparisonSalesCount);
+            response.TodaysAverageSalesValue =
+                SafeDivide(response.TodaysSalesValue, response.TodaysSalesCount);
+
+            return response;
+        }
+
     }
 
     public class DatabaseProjections {