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-04-11 19:50:44 +00:00
parent 9fb676d365
commit f761737568
1 changed files with 13 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
server/AyaNova/biz/EventLogProcessor.cs
View File

@@ -8,6 +8,7 @@ namespace AyaNova.Biz
{ {
internal static class EventLogProcessor internal static class EventLogProcessor
{ {
private const int DEFAULT_EVENT_LIMIT = 20;
/// <summary> /// <summary>
/// Add an entry to the log /// Add an entry to the log
@@ -53,9 +54,9 @@ namespace AyaNova.Biz
q = q.Where(m => m.AyId == opt.AyId); q = q.Where(m => m.AyId == opt.AyId);
q = q.OrderBy(m => m.Created); q = q.OrderBy(m => m.Created);
var limit = opt.Limit ?? 100; var limit = opt.Limit ?? DEFAULT_EVENT_LIMIT;
var offset = opt.Offset ?? 0; var offset = opt.Offset ?? 0;
q = q.OrderBy(m => m.Created); q = q.Skip(offset).Take(limit);
//Execute the query //Execute the query
var EventItems = await q.ToArrayAsync(); var EventItems = await q.ToArrayAsync();
@@ -89,14 +90,19 @@ namespace AyaNova.Biz
AyaNova.Api.Controllers.EventLogController.UserEventLog ret = new Api.Controllers.EventLogController.UserEventLog(); AyaNova.Api.Controllers.EventLogController.UserEventLog ret = new Api.Controllers.EventLogController.UserEventLog();
//Set up the query // var user = "johndoe";
var q = ct.Event.Select(m => m);
q = q.Where(m => m.UserId == opt.UserId); // var blogs = context.Blogs
var limit = opt.Limit ?? 100; // .FromSqlInterpolated($"EXECUTE dbo.GetMostPopularBlogsForUser {user}")
// .ToList();
// var qLimitOffset = $"LIMIT {listOptions.Limit} OFFSET {listOptions.Offset}";
var limit = opt.Limit ?? DEFAULT_EVENT_LIMIT;
var offset = opt.Offset ?? 0; var offset = opt.Offset ?? 0;
//Set up the query
var q = ct.Event.Select(m => m).Skip(offset).Take(limit);
q = q.Where(m => m.UserId == opt.UserId);
q = q.OrderBy(m => m.Created); q = q.OrderBy(m => m.Created);
q.Skip(offset).Take(limit);
//Execute the query //Execute the query
var EventItems = await q.ToArrayAsync(); var EventItems = await q.ToArrayAsync();