123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171 |
- using Microsoft.AspNetCore.SignalR;
- using OASystem.API.OAMethodLib.Hubs;
- using OASystem.API.OAMethodLib.Quartz.Business;
- using OASystem.Infrastructure.Repositories.PersonnelModule;
- using Quartz;
- namespace OASystem.API.OAMethodLib.Quartz.Jobs
- {
- /// <summary>
- /// 任务消息推送
- /// 每天下午两点推送
- /// </summary>
- public class TaskNewsFeedJob : IJob
- {
- private readonly ILogger<TaskNewsFeedJob> _logger;
- private readonly TaskAllocationRepository _taskAllocationRep = AutofacIocManager.Instance.GetService<TaskAllocationRepository>();
- private readonly IHubContext<ServerHub> _hubContext;
- public TaskNewsFeedJob(ILogger<TaskNewsFeedJob> logger, TaskAllocationRepository taskAllocationRep, IHubContext<ServerHub> hubContext)
- {
- _logger = logger;
- _taskAllocationRep = taskAllocationRep;
- _hubContext = hubContext;
- }
- /// <summary>
- /// 任务消息推送
- /// </summary>
- /// <param name="context"></param>
- /// <returns></returns>
- public async Task Execute(IJobExecutionContext context)
- {
- //_logger.LogInformation("调用任务消息推送 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")+"【在线人数】:"+JsonConvert.SerializeObject(ServerHub.OnlineUser));
- //在此处编写任务业务代码
- #region 消息处理
- //var data = _taskAllocationRep._sqlSugar
- // .Queryable<Pm_TaskAllocation>()
- // .Where(it => it.IsDel == 0 &&
- // !string.IsNullOrEmpty(it.PredictEndTime) &&
- // Convert.ToDateTime(it.PredictEndTime).ToString("yyyy-MM-dd").Equals(DateTime.Now.ToString("yyyy-MM-dd"))
- // )
- // .ToList();
- //if (data.Count > 0)
- //{
- // //处理要任务提醒的员工
- // List<int> primaryIds = new List<int>();
- // primaryIds = data.Select(it => it.Id).ToList();
- // var subData = _taskAllocationRep._sqlSugar
- // .Queryable<Pm_TaskRelevanceUser>()
- // .Where(it => it.IsDel == 0 &&
- // primaryIds.Contains(it.TAId) &&
- // it.TaskStatus <= (int)TaskEnum.UnderWay
- // )
- // .ToList();
- // _taskAllocationRep._sqlSugar.BeginTran();
- // var depDatas = _taskAllocationRep._sqlSugar.Queryable<Sys_Department>().Where(it => it.IsDel == 0).ToList();
- // var groupDatas = _taskAllocationRep._sqlSugar.Queryable<Grp_DelegationInfo>().Where(it => it.IsDel == 0).ToList();
- // var userDatas = _taskAllocationRep._sqlSugar.Queryable<Sys_Users>().Where(it => it.IsDel == 0).ToList();
- // foreach (var item in data)
- // {
- // string depName = string.Empty;
- // string groupName = string.Empty;
- // var depData = depDatas.Where(it => it.Id == item.DepId).FirstOrDefault();
- // if (depData != null) { depName = depData.DepName; }
- // if (item.DiId == -1) { groupName = "其他"; }
- // else
- // {
- // var groupData = groupDatas.Where(it => it.Id == item.DiId).FirstOrDefault();
- // if (groupData != null) { groupName = groupData.TeamName; }
- // }
- // var subData1 = subData.Where(it => it.TAId == item.Id).ToList();
- // foreach (var subItem in subData1)
- // {
- // string realityStartTime = string.Empty;
- // string userName = string.Empty;
- // if (!string.IsNullOrEmpty(subItem.BeginTime))
- // {
- // realityStartTime = subItem.BeginTime;
- // }
- // else
- // {
- // if (subItem.TaskStatus == -1) realityStartTime = "未开始";
- // else if (subItem.TaskStatus == 0) realityStartTime = "已知晓";
- // }
- // var userData = userDatas.Where(it => it.Id == subItem.UserId).FirstOrDefault();
- // if (userData != null) { userName = userData.CnName; }
- // string msgContent = string.Format(@"任务归属:{0}<br/>
- // 归属团组:{1}<br/>
- // 预计起止时间:{2} 至 {3}<br/>
- // 实际开始时间:{4}<br/>
- // 任务优先级:{5}<br/>
- // 任务参与者:{6}<br/>
- // 任务内容:{7}", depName, groupName, item.PredictBeginTime, item.PredictEndTime,
- // realityStartTime, item.TaskPriority, userName, item.TaskContent);
- // Sys_Message _Message = new Sys_Message()
- // {
- // Type = MessgeTypeEnum.TaskProgressUpdate,
- // Title = item.TaskName,
- // IssuerId = 4, //管理员
- // Content = msgContent,
- // ReleaseTime = DateTime.Now,
- // CreateUserId = 4,
- // CreateTime = DateTime.Now,
- // DeleteTime = "1990-01-01 00:00:00.000",
- // DiId = item.DiId,
- // };
- // var msgAddId = _taskAllocationRep._sqlSugar.Insertable<Sys_Message>(_Message).ExecuteReturnIdentity();
- // if (msgAddId < 0)
- // {
- // _taskAllocationRep._sqlSugar.RollbackTran();
- // _logger.LogError("任务通知消息推送失败!");
- // return;
- // }
- // Sys_MessageReadAuth _MessageReadAuth = new Sys_MessageReadAuth()
- // {
- // MsgId = msgAddId,
- // ReadableUId = subItem.UserId,
- // IsRead = 0,
- // ReadTime = Convert.ToDateTime("1990-01-01 00:00:00.000"),
- // CreateUserId = 4,
- // CreateTime = DateTime.Now,
- // DeleteTime = "1990-01-01 00:00:00.000"
- // };
- // var msgAuthAddId = _taskAllocationRep._sqlSugar.Insertable<Sys_MessageReadAuth>(_MessageReadAuth).ExecuteReturnIdentity();
- // if (msgAuthAddId < 0)
- // {
- // _taskAllocationRep._sqlSugar.RollbackTran();
- // _logger.LogError("任务通知消息推送失败!");
- // return;
- // }
- // }
- // }
- // _taskAllocationRep._sqlSugar.CommitTran();
- //}
- #endregion
- string msg = string.Empty;
- if (ServerHub.OnlineUser.Count > 0)
- {
- //查询需要提示的消息 Singlr
- string sql = string.Format(@"Select smra.Id,su.CnName As Issuer,sm.ReleaseTime,sm.Title,
- sm.Content,smra.ReadableUId,smra.IsRead,smra.CreateTime
- From Sys_Message sm
- Left Join Sys_MessageReadAuth smra On sm.Id = smra.MsgId
- Left Join Sys_Users su On sm.IssuerId = su.Id
- Where sm.IsDel = 0 And sm.Type = 6 And smra.IsRead = 0
- Order By smra.ReadableUId,smra.CreateTime Desc");
- var datas = _taskAllocationRep._sqlSugar.SqlQueryable<MessageReadAuthPushView>(sql).ToList();
- msg = JsonConvert.SerializeObject(datas);
- //_hubContext.Clients.All.SendAsync("ReceiveMessage", "系统通知", $"最新消息{DateTime.Now}");
- //推送给所有连接ID的第一条数据
- }
- _logger.LogInformation("调用任务消息推送 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "【在线人数】:" + JsonConvert.SerializeObject(ServerHub.OnlineUser) +"【推送消息】:"+ msg);
- await _hubContext.Clients.Clients(ServerHub.OnlineUser.Select(q => q.ConnectionId).ToList()).SendAsync("SendMessageResponse", $"最新消息{DateTime.Now}");
- //return Task.CompletedTask;
- }
- }
- }
|