admin/raven
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
John Cardinal
2020-01-21 20:31:53 +00:00
parent a678e3d14f
commit d11aa3dedd
1 changed files with 162 additions and 144 deletions
Download Patch File Download Diff File Expand all files Collapse all files

304
server/AyaNova/biz/WidgetBiz.cs
View File

@@ -405,9 +405,10 @@ namespace AyaNova.Biz
//TEST WIDGET->USER->EMAILADDRESS multi table list //TEST WIDGET->USER->EMAILADDRESS multi table list
//once this is working can replicate at will //once this is working can replicate at will
#region TestGetWidgetUserEmailList #region TestGetWidgetUserEmailList
internal async Task<ApiPagedResponse> TestGetWidgetUserEmailList(IUrlHelper Url, string routeName, ListOptions listOptions) internal async Task<ApiPagedResponse> TestGetWidgetUserEmailList(IUrlHelper Url, string routeName, ListOptions listOptions)
{ {
//var dlist=AyaNova.DataList.DataListFactory.GetListOfAllDataListKeyNames(); //var dlist=AyaNova.DataList.DataListFactory.GetListOfAllDataListKeyNames();
//TODO: Get template (MOCKED FOR NOW UNTIL PROOF OF CONCEPT) //TODO: Get template (MOCKED FOR NOW UNTIL PROOF OF CONCEPT)
var MOCK_WIDGET_USER_EMAIL_DISPLAY_TEMPLATE_JSON = @" var MOCK_WIDGET_USER_EMAIL_DISPLAY_TEMPLATE_JSON = @"
@@ -417,149 +418,166 @@ namespace AyaNova.Biz
} }
"; ";
// var AyaObjectFields = AyaObjectFieldDefinitions.AyaObjectFields(AyaObjectFieldDefinitions.TEST_WIDGET_USER_EMAIL_ADDRESS_LIST_KEY); return await DataListFetcher.GetResponse(nameof(TestWidgetUserEmailDataList), ct, Url, routeName, listOptions, MOCK_WIDGET_USER_EMAIL_DISPLAY_TEMPLATE_JSON, UserId);
var DataList=DataListFactory.GetAyaDataList(nameof(TestWidgetUserEmailDataList));
//TODO: PUt this in the template biz class ultimately and modify sqlselectbuilder to use it
//PARSE THE TEMPLATE INTO A STRING ARRAY
//SO WE KNOW WHICH FIELDS TO RETURN FROM QUERY
var jtemplate = JObject.Parse(MOCK_WIDGET_USER_EMAIL_DISPLAY_TEMPLATE_JSON);
//convert to strings array (https://stackoverflow.com/a/33836599/8939)
string[] templateFieldList;
if (listOptions.Mini)
{
templateFieldList = ((JArray)jtemplate["mini"]).ToObject<string[]>();
}
else
{
templateFieldList = ((JArray)jtemplate["full"]).ToObject<string[]>();
}
//BUILD THE QUERY
//SELECT FRAGMENT COLUMNS FROM TEMPLATE
//TODO: Make this a function called from DataList
var qSelectColumns = DataListSqlSelectBuilder.Build(DataList.FieldDefinitions, MOCK_WIDGET_USER_EMAIL_DISPLAY_TEMPLATE_JSON, listOptions.Mini);
//FROM CLAUSE
//this is where the full SQL statement needs to be made with JOINS etc
//TODO: Can this be moved away into the objectfields or new object
//var qFrom = "from awidget left outer join auser on (awidget.userid=auser.id) left outer join auseroptions on (auser.id=auseroptions.userid)";
var qFrom=DataList.SQLFrom;
//FILTERED?
DataFilter TheFilter = null;
var qWhere = string.Empty;
var qOrderBy = string.Empty;
if (listOptions.DataFilterId > 0)
{
TheFilter = await ct.DataFilter.FirstOrDefaultAsync(x => x.Id == listOptions.DataFilterId);
//WHERE CLAUSE - FILTER
qWhere = DataListSqlFilterCriteriaBuilder.DataFilterToSQLCriteria(TheFilter, DataList.FieldDefinitions, UserId);
//ORDER BY CLAUSE - SORT
//BUILD ORDER BY AND APPEND IT
qOrderBy = DataListSqlFilterOrderByBuilder.DataFilterToSQLOrderBy(TheFilter);
}
//LIMIT AND OFFSET CLAUSE - PAGING
listOptions.Offset = listOptions.Offset ?? ListOptions.DefaultOffset;
listOptions.Limit = listOptions.Limit ?? ListOptions.DefaultLimit;
var qLimitOffset = $"LIMIT {listOptions.Limit} OFFSET {listOptions.Offset}";
//PUT IT ALL TOGETHER
string qDataQuery = string.Empty;
string qTotalRecordsQuery = string.Empty;
if (TheFilter != null)
{
qDataQuery = $"{qSelectColumns} {qFrom} {qWhere} {qOrderBy} {qLimitOffset}";
qTotalRecordsQuery = $"SELECT COUNT(*) {qFrom} {qWhere}";
}
else
{
qDataQuery = $"{qSelectColumns} {qFrom} {qLimitOffset}";
qTotalRecordsQuery = $"SELECT COUNT(*) {qFrom}";
}
//RETURN OBJECTS
int returnRowColumnCount = templateFieldList.Count() + 1;//Templates don't have the DF column in them but we need it and it's in the query so plus one
List<List<AyaFieldData>> rows = new List<List<AyaFieldData>>();
long totalRecordCount = 0;
//QUERY THE DB
using (var command = ct.Database.GetDbConnection().CreateCommand())
{
ct.Database.OpenConnection();
//GET DATA RETURN ROWS
command.CommandText = qDataQuery;
using (var dr = command.ExecuteReader())
{
while (dr.Read())
{
List<AyaFieldData> row = new List<AyaFieldData>(returnRowColumnCount);
//PROCESS THE DF DEFAULT FIRST COLUMN
//first column is always the underlying id value of the default record to open for this row in the client ui
row.Add(new AyaFieldData() { v = dr.GetInt64(0) });
//GetOrdinal by name is flakey in npgsql so just going by field definition and ordinal numerically
int nCurrentColumnPointer = 1;//start at 1
//INSERT REMAINING FIELDS FROM TEMPLATE INTO THE RETURN ROWS LIST
foreach (string TemplateField in templateFieldList)
{
//get the AyaObjectFieldDefinition
AyaDataListFieldDefinition f = DataList.FieldDefinitions.FirstOrDefault(x => x.FieldKey == TemplateField);
AyaFieldData AyaField = new AyaFieldData();
AyaField.v = dr.GetValue(nCurrentColumnPointer);
nCurrentColumnPointer++;
if (f.SqlIdColumnName != null)//skip over df column id, it's not there
{
AyaField.i = dr.GetInt64(nCurrentColumnPointer);
nCurrentColumnPointer++;
}
row.Add(AyaField);
}
rows.Add(row);
}
}
//GET TOTAL RECORD COUNT
command.CommandText = qTotalRecordsQuery;
using (var dr = command.ExecuteReader())
{
if (dr.Read())
{
totalRecordCount = dr.GetInt64(0);
}
}
}
//BUILD THE PAGING LINKS PORTION
var pageLinks = new PaginationLinkBuilder(Url, routeName, null, listOptions, totalRecordCount).PagingLinksObject();
//BUILD THE COLUMNS RETURN PROPERTY JSON FRAGMENT
string ColumnsJSON = string.Empty;
if (listOptions.Mini)
{
ColumnsJSON = DataList.GenerateMINIListColumnsJSON();
}
else
{
ColumnsJSON = DataList.GenerateListColumnsJSONFromTemplate(MOCK_WIDGET_USER_EMAIL_DISPLAY_TEMPLATE_JSON);
}
ApiPagedResponse pr = new ApiPagedResponse(rows, pageLinks, ColumnsJSON);
return pr;
} }
//WORKING ORIGINAL BEFORE MOVE OUT OF HERE
// internal async Task<ApiPagedResponse> TestGetWidgetUserEmailList(IUrlHelper Url, string routeName, ListOptions listOptions)
// {
// //var dlist=AyaNova.DataList.DataListFactory.GetListOfAllDataListKeyNames();
// //TODO: Get template (MOCKED FOR NOW UNTIL PROOF OF CONCEPT)
// var MOCK_WIDGET_USER_EMAIL_DISPLAY_TEMPLATE_JSON = @"
// {
// ""full"":[""widgetname"",""username"",""emailaddress"",""widgetactive""],
// ""mini"":[""widgetname"",""username"",""emailaddress""]
// }
// ";
// // var AyaObjectFields = AyaObjectFieldDefinitions.AyaObjectFields(AyaObjectFieldDefinitions.TEST_WIDGET_USER_EMAIL_ADDRESS_LIST_KEY);
// var DataList=DataListFactory.GetAyaDataList(nameof(TestWidgetUserEmailDataList));
// //TODO: PUt this in the template biz class ultimately and modify sqlselectbuilder to use it
// //PARSE THE TEMPLATE INTO A STRING ARRAY
// //SO WE KNOW WHICH FIELDS TO RETURN FROM QUERY
// var jtemplate = JObject.Parse(MOCK_WIDGET_USER_EMAIL_DISPLAY_TEMPLATE_JSON);
// //convert to strings array (https://stackoverflow.com/a/33836599/8939)
// string[] templateFieldList;
// if (listOptions.Mini)
// {
// templateFieldList = ((JArray)jtemplate["mini"]).ToObject<string[]>();
// }
// else
// {
// templateFieldList = ((JArray)jtemplate["full"]).ToObject<string[]>();
// }
// //BUILD THE QUERY
// //SELECT FRAGMENT COLUMNS FROM TEMPLATE
// //TODO: Make this a function called from DataList
// var qSelectColumns = DataListSqlSelectBuilder.Build(DataList.FieldDefinitions, MOCK_WIDGET_USER_EMAIL_DISPLAY_TEMPLATE_JSON, listOptions.Mini);
// //FROM CLAUSE
// //this is where the full SQL statement needs to be made with JOINS etc
// //TODO: Can this be moved away into the objectfields or new object
// //var qFrom = "from awidget left outer join auser on (awidget.userid=auser.id) left outer join auseroptions on (auser.id=auseroptions.userid)";
// var qFrom=DataList.SQLFrom;
// //FILTERED?
// DataFilter TheFilter = null;
// var qWhere = string.Empty;
// var qOrderBy = string.Empty;
// if (listOptions.DataFilterId > 0)
// {
// TheFilter = await ct.DataFilter.FirstOrDefaultAsync(x => x.Id == listOptions.DataFilterId);
// //WHERE CLAUSE - FILTER
// qWhere = DataListSqlFilterCriteriaBuilder.DataFilterToSQLCriteria(TheFilter, DataList.FieldDefinitions, UserId);
// //ORDER BY CLAUSE - SORT
// //BUILD ORDER BY AND APPEND IT
// qOrderBy = DataListSqlFilterOrderByBuilder.DataFilterToSQLOrderBy(TheFilter);
// }
// //LIMIT AND OFFSET CLAUSE - PAGING
// listOptions.Offset = listOptions.Offset ?? ListOptions.DefaultOffset;
// listOptions.Limit = listOptions.Limit ?? ListOptions.DefaultLimit;
// var qLimitOffset = $"LIMIT {listOptions.Limit} OFFSET {listOptions.Offset}";
// //PUT IT ALL TOGETHER
// string qDataQuery = string.Empty;
// string qTotalRecordsQuery = string.Empty;
// if (TheFilter != null)
// {
// qDataQuery = $"{qSelectColumns} {qFrom} {qWhere} {qOrderBy} {qLimitOffset}";
// qTotalRecordsQuery = $"SELECT COUNT(*) {qFrom} {qWhere}";
// }
// else
// {
// qDataQuery = $"{qSelectColumns} {qFrom} {qLimitOffset}";
// qTotalRecordsQuery = $"SELECT COUNT(*) {qFrom}";
// }
// //RETURN OBJECTS
// int returnRowColumnCount = templateFieldList.Count() + 1;//Templates don't have the DF column in them but we need it and it's in the query so plus one
// List<List<AyaFieldData>> rows = new List<List<AyaFieldData>>();
// long totalRecordCount = 0;
// //QUERY THE DB
// using (var command = ct.Database.GetDbConnection().CreateCommand())
// {
// ct.Database.OpenConnection();
// //GET DATA RETURN ROWS
// command.CommandText = qDataQuery;
// using (var dr = command.ExecuteReader())
// {
// while (dr.Read())
// {
// List<AyaFieldData> row = new List<AyaFieldData>(returnRowColumnCount);
// //PROCESS THE DF DEFAULT FIRST COLUMN
// //first column is always the underlying id value of the default record to open for this row in the client ui
// row.Add(new AyaFieldData() { v = dr.GetInt64(0) });
// //GetOrdinal by name is flakey in npgsql so just going by field definition and ordinal numerically
// int nCurrentColumnPointer = 1;//start at 1
// //INSERT REMAINING FIELDS FROM TEMPLATE INTO THE RETURN ROWS LIST
// foreach (string TemplateField in templateFieldList)
// {
// //get the AyaObjectFieldDefinition
// AyaDataListFieldDefinition f = DataList.FieldDefinitions.FirstOrDefault(x => x.FieldKey == TemplateField);
// AyaFieldData AyaField = new AyaFieldData();
// AyaField.v = dr.GetValue(nCurrentColumnPointer);
// nCurrentColumnPointer++;
// if (f.SqlIdColumnName != null)//skip over df column id, it's not there
// {
// AyaField.i = dr.GetInt64(nCurrentColumnPointer);
// nCurrentColumnPointer++;
// }
// row.Add(AyaField);
// }
// rows.Add(row);
// }
// }
// //GET TOTAL RECORD COUNT
// command.CommandText = qTotalRecordsQuery;
// using (var dr = command.ExecuteReader())
// {
// if (dr.Read())
// {
// totalRecordCount = dr.GetInt64(0);
// }
// }
// }
// //BUILD THE PAGING LINKS PORTION
// var pageLinks = new PaginationLinkBuilder(Url, routeName, null, listOptions, totalRecordCount).PagingLinksObject();
// //BUILD THE COLUMNS RETURN PROPERTY JSON FRAGMENT
// string ColumnsJSON = string.Empty;
// if (listOptions.Mini)
// {
// ColumnsJSON = DataList.GenerateMINIListColumnsJSON();
// }
// else
// {
// ColumnsJSON = DataList.GenerateListColumnsJSONFromTemplate(MOCK_WIDGET_USER_EMAIL_DISPLAY_TEMPLATE_JSON);
// }
// ApiPagedResponse pr = new ApiPagedResponse(rows, pageLinks, ColumnsJSON);
// return pr;
// }
#endregion #endregion
//////////////////////////////////////////////////////////////////////////////////////////////// ////////////////////////////////////////////////////////////////////////////////////////////////