IMContentBLL.cs 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126
  1. using LeaRun.Application.Entity.MessageManage;
  2. using LeaRun.Application.IService.MessageManage;
  3. using LeaRun.Application.Service.MessageManage;
  4. using LeaRun.Util.WebControl;
  5. using System.Collections.Generic;
  6. using System.Data;
  7. namespace LeaRun.Application.Busines.MessageManage
  8. {
  9. /// <summary>
  10. /// 版 本 V6.1
  11. /// Copyright (c) 2013-2016 上海力软信息技术有限公司
  12. /// 创建人:陈彬彬
  13. /// 日 期:2015.11.30 15:16
  14. /// 描 述:即时通信群组管理
  15. /// </summary>
  16. public class IMContentBLL
  17. {
  18. private IMsgContentService server = new IMContentService();
  19. private IMsgGroupService groupServer = new IMGroupService();
  20. /// <summary>
  21. /// 获取消息列表
  22. /// </summary>
  23. /// <param name="pagination"></param>
  24. /// <param name="queryJson"></param>
  25. /// <returns></returns>
  26. public IEnumerable<IMReadModel> GetListOneToOne(Pagination pagination, string userId,string sendId)
  27. {
  28. return server.GetList(pagination, userId, sendId);
  29. }
  30. /// <summary>
  31. /// 获取消息列表(群组)
  32. /// </summary>
  33. /// <param name="pagination"></param>
  34. /// <param name="queryJson"></param>
  35. /// <returns></returns>
  36. public IEnumerable<IMReadModel> GetListByGroupId(Pagination pagination, string queryJson)
  37. {
  38. return server.GetListByGroupId(pagination, queryJson);
  39. }
  40. /// <summary>
  41. /// 获取消息数量列表
  42. /// </summary>
  43. /// <param name="queryJson">readStatus,userId</param>
  44. /// <returns></returns>
  45. public IEnumerable<IMReadNumModel> GetReadList(string userId)
  46. {
  47. return server.GetReadList(userId);
  48. }
  49. /// <summary>
  50. /// 获取某用户某种消息的总数
  51. /// </summary>
  52. /// <param name="userId"></param>
  53. /// <param name="status"></param>
  54. /// <returns></returns>
  55. public string GetReadAllNum(string userId, string status)
  56. {
  57. string num = "0";
  58. DataTable dt = server.GetReadAllNum(userId, status);
  59. if (dt.Rows.Count > 0)
  60. {
  61. if (dt.Rows[0]["unReadNum"].ToString() != "")
  62. {
  63. num = dt.Rows[0]["unReadNum"].ToString();
  64. }
  65. }
  66. return num;
  67. }
  68. #region 提交数据
  69. /// <summary>
  70. /// 增加一条一对一消息
  71. /// </summary>
  72. /// <param name="userId"></param>
  73. /// <param name="sendId"></param>
  74. /// <param name="createName"></param>
  75. /// <param name="message"></param>
  76. public void AddOneToOne(string userId,string sendId,string createName,string message)
  77. {
  78. IMContentEntity entity = new IMContentEntity();
  79. entity.SendId = sendId;
  80. entity.ToId = userId;
  81. entity.MsgContent = message;
  82. entity.IsGroup = 0;
  83. entity.CreateUserId = sendId;
  84. entity.CreateUserName = createName;
  85. server.Add(entity,null);
  86. }
  87. /// <summary>
  88. /// 增加群组消息
  89. /// </summary>
  90. /// <param name="groupId"></param>
  91. /// <param name="sendId"></param>
  92. /// <param name="createName"></param>
  93. /// <param name="message"></param>
  94. public void AddGroup(string groupId, string sendId, string createName, string message,out DataTable dtUserId)
  95. {
  96. IMContentEntity entity = new IMContentEntity();
  97. entity.SendId = sendId;
  98. entity.ToId = groupId;
  99. entity.MsgContent = message;
  100. entity.IsGroup = 0;
  101. entity.CreateUserId = sendId;
  102. entity.CreateUserName = createName;
  103. DataTable dt = groupServer.GetUserIdList(groupId);
  104. dtUserId = dt;
  105. server.Add(entity, dt);
  106. }
  107. /// <summary>
  108. /// 更新消息的阅读状态
  109. /// </summary>
  110. /// <param name="sendId"></param>
  111. /// <param name="isGroup"></param>
  112. public void UpDateSatus(string userId, string sendId,string status)
  113. {
  114. server.Update(userId, sendId, status);
  115. }
  116. #endregion
  117. }
  118. }