Sc 115 add pagination to all tables that do not have it

Source/Applications/SystemCenter/Controllers/OpenXDA/AssetGroups/OpenXDAAssetGroupsController.cs

@@ -33,30 +33,29 @@
 using System.Collections.Generic;
 using System.Data;
 using System.Linq;
-using System.Net.Http;
-using System.Transactions;
+using System.Reflection;
 using System.Web.Http;
 using GSF.Data;
 using GSF.Data.Model;
 using GSF.Web.Model;
+using Newtonsoft.Json;
 using Newtonsoft.Json.Linq;
 using openXDA.Model;
-using SystemCenter.Model;
 
 namespace SystemCenter.Controllers.OpenXDA
 {
     [RoutePrefix("api/OpenXDA/AssetGroup")]
     public class OpenXDAAssetGroupController : ModelController<AssetGroupView>
     {
-        private class extendedAssetGroupView: AssetGroupView
+        private class extendedAssetGroupView : AssetGroupView
         {
             public List<int> MeterList { get; set; }
             public List<int> AssetList { get; set; }
             public List<int> UserList { get; set; }
             public List<int> AssetGroupList { get; set; }
 
         }
-     
+
         [HttpGet, Route("{assetGroupID:int}/Assets")]
         public IHttpActionResult GetAssets(int assetGroupID)
         {
@@ -93,7 +92,7 @@ GROUP BY
                                 AssetAssetGroup.AssetGroupID
                             HAVING AssetAssetGroup.AssetGroupID = {0}";
 
-                        return Ok(connection.RetrieveData(sql,assetGroupID));
+                        return Ok(connection.RetrieveData(sql, assetGroupID));
                     }
                     catch (Exception ex)
                     {
@@ -105,6 +104,74 @@ GROUP BY
                 return Unauthorized();
         }
 
+        [HttpPost, Route("{assetGroupID:int}/Assets/{page:int}")]
+        public IHttpActionResult GetAssetsPaged([FromBody] PostData postData, [FromUri] int assetGroupID, [FromUri] int page)
+        {
+
+            if (!GetAuthCheck())
+                return Unauthorized();
+
+            int recordsPerPage = Take ?? 50;
+
+            PagedResults results = new PagedResults();
+            results.RecordsPerPage = recordsPerPage;
+
+            string[] sortFields = { "AssetName", "AssetKey", "AssetType" };
+
+            if (!sortFields.Any(f => f.Equals(postData.OrderBy, StringComparison.OrdinalIgnoreCase)))
+            {
+                return BadRequest($"{postData.OrderBy} is not a valid search field.");
+            }
+
+            using (AdoDataConnection connection = new AdoDataConnection(Connection))
+            {
+                string allSql = $@"SELECT   
+                            DISTINCT
+                                Asset.ID,
+                                AssetAssetGroup.AssetGroupID,
+                                Asset.AssetKey,
+                                Asset.AssetName,
+                                Asset.VoltageKV,
+                                AssetType.Name as AssetType,
+                                COUNT(DISTINCT Meter.ID) as Meters,
+                                COUNT(DISTINCT Location.ID) as Locations
+                            FROM
+                                Asset Join
+                                AssetType ON Asset.AssetTypeID = AssetType.ID LEFT JOIN
+                                MeterAsset ON MeterAsset.AssetID = Asset.ID LEFT JOIN
+                                Meter ON MeterAsset.MeterID = Meter.ID LEFT JOIN
+                                AssetLocation ON AssetLocation.AssetID = Asset.ID LEFT JOIN
+                                Location ON AssetLocation.LocationID = Location.ID LEFT JOIN
+                                AssetAssetGroup ON Asset.ID = AssetAssetGroup.AssetID
+                            GROUP BY
+                                Asset.ID,
+                                Asset.AssetKey, 
+                                Asset.AssetName,
+                                Asset.VoltageKV,
+                                AssetType.Name,
+                                AssetAssetGroup.AssetGroupID
+                            HAVING AssetAssetGroup.AssetGroupID = {{0}}
+                            ";
+
+                DataTable allRecords = connection.RetrieveData(allSql, assetGroupID);
+
+                string sql = $@"{allSql}
+                            ORDER BY {postData.OrderBy} {(postData.Ascending ? "ASC" : "DESC")}
+                            OFFSET {page * recordsPerPage} ROWS FETCH NEXT {recordsPerPage} ROWS ONLY
+                            ";
+
+                DataTable records = connection.RetrieveData(sql, assetGroupID);
+
+                int totalRecords = allRecords.Rows.Count;
+
+                results.TotalRecords = totalRecords;
+                results.NumberOfPages = (totalRecords + recordsPerPage - 1) / recordsPerPage;
+                results.Data = JsonConvert.SerializeObject(records);
+            }
+
+            return Ok(results);
+        }
+
         [HttpPost, Route("{assetGroupID:int}/AddAssets")]
         public IHttpActionResult AddAssets(int assetGroupID, [FromBody] IEnumerable<int> assets)
         {
@@ -119,7 +186,7 @@ public IHttpActionResult AddAssets(int assetGroupID, [FromBody] IEnumerable<int>
                         {
                             int n = connection.ExecuteScalar<int>("Select Count(ID) FROM AssetAssetGroup WHERE AssetID = {0} AND AssetGroupID = {1}", assetID, assetGroupID);
                             if (n == 0)
-                                assetassetGroupTbl.AddNewRecord( new AssetAssetGroup() { AssetGroupID = assetGroupID, AssetID = assetID});
+                                assetassetGroupTbl.AddNewRecord(new AssetAssetGroup() { AssetGroupID = assetGroupID, AssetID = assetID });
                         }
                         return Ok(1);
                     }
@@ -192,8 +259,8 @@ GROUP BY
                             Location.Name,
                             MeterAssetGroup.AssetGroupID
                         HAVING MeterAssetGroup.AssetGroupID = {0}";
-                       
-                        return Ok(connection.RetrieveData(sql,assetGroupID));
+
+                        return Ok(connection.RetrieveData(sql, assetGroupID));
                     }
                     catch (Exception ex)
                     {
@@ -205,6 +272,71 @@ GROUP BY
                 return Unauthorized();
         }
 
+        [HttpPost, Route("{assetGroupID:int}/Meters/{page:int}")]
+        public IHttpActionResult GetMetersPaged([FromBody] PostData postData, [FromUri] int assetGroupID, [FromUri] int page)
+        {
+            if (!GetAuthCheck())
+                return Unauthorized();
+
+            int recordsPerPage = Take ?? 50;
+
+            PagedResults results = new PagedResults();
+            results.RecordsPerPage = recordsPerPage;
+
+            string[] sortFields = { "Name", "Location" };
+
+            if (!sortFields.Any(f => f.Equals(postData.OrderBy, StringComparison.OrdinalIgnoreCase)))
+            {
+                return BadRequest($"{postData.OrderBy} is not a valid search field.");
+            }
+
+            using (AdoDataConnection connection = new AdoDataConnection(Connection))
+            {
+                string allSql = $@"SELECT DISTINCT
+                            Meter.ID,
+                            MeterAssetGroup.AssetGroupID,
+                            Meter.AssetKey,
+                            Meter.Name,
+                            Meter.Make,
+                            Meter.Model,
+                            Location.Name as Location,
+                            COUNT(DISTINCT MeterAsset.AssetID)  as MappedAssets
+                        FROM
+                            Meter LEFT JOIN
+                            Location ON Meter.LocationID = Location.ID LEFT JOIN
+                            MeterAsset ON Meter.ID = MeterAsset.MeterID LEFT JOIN
+                            Asset ON MeterAsset.AssetID = Asset.ID LEFT JOIN
+                            MeterAssetGroup ON Meter.ID = MeterAssetGroup.MeterID
+                        GROUP BY
+                            Meter.ID,
+                            Meter.AssetKey,
+                            Meter.Name,
+                            Meter.Make,
+                            Meter.Model,
+                            Location.Name,
+                            MeterAssetGroup.AssetGroupID
+                        HAVING MeterAssetGroup.AssetGroupID = {{0}}
+                ";
+
+                DataTable allRecords = connection.RetrieveData(allSql, assetGroupID);
+
+                string orderedPagedSql = $@"{allSql}
+                        ORDER BY {postData.OrderBy} {(postData.Ascending ? "ASC" : "DESC")}
+                        OFFSET {page * recordsPerPage} ROWS FETCH NEXT {recordsPerPage} ROWS ONLY;
+                ";
+
+                DataTable records = connection.RetrieveData(orderedPagedSql, assetGroupID);
+
+                int totalRecords = allRecords.Rows.Count;
+
+                results.TotalRecords = totalRecords;
+                results.NumberOfPages = (totalRecords + recordsPerPage - 1) / recordsPerPage;
+                results.Data = JsonConvert.SerializeObject(records);
+            }
+
+            return Ok(results);
+        }
+
         [HttpPost, Route("{assetGroupID:int}/AddMeters")]
         public IHttpActionResult AddMeters(int assetGroupID, [FromBody] IEnumerable<int> meters)
         {
@@ -293,7 +425,6 @@ public IHttpActionResult GetSubGroups(int assetGroupID)
                     try
                     {
                         IEnumerable<AssetGroupView> records = new TableOperations<AssetGroupView>(connection).QueryRecordsWhere("ID in (SELECT ChildAssetGroupID FROM AssetGroupAssetGroupView WHERE ParentAssetGroupID = {0})", assetGroupID);
-
                         return Ok(records);
                     }
                     catch (Exception ex)
@@ -306,6 +437,34 @@ public IHttpActionResult GetSubGroups(int assetGroupID)
                 return Unauthorized();
         }
 
+        [HttpPost, Route("{assetGroupID:int}/AssetGroups/{page:int}")]
+        public IHttpActionResult GetSubGroupsPaged([FromBody] PostData postData, [FromUri] int assetGroupID, [FromUri] int page)
+        {
+            if (!GetAuthCheck())
+                return Unauthorized();
+
+            int recordsPerPage = Take ?? 50;
+
+            PagedResults results = new PagedResults();
+            results.RecordsPerPage = recordsPerPage;
+
+            String[] sortFields = { "AssetGroups", "Meters", "Assets", "Name" };
+
+            if (!sortFields.Any(f => f.Equals(postData.OrderBy, StringComparison.OrdinalIgnoreCase)))
+                return BadRequest($"{postData.OrderBy} is not a valid search field.");
+
+            using (AdoDataConnection connection = new AdoDataConnection(Connection))
+            {
+                IEnumerable<AssetGroupView> records = new TableOperations<AssetGroupView>(connection).QueryRecords($"{postData.OrderBy} {(postData.Ascending ? "ASC" : "DESC")}", new RecordRestriction("ID in (SELECT ChildAssetGroupID FROM AssetGroupAssetGroupView WHERE ParentAssetGroupID = {0})", assetGroupID));
+
+                results.TotalRecords = records.Count();
+                results.NumberOfPages = (records.Count() + recordsPerPage - 1) / recordsPerPage;
+                results.Data = JsonConvert.SerializeObject(records.Skip(page * recordsPerPage).Take(recordsPerPage));
+            }
+
+            return Ok(results);
+        }
+
         [HttpPost, Route("{assetGroupID:int}/AddAssetGroups")]
         public IHttpActionResult AddSubgroups(int assetGroupID, [FromBody] IEnumerable<int> subGroups)
         {
@@ -368,7 +527,7 @@ public override IHttpActionResult Delete(AssetGroupView record)
 
                     using (AdoDataConnection connection = new AdoDataConnection(Connection))
                     {
-                       
+
                         int id = record.ID;
                         int result = connection.ExecuteNonQuery($"EXEC UniversalCascadeDelete 'AssetGroup', 'ID = {id}'");
                         return Ok(result);
@@ -396,14 +555,14 @@ public override IHttpActionResult Post([FromBody] JObject record)
                     {
 
                         extendedAssetGroupView newRecord = record.ToObject<extendedAssetGroupView>();
-                        AssetGroup newGroup = new AssetGroup() { ID= newRecord.ID, DisplayDashboard = newRecord.DisplayDashboard, Name= newRecord.Name, DisplayEmail=newRecord.DisplayEmail };
+                        AssetGroup newGroup = new AssetGroup() { ID = newRecord.ID, DisplayDashboard = newRecord.DisplayDashboard, Name = newRecord.Name, DisplayEmail = newRecord.DisplayEmail };
 
                         int result = new TableOperations<AssetGroup>(connection).AddNewRecord(newRecord);
 
                         return Ok(new TableOperations<AssetGroupView>(connection).QueryRecordWhere("Name = {0}", newRecord.Name));
-
 
-                     }
+
+                    }
                 }
                 else
                 {