asp.net-mvc – 在asp.net和ravendb中处理基于活动的feed的最佳

我将每个用户事件存储在单独的文档中(即下面示例中的UserEvent),其中用户具有链接到它的附加属性以及与用户相关联的最后事件的多个事件和时间戳.这将使用户文档保持更小,但具有很多重要信息

在UserEvent中,它将是一个包含id的简单文档,指向此文档引用的用户标识的链接,“事件”集合和lasteventid.这样,如果需要,每个“事件”成为维护的子文档.

最后一个UserEvent索引,允许您轻松查询数据

public class User
{
    public string Id { get; set; }
    // other user properties

    public string UserEventId { get; set; }
    public int NumberOfEvents { get; set; }
    public DateTimeOffset LastEvent { get; set; }
}

public class UserEvent
{
    public string Id { get; set; }

    public string UserId { get; set; }

    public int LastEventId { get; set; }

    public ICollection<Event> Events { get; protected set; }

    public int GenerateEventId()
    {
        return ++LastEventId;
    }

    public class Event
    {
        public int Id { get; set; }
        public DateTimeOffset CreatedAt { get; set; }
        public string ActivityType { get; set; }
        // other event properties
    }
}

public class UserEvents_CreationDate : AbstractIndexCreationTask<UserEvent,UserEvents_CreationDate.ReduceResult>
{
    public UserEvents_CreationDate()
    {
        Map = userEvents => from userEvent in userEvents
                            from evt in userEvent.Events
                            select new
                            {
                                evt.CreatedAt,EventId = evt.Id,UserEventId = userEvent.Id,userEvent.UserId,evt.ActivityType
                            };
        Store(x => x.CreatedAt,FieldStorage.Yes);
        Store(x => x.EventId,FieldStorage.Yes);
        Store(x => x.UserEventId,FieldStorage.Yes);
        Store(x => x.UserId,FieldStorage.Yes);
        Store(x => x.ActivityType,FieldStorage.Yes);
    }

    public class ReduceResult
    {
        public DateTimeOffset CreatedAt { get; set; }
        public int EventId { get; set; }
        public string UserEventId { get; set; }
        public string UserId { get; set; }
        public string ActivityType { get; set; }
    }
}

public static class Helpers
{
    public static DateTimeOffset AsMinutes(this DateTimeOffset self)
    {
        return new DateTimeOffset(self.Year,self.Month,self.Day,self.Hour,self.Minute,self.Offset);
    }

    public static IList<Tuple<UserEvents_CreationDate.ReduceResult,User>> QueryForRecentEvents(
        this IDocumentSession documentSession,Func
            <IRavenQueryable<UserEvents_CreationDate.ReduceResult>,IQueryable<UserEvents_CreationDate.ReduceResult>
            > processQuery)
    {
        IRavenQueryable<UserEvents_CreationDate.ReduceResult> query = documentSession
            .Query<UserEvents_CreationDate.ReduceResult,UserEvents_CreationDate>()
            .Include(comment => comment.UserEventId)
            .Include(comment => comment.UserId)
            .OrderByDescending(x => x.CreatedAt)
            .Where(x => x.CreatedAt < DateTimeOffset.Now.AsMinutes())
            .AsProjection<UserEvents_CreationDate.ReduceResult>();

        List<UserEvents_CreationDate.ReduceResult> list = processQuery(query).ToList();

        return (from identifier in list
                let user = documentSession.Load<User>(identifier.UserId)
                select Tuple.Create(identifier,user))
            .ToList();
    }
}

然后你要做的就是查询.

documentSession.QueryForRecentEvents(q => q.Where(x => x.UserId == user.Id &&  x.ActivityType == "asfd").Take(20)).Select(x => x.Item1);