MessageRepository.cs 9.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234
  1. using OASystem.Domain;
  2. using OASystem.Domain.Dtos.System;
  3. using System;
  4. using System.Collections.Generic;
  5. using System.Linq;
  6. using System.Security.Cryptography;
  7. using System.Text;
  8. using System.Threading.Tasks;
  9. namespace OASystem.Infrastructure.Repositories.System
  10. {
  11. public class MessageRepository : BaseRepository<Sys_Message, MessageView>
  12. {
  13. public MessageRepository(SqlSugarClient sqlSugar) : base(sqlSugar) { }
  14. /// <summary>
  15. /// 发布消息
  16. /// </summary>
  17. /// <param name="msgDto"></param>
  18. /// <returns></returns>
  19. public async Task<bool> AddMsg(MessageDto msgDto)
  20. {
  21. #region 参数处理
  22. if (msgDto == null) { return false; }
  23. if (string.IsNullOrEmpty(msgDto.Title)) { return false; }
  24. if (string.IsNullOrEmpty(msgDto.Content)) { return false; }
  25. if (msgDto.UIdList.Count <= 0) { return false; }
  26. #endregion
  27. _sqlSugar.BeginTran();
  28. try
  29. {
  30. Sys_Message message = new Sys_Message()
  31. {
  32. Type = msgDto.Type,
  33. IssuerId = msgDto.IssuerId,
  34. Title = msgDto.Title,
  35. Content = msgDto.Content,
  36. ReleaseTime = msgDto.ReleaseTime,
  37. CreateUserId = msgDto.IssuerId,
  38. CreateTime = DateTime.Now,
  39. DeleteUserId = null,
  40. DeleteTime = "1990-01-01 00:00:00.000",
  41. Remark = "",
  42. IsDel = 0,
  43. DiId = msgDto.DiId
  44. };
  45. int? msgId = await _sqlSugar.Insertable(message).ExecuteReturnIdentityAsync();
  46. if (!msgId.HasValue) { _sqlSugar.RollbackTran(); return false; }
  47. List<Sys_MessageReadAuth> messageReadAuths = new List<Sys_MessageReadAuth>();
  48. foreach (int item in msgDto.UIdList)
  49. {
  50. Sys_MessageReadAuth messageReadAuth = new Sys_MessageReadAuth()
  51. {
  52. MsgId = msgId.Value,
  53. ReadableUId = item,
  54. ReadTime = new DateTime(1990, 1, 1),
  55. CreateUserId = msgDto.IssuerId,
  56. CreateTime = DateTime.Now,
  57. DeleteUserId = null,
  58. DeleteTime = "1990-01-01 00:00:00.000",
  59. Remark = "",
  60. IsDel = 0
  61. };
  62. messageReadAuths.Add(messageReadAuth);
  63. }
  64. int? readIds = await _sqlSugar.Insertable<Sys_MessageReadAuth>(messageReadAuths).ExecuteCommandAsync();
  65. if (!readIds.HasValue)
  66. {
  67. _sqlSugar.RollbackTran();
  68. return false;
  69. }
  70. _sqlSugar.CommitTran();
  71. }
  72. catch (Exception)
  73. {
  74. _sqlSugar.RollbackTran();
  75. return false;
  76. }
  77. return true;
  78. }
  79. /// <summary>
  80. /// 获取消息列表
  81. /// </summary>
  82. /// <param name="uId">可读用户Id</param>
  83. /// <returns></returns>
  84. public async Task<Result> GetMsgList(MsgDto dto)
  85. {
  86. Result result = new Result() { Code = -1, Msg = "未知错误", Data = null };
  87. if (dto.PortType == 1 || dto.PortType == 2) // web/android
  88. {
  89. string msgSqlWhere = string.Format(@"Select sm.Type,sm.Title,sm.Content,sd.DepName issuerDep,su.CnName issuerUser,
  90. sm.ReleaseTime,smra.Id AuthId,smra.ReadableUId,smra.IsRead,smra.ReadTime
  91. From Sys_Message sm
  92. Inner Join Sys_MessageReadAuth smra On sm.Id = smra.MsgId
  93. Inner Join Sys_Users su On sm.IssuerId = su.Id
  94. Inner Join Sys_Department sd On su.DepId = sd.Id
  95. Inner Join Sys_Users suAuth On smra.ReadableUId = suAuth.Id
  96. Where sm.IsDel = 0
  97. And smra.IsDel = 0
  98. And smra.ReadableUId = {0}
  99. Order By ReleaseTime Desc ", dto.UserId);
  100. var _readableMsgList = await _sqlSugar.SqlQueryable<ReadbleMessageView>(msgSqlWhere).ToListAsync();
  101. if (_readableMsgList.Count > 0)
  102. {
  103. result.Code = 0;
  104. result.Msg = "成功!";
  105. result.Data = _readableMsgList;
  106. }
  107. else
  108. {
  109. result.Msg = "暂无该用户的消息!";
  110. }
  111. }
  112. return result;
  113. }
  114. /// <summary>
  115. /// 获取消息详细
  116. /// </summary>
  117. /// <param name="dto">msgInfo请求dto</param>
  118. /// <returns></returns>
  119. public async Task<Result> GetMsgInfo(MsgInfoDto dto)
  120. {
  121. Result result = new Result() { Code = -1, Msg = "未知错误", Data = null };
  122. if (dto.PortType == 1 || dto.PortType == 2)
  123. {
  124. string msgSqlWhere = string.Format(@"Select sm.Type,sc.CompanyName,sd.DepName,sjp.JobName,su.CnName,sm.ReleaseTime,
  125. sm.Title,sm.Content,smra.IsRead,smra.ReadTime
  126. From Sys_Message sm
  127. Inner Join Sys_MessageReadAuth smra On sm.Id = smra.MsgId
  128. Inner Join Sys_Users su On sm.IssuerId = su.id
  129. Inner Join Sys_JobPost sjp On su.JobPostId = sjp.Id
  130. Inner Join Sys_Department sd On su.DepId = sd.Id
  131. Inner Join Sys_Company sc On su.CompanyId = sc.Id
  132. Where sm.IsDel = 0
  133. And sm.Id = {0}
  134. And smra.IsDel = 0", dto.MsgId);
  135. var _readableMsgInfo = await _sqlSugar.SqlQueryable<MessageInfoView>(msgSqlWhere).FirstAsync();
  136. if (_readableMsgInfo != null)
  137. {
  138. result.Code = 0;
  139. result.Msg = "成功!";
  140. result.Data = _readableMsgInfo;
  141. }
  142. else
  143. {
  144. result.Msg = "暂无该用户的消息!";
  145. }
  146. }
  147. return result;
  148. }
  149. /// <summary>
  150. /// 消息设置已读
  151. /// </summary>
  152. /// <param name="dto"></param>
  153. /// <returns></returns>
  154. public async Task<Result> SetMsgRead(MsgSetReadDto dto)
  155. {
  156. Result result = new Result() { Code = -1, Msg = "未知错误", Data = null };
  157. if (dto.PortType == 1 || dto.PortType == 2)
  158. {
  159. var msgReadStatus = await _sqlSugar.Updateable<Sys_MessageReadAuth>()
  160. .Where(a => a.Id == dto.MsgAnthId)
  161. .SetColumns(a => new Sys_MessageReadAuth
  162. {
  163. IsRead = 1
  164. }).ExecuteCommandAsync();
  165. if (msgReadStatus > 0)
  166. {
  167. result.Code = 0;
  168. result.Msg = "成功!";
  169. }
  170. else
  171. {
  172. result.Msg = "失败!";
  173. }
  174. }
  175. return result;
  176. }
  177. /// <summary>
  178. /// 消息设置已读
  179. /// </summary>
  180. /// <param name="dto"></param>
  181. /// <returns></returns>
  182. public async Task<Result> DelMsg(MsgDeleteDto dto)
  183. {
  184. Result result = new Result() { Code = -1, Msg = "未知错误", Data = null };
  185. if (dto.PortType == 1 || dto.PortType == 2)
  186. {
  187. var msgReadStatus = await _sqlSugar.Updateable<Sys_Message>()
  188. .Where(a => a.Id == dto.MsgId)
  189. .SetColumns(a => new Sys_Message
  190. {
  191. IsDel = 1,
  192. DeleteUserId = dto.UserId,
  193. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
  194. }).ExecuteCommandAsync();
  195. if (msgReadStatus > 0)
  196. {
  197. result.Code = 0;
  198. result.Msg = "成功!";
  199. }
  200. else
  201. {
  202. result.Msg = "操作失败!";
  203. }
  204. }
  205. return result;
  206. }
  207. }
  208. }