TaskNewsFeedJob.cs 9.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171
  1. using Microsoft.AspNetCore.SignalR;
  2. using OASystem.API.OAMethodLib.Hubs;
  3. using OASystem.API.OAMethodLib.Quartz.Business;
  4. using OASystem.Infrastructure.Repositories.PersonnelModule;
  5. using Quartz;
  6. namespace OASystem.API.OAMethodLib.Quartz.Jobs
  7. {
  8. /// <summary>
  9. /// 任务消息推送
  10. /// 每天下午两点推送
  11. /// </summary>
  12. public class TaskNewsFeedJob : IJob
  13. {
  14. private readonly ILogger<TaskNewsFeedJob> _logger;
  15. private readonly TaskAllocationRepository _taskAllocationRep = AutofacIocManager.Instance.GetService<TaskAllocationRepository>();
  16. private readonly IHubContext<ServerHub> _hubContext;
  17. public TaskNewsFeedJob(ILogger<TaskNewsFeedJob> logger, TaskAllocationRepository taskAllocationRep, IHubContext<ServerHub> hubContext)
  18. {
  19. _logger = logger;
  20. _taskAllocationRep = taskAllocationRep;
  21. _hubContext = hubContext;
  22. }
  23. /// <summary>
  24. /// 任务消息推送
  25. /// </summary>
  26. /// <param name="context"></param>
  27. /// <returns></returns>
  28. public async Task Execute(IJobExecutionContext context)
  29. {
  30. //_logger.LogInformation("调用任务消息推送 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")+"【在线人数】:"+JsonConvert.SerializeObject(ServerHub.OnlineUser));
  31. //在此处编写任务业务代码
  32. #region 消息处理
  33. //var data = _taskAllocationRep._sqlSugar
  34. // .Queryable<Pm_TaskAllocation>()
  35. // .Where(it => it.IsDel == 0 &&
  36. // !string.IsNullOrEmpty(it.PredictEndTime) &&
  37. // Convert.ToDateTime(it.PredictEndTime).ToString("yyyy-MM-dd").Equals(DateTime.Now.ToString("yyyy-MM-dd"))
  38. // )
  39. // .ToList();
  40. //if (data.Count > 0)
  41. //{
  42. // //处理要任务提醒的员工
  43. // List<int> primaryIds = new List<int>();
  44. // primaryIds = data.Select(it => it.Id).ToList();
  45. // var subData = _taskAllocationRep._sqlSugar
  46. // .Queryable<Pm_TaskRelevanceUser>()
  47. // .Where(it => it.IsDel == 0 &&
  48. // primaryIds.Contains(it.TAId) &&
  49. // it.TaskStatus <= (int)TaskEnum.UnderWay
  50. // )
  51. // .ToList();
  52. // _taskAllocationRep._sqlSugar.BeginTran();
  53. // var depDatas = _taskAllocationRep._sqlSugar.Queryable<Sys_Department>().Where(it => it.IsDel == 0).ToList();
  54. // var groupDatas = _taskAllocationRep._sqlSugar.Queryable<Grp_DelegationInfo>().Where(it => it.IsDel == 0).ToList();
  55. // var userDatas = _taskAllocationRep._sqlSugar.Queryable<Sys_Users>().Where(it => it.IsDel == 0).ToList();
  56. // foreach (var item in data)
  57. // {
  58. // string depName = string.Empty;
  59. // string groupName = string.Empty;
  60. // var depData = depDatas.Where(it => it.Id == item.DepId).FirstOrDefault();
  61. // if (depData != null) { depName = depData.DepName; }
  62. // if (item.DiId == -1) { groupName = "其他"; }
  63. // else
  64. // {
  65. // var groupData = groupDatas.Where(it => it.Id == item.DiId).FirstOrDefault();
  66. // if (groupData != null) { groupName = groupData.TeamName; }
  67. // }
  68. // var subData1 = subData.Where(it => it.TAId == item.Id).ToList();
  69. // foreach (var subItem in subData1)
  70. // {
  71. // string realityStartTime = string.Empty;
  72. // string userName = string.Empty;
  73. // if (!string.IsNullOrEmpty(subItem.BeginTime))
  74. // {
  75. // realityStartTime = subItem.BeginTime;
  76. // }
  77. // else
  78. // {
  79. // if (subItem.TaskStatus == -1) realityStartTime = "未开始";
  80. // else if (subItem.TaskStatus == 0) realityStartTime = "已知晓";
  81. // }
  82. // var userData = userDatas.Where(it => it.Id == subItem.UserId).FirstOrDefault();
  83. // if (userData != null) { userName = userData.CnName; }
  84. // string msgContent = string.Format(@"任务归属:{0}<br/>
  85. // 归属团组:{1}<br/>
  86. // 预计起止时间:{2} 至 {3}<br/>
  87. // 实际开始时间:{4}<br/>
  88. // 任务优先级:{5}<br/>
  89. // 任务参与者:{6}<br/>
  90. // 任务内容:{7}", depName, groupName, item.PredictBeginTime, item.PredictEndTime,
  91. // realityStartTime, item.TaskPriority, userName, item.TaskContent);
  92. // Sys_Message _Message = new Sys_Message()
  93. // {
  94. // Type = MessgeTypeEnum.TaskProgressUpdate,
  95. // Title = item.TaskName,
  96. // IssuerId = 4, //管理员
  97. // Content = msgContent,
  98. // ReleaseTime = DateTime.Now,
  99. // CreateUserId = 4,
  100. // CreateTime = DateTime.Now,
  101. // DeleteTime = "1990-01-01 00:00:00.000",
  102. // DiId = item.DiId,
  103. // };
  104. // var msgAddId = _taskAllocationRep._sqlSugar.Insertable<Sys_Message>(_Message).ExecuteReturnIdentity();
  105. // if (msgAddId < 0)
  106. // {
  107. // _taskAllocationRep._sqlSugar.RollbackTran();
  108. // _logger.LogError("任务通知消息推送失败!");
  109. // return;
  110. // }
  111. // Sys_MessageReadAuth _MessageReadAuth = new Sys_MessageReadAuth()
  112. // {
  113. // MsgId = msgAddId,
  114. // ReadableUId = subItem.UserId,
  115. // IsRead = 0,
  116. // ReadTime = Convert.ToDateTime("1990-01-01 00:00:00.000"),
  117. // CreateUserId = 4,
  118. // CreateTime = DateTime.Now,
  119. // DeleteTime = "1990-01-01 00:00:00.000"
  120. // };
  121. // var msgAuthAddId = _taskAllocationRep._sqlSugar.Insertable<Sys_MessageReadAuth>(_MessageReadAuth).ExecuteReturnIdentity();
  122. // if (msgAuthAddId < 0)
  123. // {
  124. // _taskAllocationRep._sqlSugar.RollbackTran();
  125. // _logger.LogError("任务通知消息推送失败!");
  126. // return;
  127. // }
  128. // }
  129. // }
  130. // _taskAllocationRep._sqlSugar.CommitTran();
  131. //}
  132. #endregion
  133. string msg = string.Empty;
  134. if (ServerHub.OnlineUser.Count > 0)
  135. {
  136. //查询需要提示的消息 Singlr
  137. string sql = string.Format(@"Select smra.Id,su.CnName As Issuer,sm.ReleaseTime,sm.Title,
  138. sm.Content,smra.ReadableUId,smra.IsRead,smra.CreateTime
  139. From Sys_Message sm
  140. Left Join Sys_MessageReadAuth smra On sm.Id = smra.MsgId
  141. Left Join Sys_Users su On sm.IssuerId = su.Id
  142. Where sm.IsDel = 0 And sm.Type = 6 And smra.IsRead = 0
  143. Order By smra.ReadableUId,smra.CreateTime Desc");
  144. var datas = _taskAllocationRep._sqlSugar.SqlQueryable<MessageReadAuthPushView>(sql).ToList();
  145. msg = JsonConvert.SerializeObject(datas);
  146. //_hubContext.Clients.All.SendAsync("ReceiveMessage", "系统通知", $"最新消息{DateTime.Now}");
  147. //推送给所有连接ID的第一条数据
  148. }
  149. _logger.LogInformation("调用任务消息推送 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "【在线人数】:" + JsonConvert.SerializeObject(ServerHub.OnlineUser) +"【推送消息】:"+ msg);
  150. await _hubContext.Clients.Clients(ServerHub.OnlineUser.Select(q => q.ConnectionId).ToList()).SendAsync("SendMessageResponse", $"最新消息{DateTime.Now}");
  151. //return Task.CompletedTask;
  152. }
  153. }
  154. }