消息管理之获取未读信息数目

消息管理之获取未读信息数目

小Z最近在做一个体育方面的平台，其中在整消息管理这一块，主要用到的设计模式是“拉”模式，就是后台创建一条消息，用户进行消息界面时通过WebAPI进行拉处理，类似于我们每天去邮箱，打开邮箱，看看有没有新消息。其中DDD DomainServices中的代码如下，

            /// <summary>/// 接收消息并且返回未读消息数目/// </summary>/// <returns></returns>public int RecieveMessage(){var notReadCount = 0;var recieveDateTime = ;var userId = currentUser.UserId;//查看用户是否有消息事件var userMessageEventInfo = _iuserMessageEventInfoServices.Find(ent => ent.UserId == userId);if (userMessageEventInfo == null){userMessageEventInfo = new UserMessageEventInfo();userMessageEventInfo.UserId = userId;userMessageEventInfo.LastViewDateTime = recieveDateTime;_iuserMessageEventInfoServices.Add(userMessageEventInfo);}//获取用户最后访问之后的未读消息数量var userMessages = _iuserMessageServices.FindAll(ent => ent.UserId == userId && ent.IsRead == false);if (userMessages != null && userMessages.Count() > 0){notReadCount = userMessages.Count();}//比较消息发送时间和用户最后访问时间，进行消息抽取var messages = domainRepository.FindAll(ent => ent.CreateTime >= userMessageEventInfo.LastViewDateTime);foreach (var message in messages){UserMessage userMessage = new UserMessage(userId);                userMessage.MessageId = message.Id;_iuserMessageServices.Add(userMessage);notReadCount;}userMessageEventInfo.LastViewDateTime = recieveDateTime;_unitOfWork.Commit();return notReadCount;}