using System; using System.Collections.Generic; using System.Linq; namespace Bootstrap.DataAccess { /// /// /// public class Message { /// /// 消息主键 数据库自增 /// public string Id { get; set; } /// /// 标题 /// public string Title { get; set; } /// /// 内容 /// public string Content { get; set; } /// /// 发消息人 /// public string From { get; set; } /// /// 收消息人 /// public string To { get; set; } /// /// 消息发送时间 /// public DateTime SendTime { get; set; } /// /// 消息状态:0-未读,1-已读 和Dict表的通知消息关联 /// public string Status { get; set; } /// /// 标旗状态:0-未标旗,1-已标旗 /// public int Mark { get; set; } /// /// 删除状态:0-未删除,1-已删除 /// public int IsDelete { get; set; } /// /// 消息标签:0-一般,1-紧要 和Dict表的消息标签关联 /// public string Label { get; set; } /// /// 获得/设置 标签名称 /// public string LabelName { get; set; } /// /// 获得/设置 时间描述 2分钟内为刚刚 /// public string Period { get; set; } /// /// 获得/设置 发件人头像 /// public string FromIcon { get; set; } /// /// 获得/设置 发件人昵称 /// public string FromDisplayName { get; set; } //TODO: SQL语句不兼容 /// /// 所有有关userName所有消息列表 /// /// /// protected virtual IEnumerable Retrieves(string userName) { var db = DbManager.Create(); var t = db.Provider.EscapeSqlIdentifier("To"); var f = db.Provider.EscapeSqlIdentifier("From"); return db.Fetch($"select m.*, d.Name, u.DisplayName from [Messages] m left join Dicts d on m.Label = d.Code and d.Category = @Category and d.Define = 0 inner join Users u on m.{f} = u.UserName where {t} = @UserName or {f} = @UserName order by SendTime desc", new { UserName = userName, Category = "消息标签" }); } /// /// 收件箱 /// /// public virtual IEnumerable Inbox(string userName) { var messageRet = Retrieves(userName); return messageRet.Where(n => n.To.Equals(userName, StringComparison.OrdinalIgnoreCase)); } /// /// 发件箱 /// /// /// public virtual IEnumerable SendMail(string userName) { var messageRet = Retrieves(userName); return messageRet.Where(n => n.From.Equals(userName, StringComparison.OrdinalIgnoreCase)); } /// /// 垃圾箱 /// /// /// public virtual IEnumerable Trash(string userName) { var messageRet = Retrieves(userName); return messageRet.Where(n => n.IsDelete == 1); } /// /// 标旗 /// /// /// public virtual IEnumerable Flag(string userName) { var messageRet = Retrieves(userName); return messageRet.Where(n => n.Mark == 1); } /// /// 获取Header处显示的消息列表 /// /// /// public virtual IEnumerable RetrieveHeaders(string userName) { var messageRet = Inbox(userName); messageRet.AsParallel().ForAll(n => { var ts = DateTime.Now - n.SendTime; if (ts.TotalMinutes < 5) n.Period = "刚刚"; else if (ts.Days > 0) n.Period = string.Format("{0}天", ts.Days); else if (ts.Hours > 0) n.Period = string.Format("{0}小时", ts.Hours); else if (ts.Minutes > 0) n.Period = string.Format("{0}分钟", ts.Minutes); }); return messageRet; } } }