feat: create server operations project

Author: gdenchevprog

core/KendoCoreService.sln

@@ -0,0 +1,25 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.2.32630.192
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "KendoCoreService", "KendoCoreService\KendoCoreService.csproj", "{428FECF6-2150-4B40-9A0A-3F5CF542CBD2}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{428FECF6-2150-4B40-9A0A-3F5CF542CBD2}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{428FECF6-2150-4B40-9A0A-3F5CF542CBD2}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{428FECF6-2150-4B40-9A0A-3F5CF542CBD2}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{428FECF6-2150-4B40-9A0A-3F5CF542CBD2}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {AC4A30EC-62C2-432C-9EAF-C83833D24075}
+	EndGlobalSection
+EndGlobal

core/KendoCoreService/Controllers/ProductsController.cs

@@ -0,0 +1,66 @@
+using KendoCoreService.Extensions;
+using KendoCoreService.Interfaces;
+using KendoCoreService.Models.Request;
+using KendoCoreService.Models.Response;
+using Microsoft.AspNetCore.Mvc;
+using System.Collections;
+
+namespace KendoCoreService.Controllers
+{
+    [ApiController]
+    [Route("[controller]/[action]")]
+    public class ProductsController : ControllerBase
+    {
+        private readonly IProductRepository _products;
+
+        public ProductsController(IProductRepository products)
+        {
+            _products = products;
+        }
+
+        [HttpPost]
+        public IActionResult Read([FromBody]Request request)
+        {
+            var data = this._products.All().AsQueryable();
+            int total = data.Count();
+            IList resultData;
+            bool isGrouped = false;
+
+            var aggregates = new Dictionary<string, Dictionary<string, string>>();
+            
+            if (request.Sorts != null)
+            {
+                data = data.Sort(request.Sorts);
+            }
+
+            if (request.Filter != null)
+            {
+                data = data.Filter(request.Filter);
+                total = data.Count();
+            }
+
+            if (request.Aggregates != null)
+            {
+                aggregates = data.CalculateAggregates(request.Aggregates);
+            }
+
+            if (request.Take > 0)
+            {
+                data = data.Page(request.Skip, request.Take);
+            }
+
+            if (request.Groups != null && request.Groups.Count > 0)
+            {
+                resultData = data.Group(request.Groups).Cast<Group>().ToList();
+                isGrouped = true;
+            }
+            else
+            {
+                resultData = data.ToList();
+            }
+
+            var result = new Response(resultData, aggregates, total, isGrouped).ToResult();
+            return Ok(result);
+        }
+    }
+}

core/KendoCoreService/Extensions/AggregateExtension.cs

@@ -0,0 +1,62 @@
+using KendoCoreService.Models.Request;
+
+namespace KendoCoreService.Extensions
+{
+    public static class AggregateExtension
+    {
+        public static Dictionary<string, Dictionary<string, string>> CalculateAggregates<T>(this IQueryable<T> data, List<AggregateRequest> aggregates)
+        {
+            if (aggregates == null)
+            {
+                return new Dictionary<string, Dictionary<string, string>>();
+            }
+
+            int count = aggregates.Count;
+            var result = new Dictionary<string, Dictionary<string, string>>();
+
+            if (count > 0)
+            {
+                foreach (var aggregate in aggregates)
+                {
+                    string field = aggregate.Field;
+                    string functionName = aggregate.Aggregate;
+                    double aggregateResult = 0;
+
+                    switch (functionName)
+                    {
+                        case "sum":
+                            aggregateResult = data.Sum(x => CommonExtension.ParseObjectToDouble(x, field));
+                            break;
+                        case "average":
+                            aggregateResult = data.Average(x => CommonExtension.ParseObjectToDouble(x, field));
+                            break;
+                        case "max":
+                            aggregateResult = data.Max(x => CommonExtension.ParseObjectToDouble(x, field));
+                            break;
+                        case "min":
+                            aggregateResult = data.Min(x => CommonExtension.ParseObjectToDouble(x, field));
+                            break;
+                        case "count":
+                            aggregateResult = data.Select(x => CommonExtension.GetValueByPropertyName(x, field)).Count();
+                            break;
+                    }
+
+                    string functionResult = aggregateResult.ToString();
+
+                    if (!result.ContainsKey(field))
+                    {
+                        result.Add(field, new Dictionary<string, string> { { functionName, functionResult } });
+                    }
+                    else
+                    {
+                        result[field].Add(functionName, functionResult);
+                    }
+                }
+
+                return result;
+            }
+
+            return new Dictionary<string, Dictionary<string, string>>();
+        }
+    }
+}

core/KendoCoreService/Extensions/CommonExtension.cs

@@ -0,0 +1,49 @@
+using System;
+using System.Linq;
+using System.Reflection;
+
+namespace KendoCoreService.Extensions
+{
+    public static class CommonExtension
+    {
+        public static object GetValueByPropertyName(object obj, string propertyName)
+        {
+            return obj.GetType().GetProperty(propertyName).GetValue(obj, null) ?? "null";
+        }
+
+        public static PropertyInfo GetPropertyInfo(Type objType, string propertyName)
+        {
+            return objType.GetProperties().FirstOrDefault(p => p.Name == propertyName);
+        }
+
+        public static double ParseObjectToDouble(object data, string field)
+        {
+            return double.Parse(GetValueByPropertyName(data, field).ToString());
+        }
+
+        public static bool IsNumber(this object value)
+        {
+            return double.TryParse(value.ToString(), out double r);
+        }
+
+        public static bool IsNull(this string str)
+        {
+            return str == "null";
+        }
+
+        public static bool IsNotNull(this string str)
+        {
+            return str != "null";
+        }
+
+        public static bool IsEmpty(this string str)
+        {
+            return str.Length == 0;
+        }
+
+        public static bool IsNotEmpty(this string str)
+        {
+            return str.Length != 0;
+        }
+    }
+}