OA2023/OASystem/OASystem.Api/OAMethodLib/Quartz/Jobs/TaskNewsFeedJob.cs

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;
        }
    }
}