SignalR.Core 消息推送实例
public class ChatHub : Hub { private string _className = "ChatHub"; //private System.Threading.Timer timer = null; private System.Threading.Timer _timer = null; private static readonly object _lock = new object(); /// <summary> /// 前端接口接收消息的方法名 /// </summary> private string _receiveMsgmethod = "chatHubReceiveMsg"; /// <summary> /// 前端接口注册用户的方法名 /// </summary> private string _registerUserthod = "chatHubRegisterUsert"; /// <summary> /// 系统消息发送人 /// </summary> private string _sendUser = "system"; private ITokenHelper _tokenHelper = new TokenHelper(); /// <summary> /// 当连接成功时执行 /// </summary> /// <returns></returns> public override Task OnConnectedAsync() { try { string connId = Context.ConnectionId; var tokenobj = Context.GetHttpContext().Request.Query["token"].ToString(); var uid = Context.GetHttpContext().Request.Query["uid"].ToString(); //读取配置文件中 的 秘钥 var secretKey = ConfigManagerHelper.JwtTokenConfig["Secret"]; if (!string.IsNullOrEmpty(tokenobj)) { //var userId = string.Empty; //string token = tokenobj.Split(" ")[1].ToString();//剔除Bearer ////string mobile = "";//用户手机号 //// //验证jwt,同时取出来jwt里边的用户ID //TokenType tokenType = _tokenHelper.ValiTokenState(token, secretKey // , a => a["iss"] == "test.cn" && a["aud"] == "test" // , action => // { // userId = action["id"]; // //mobile = action["phone_number"]; // }); var userModel = new OnlineUserModel() { Token = tokenobj, F_Id = uid, ConnectionId = connId, HubClients = Clients }; OnlineUserService.Instance.AddOnlineUser(userModel); /*根据令牌获取用户的信息*/ //{ // await RedisClient.Instance.SetAsync("缓存key-用户标识", this.Context.ConnectionId); //} } //_logger.LogWarning("SignalR已连接"); //验证Token //var token = _accessor.HttpContext.Request.Query["access_token"]; //var user = JwtHelper.SerializeJwt(token); //ApiLogQueueService.Instance.AddLog(_className, "OnConnectedAsync", ApiLogType.Warning, ProjectIdEnum.LDApi.GetHashCode(), 200, token, "SignalR已连接，用户名：" + CurrentUserName, string.Empty, 200, 0, CommonHelp.ServiceIp); //_logger.LogWarning("SignalR已连接，用户名：" + CurrentUserName); //连接用户 这里可以存在Redis //var model = new T_sys_userModel //{ // p_attribute1 = connId //}; OnlineUserService.Instance.AddClients(connId, Clients); //var msgModel = new MessageModel() //{ // SendUserID = connId, // SendUserName = secretKey, // Msg = connId + "连接成功,uid:" + uid, // Type = MessageTypeEnum.System.GetHashCode(), // City = tokenobj //}; //Clients.All.SendAsync("chatHubConnectResponse", _sendUser+ "OnConnectedAsync", msgModel);//connId + "连接成功" TimerSend(); } catch (Exception ex) { ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() { Search1 = "OnConnectedAsync", Search2 = string.Empty, ClassName = _className, Method = "OnConnectedAsync", Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), RequestModel = string.Empty, ResponseModel = string.Empty, ElapsedTime = 0, Code = InterfaceName.ChatHub_SendMessageAsync.GetHashCode(), InterfaceNameEnum = InterfaceName.ChatHub_SendMessageAsync, ProjectId = ProjectIdEnum.LDApi.GetHashCode(), ResultCode = 200, Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, RowStatus = TrueOrFalseEnum.True.GetHashCode(), CreatedBy = "system", CreatedOn = DateTime.Now }); } //给当前的连接分组 可以进行同一组接收消息 也可以用Token获取机构权限 //await Groups.AddToGroupAsync(Context.ConnectionId, "测试组"); //给当前连接返回消息 .Clients可以发多个连接ID //Clients.Client(connId).SendAsync("ConnectResponse", // new AjaxResultModel<T_sys_userModel>() // { // state = 200, // data = model, // message = model.p_attribute1 + "连接成功" // }); return base.OnConnectedAsync(); } /// <summary> /// 当连接断开时的处理 /// </summary> public override Task OnDisconnectedAsync(Exception exception) { try { //var token = Context.GetHttpContext().Request.Query["token"].ToString(); //var uid = Context.GetHttpContext().Request.Query["uid"].ToString(); //var userModel = OnlineUserService.Instance.GetUserByConnectionId(connId); string connId = Context.ConnectionId; OnlineUserService.Instance.RemoveClients(connId); //if (Clients != null) //{ // var msg = connId + "断开连接"; // if (userModel != null) // { // msg = userModel.F_RealName + "断开连接"; // } // var msgModel = new MessageModel() // { // SendUserID = connId, // SendUserName = string.Empty, // Msg = msg + "uid:" + uid, // Type = MessageTypeEnum.System.GetHashCode(), // City = token // }; // Clients.All.SendAsync("chatHubDisconnectResponse", _sendUser, msgModel); //} } catch (Exception ex) { ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() { Search1 = "OnDisconnectedAsync", Search2 = string.Empty, ClassName = _className, Method = "OnDisconnectedAsync", Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), RequestModel = string.Empty, ResponseModel = string.Empty, ElapsedTime = 0, Code = InterfaceName.ChatHub_SendMessageAsync.GetHashCode(), InterfaceNameEnum = InterfaceName.ChatHub_SendMessageAsync, ProjectId = ProjectIdEnum.LDApi.GetHashCode(), ResultCode = 200, Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, RowStatus = TrueOrFalseEnum.True.GetHashCode(), CreatedBy = "system", CreatedOn = DateTime.Now }); } return base.OnDisconnectedAsync(exception); } /// <summary> /// 定时器 /// </summary> /// <returns></returns> private void TimerSend() { //System.Threading.Timer t = new System.Threading.Timer(SendMessageAsync, null, 0, 1000); //if (_timer == null) //{ // lock (_lock) // { // if (_timer == null) // { // _timer = new System.Threading.Timer(SendMessageAsync, null, 0, 60000); // } // } //} } /// <summary> /// 发信息 ok /// </summary> /// <returns></returns> private void SendMessageAsync(object a) { try { var msg = "[" + CommonHelp.ServiceIp + "]系统消息:现在是" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); //var task = _hubClients.All.SendAsync("Show", "system", msg); //var task = hubClients.All.SendAsync(_receiveMsgmethod, "system", msg); var task = OnlineUserService.Instance.SendPublicMsg(msg, "systemId", "system"); //task.Wait(); //var msg = "系统消息:现在是" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); ////var task =_hubContext.Clients.All.SendAsync("Show", "system", "系统消息:现在是" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); //var task = OnlineUser.Values.All.SendAsync("Show", "system", msg); //task.Wait(); //if (Clients != null) //{ // //string userid = Guid.NewGuid().ToString(); // var msg = "系统消息:现在是" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); // //var task =_hubContext.Clients.All.SendAsync("Show", "system", "系统消息:现在是" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); // var task = Clients.All.SendAsync("Show", "system", msg); // task.Wait(); // //var isSucceed = _userLoginLogService.Add(new Admin.Models.Tables.TB_UserLoginLogModel() // //{ // // F_Id = Guid.NewGuid().ToString("N"), // // F_ClientIP = msg, // // F_LoginTime = DateTime.Now, // // F_LoginType = "登录", // // F_ServiceType = "登录", // // F_UserId = "system", // //}); // //var aa = isSucceed; //} } catch (Exception ex) { ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() { Search1 = "SendMessageAsync", Search2 = string.Empty, ClassName = _className, Method = "SendMessageAsync", Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), RequestModel = string.Empty, ResponseModel = string.Empty, ElapsedTime = 0, Code = InterfaceName.ChatHub_SendMessageAsync.GetHashCode(), InterfaceNameEnum = InterfaceName.ChatHub_SendMessageAsync, ProjectId = ProjectIdEnum.LDApi.GetHashCode(), ResultCode = 200, Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, RowStatus = TrueOrFalseEnum.True.GetHashCode(), CreatedBy = "system", CreatedOn = DateTime.Now }); } } /// <summary> /// 开始计时器 前端调用 invoke /// </summary> private void startReminbScheduleTimer() { //设置定时间隔(毫秒为单位) //int interval = 3000;//60000一分钟 //timer = new System.Timers.Timer(interval); ////设置执行一次（false）还是一直执行(true) //timer.AutoReset = true; ////设置是否执行System.Timers.Timer.Elapsed事件 //timer.Enabled = true; ////绑定Elapsed事件 需要执行的事件 //timer.Elapsed += new System.Timers.ElapsedEventHandler(ReminbSchedule); //timer.Start(); } /// <summary> /// 日程提醒 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> //public async void ReminbSchedule(object sender, ElapsedEventArgs e) public void ReminbSchedule(object sender) { try { //获取需要此人需要提醒的日程 DateTime StartTime = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd HH:mm:00")); DateTime EndTime = StartTime.AddMinutes(1); //var taskPublicSendMsg = SendMsg("system", "[" + CommonHelp.ServiceIp + "]系统消息:现在是" + StartTime.ToString("yyyy-MM-dd HH:mm:ss")); //taskPublicSendMsg.Wait(); var task = OnlineUserService.Instance.SendPublicMsg("[" + CommonHelp.ServiceIp + "]系统消息:现在是" + StartTime.ToString("yyyy-MM-dd HH:mm:ss"), "systemId", "system"); //task.Wait(); //var list = getRemindSchedule(StartTime, EndTime); ////if (Type = 1)//1系统消息 2 电子邮件 3 系统弹窗 ////{ ////} //// var currentuserid = Context.UserIdentifier; ////前端 判断Direct类型 为3时时日程提醒 //foreach (var item in list) //{ // //IpAddress：日程ID Time：(2 天前 · 日历 · 2021年12月28日 16:00 - 2021年12月28日 18:00) // var timestr = LD.Code.Common.DateStringFromNow(item.RemindTime) + "· 日历 ·" + item.F_StartTime.ToString("yyyy年MM月dd日 HH:00") + " - " + item.F_EndTime.ToString("yyyy年MM月dd日 HH:00"); // var t = Clients.User(CurrentUserId).SendAsync("ReceiveMessage", new MessageModel() { UserID = CurrentUserId, Name = CurrentUserName, Msg = item.F_Title, Direct = 3, IpAddress = item.F_Id, Time = timestr }); // await Task.WhenAll(t); // //标记为已提醒 // await UpdateRemind(item.ReminbId, item.IsEdit); //} } catch (Exception ex) { ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() { Search1 = "ReminbSchedule", Search2 = string.Empty, ClassName = _className, Method = "ReminbSchedule", Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), RequestModel = string.Empty, ResponseModel = string.Empty, ElapsedTime = 0, Code = InterfaceName.ChatHub_ReminbSchedule.GetHashCode(), InterfaceNameEnum = InterfaceName.ChatHub_ReminbSchedule, ProjectId = ProjectIdEnum.LDApi.GetHashCode(), ResultCode = 200, Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, RowStatus = TrueOrFalseEnum.True.GetHashCode(), CreatedBy = "system", CreatedOn = DateTime.Now }); } } /// <summary> /// 给连接的所有人发送消息 /// </summary> /// <param name="username"></param> /// <param name="message"></param> /// <returns></returns> //public Task SendMsg(string username, string message) //{ // //Show方法需要在前端实现 // return Clients.All.SendAsync("Show", username, message); //} /// <summary> /// 公共消息 /// </summary> /// <param name="message"></param> /// <param name="sendUserId"></param> /// <param name="sendUserName"></param> /// <returns></returns> public async Task PublicSendMsg(string message, string sendUserId, string sendUserName) { // 后期考虑后台管理添加系统通知，这里来查 通知到链接的人 //var hubClients = OnlineUserService.Instance.GetClient(); //if (hubClients != null) //{ // var t1 = hubClients.All.SendAsync(_receiveMsgmethod, _sendUser, message);//new { Msg = message, Direct = 0 } // var t2 = this.InsertMessage(0, CurrentUserId, userId, message); ;//添加历史记录 // await Task.WhenAll(t1);//, t2 //} if (!string.IsNullOrEmpty(message) && !string.IsNullOrEmpty(sendUserId) && !string.IsNullOrEmpty(sendUserName)) { var t1 = OnlineUserService.Instance.SendPublicMsg(message, sendUserId, sendUserName); //t1.Wait(); } } /// <summary> /// 发送组消息 /// </summary> /// <param name="groupId"></param> /// <param name="message"></param> /// <param name="sendUserId"></param> /// <param name="sendUserName"></param> /// <returns></returns> public async Task SendGroupMsg(string groupId,string message, string sendUserId, string sendUserName) { // 后期考虑后台管理添加系统通知，这里来查 通知到链接的人 if (!string.IsNullOrEmpty(message) && !string.IsNullOrEmpty(sendUserId) && !string.IsNullOrEmpty(sendUserName)) { var t1 = OnlineUserService.Instance.SendGroupMsg(groupId, message, sendUserId, sendUserName); //t1.Wait(); } } /// <summary> /// 注册用户消息 /// </summary> /// <param name="userId"></param> /// <param name="userName"></param> /// <param name="connectionId"></param> /// <returns></returns> public void RegisterUser(string userId, string userName, string connectionId) { try { // 后期考虑后台管理添加系统通知，这里来查 通知到链接的人 var hubClients = OnlineUserService.Instance.GetClient(); if (hubClients != null) { if (!string.IsNullOrEmpty(userId) && !string.IsNullOrEmpty(userName) && !string.IsNullOrEmpty(connectionId)) { OnlineUserService.Instance.AddOnlineUser(new OnlineUserModel() { F_Id = userId, F_RealName = userName, ConnectionId = connectionId }); //userName + "注册成功" var msgModel = new MessageModel() { SendUserID = "systemId", SendUserName = "system", Msg = userName + "注册成功", Type = MessageTypeEnum.System.GetHashCode() }; hubClients.All.SendAsync(_registerUserthod, "system", msgModel); } } } catch (Exception ex) { //写日志 ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() { Search1 = "RegisterUser", Search2 = string.Empty, ClassName = _className, Method = "RegisterUser", Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), RequestModel = string.Empty, ResponseModel = string.Empty, ElapsedTime = 0, Code = InterfaceName.ChatHub_RegisterUser.GetHashCode(), InterfaceNameEnum = InterfaceName.ChatHub_RegisterUser, ProjectId = ProjectIdEnum.LDApi.GetHashCode(), ResultCode = 200, Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, RowStatus = TrueOrFalseEnum.True.GetHashCode(), CreatedBy = "system", CreatedOn = DateTime.Now }); } } /// <summary> /// 加入案件组 /// </summary> /// <param name="lawcaseId"></param> /// <param name="userId"></param> /// <returns></returns> public void JoinGroup(string lawcaseId, string userId) { try { if (!string.IsNullOrEmpty(userId) && !string.IsNullOrEmpty(lawcaseId)) { if (lawcaseId.Contains(",")) { var lawcaseIds = lawcaseId.Split(',').ToList(); foreach (var item in lawcaseIds) { if (!string.IsNullOrEmpty(item)) { OnlineUserService.Instance.JoinGroup(item, userId);//, this.Groups } } } else { OnlineUserService.Instance.JoinGroup(lawcaseId, userId);//, this.Groups } } } catch (Exception ex) { //写日志 ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() { Search1 = "JoinGroup", Search2 = string.Empty, ClassName = _className, Method = "JoinGroup", Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), RequestModel = string.Empty, ResponseModel = string.Empty, ElapsedTime = 0, Code = InterfaceName.ChatHub_RegisterUser.GetHashCode(), InterfaceNameEnum = InterfaceName.ChatHub_RegisterUser, ProjectId = ProjectIdEnum.LDApi.GetHashCode(), ResultCode = 200, Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, RowStatus = TrueOrFalseEnum.True.GetHashCode(), CreatedBy = "system", CreatedOn = DateTime.Now }); } } /// <summary> /// 加入案件组(批量) /// </summary> /// <param name="lawcaseId"></param> /// <param name="userId"></param> /// <returns></returns> //public void JoinGroupBatch(string lawcaseId, string userId) //{ // try // { // if (!string.IsNullOrEmpty(userId) && !string.IsNullOrEmpty(lawcaseId)) // { // OnlineUserService.Instance.JoinGroup(lawcaseId, userId);//, this.Groups // } // } // catch (Exception ex) // { // //写日志 // ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() // { // Search1 = "JoinGroup", // Search2 = string.Empty, // ClassName = _className, // Method = "JoinGroup", // Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), // RequestModel = string.Empty, // ResponseModel = string.Empty, // ElapsedTime = 0, // Code = InterfaceName.ChatHub_RegisterUser.GetHashCode(), // InterfaceNameEnum = InterfaceName.ChatHub_RegisterUser, // ProjectId = ProjectIdEnum.LDApi.GetHashCode(), // ResultCode = 200, // Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, // RowStatus = TrueOrFalseEnum.True.GetHashCode(), // CreatedBy = "system", // CreatedOn = DateTime.Now // }); // } //} /// <summary> /// 移除案件组 /// </summary> /// <param name="lawcaseId"></param> /// <param name="userId"></param> /// <returns></returns> public void RemoveGroup(string lawcaseId, string userId) { try { if (!string.IsNullOrEmpty(userId) && !string.IsNullOrEmpty(lawcaseId)) { OnlineUserService.Instance.RemoveGroup(lawcaseId, userId);//, this.Groups } } catch (Exception ex) { //写日志 ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() { Search1 = "RemoveGroup", Search2 = string.Empty, ClassName = _className, Method = "RemoveGroup", Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), RequestModel = string.Empty, ResponseModel = string.Empty, ElapsedTime = 0, Code = InterfaceName.ChatHub_RegisterUser.GetHashCode(), InterfaceNameEnum = InterfaceName.ChatHub_RegisterUser, ProjectId = ProjectIdEnum.LDApi.GetHashCode(), ResultCode = 200, Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, RowStatus = TrueOrFalseEnum.True.GetHashCode(), CreatedBy = "system", CreatedOn = DateTime.Now }); } } /// <summary> /// 私聊 /// </summary> /// <param name="receiveUserId"></param> /// <param name="message"></param> /// <param name="sendUserId"></param> /// <param name="sendUserName"></param> /// <returns></returns> //public async Task SendPrivateMsg(string receiveUserId, string message, string sendUserId, string sendUserName) //{ // var hubClients = OnlineUserService.Instance.GetClient(); // if (hubClients != null && string.IsNullOrEmpty(receiveUserId) && string.IsNullOrEmpty(message)) // { // var model = OnlineUserService.Instance.GetUserByUserId(receiveUserId); // if (model != null) // { // //var t1 = _hubClients.User(model.ConnectionId).SendAsync(_receiveMsgmethod, new MessageModel() { UserID = sendUserId, Name = sendUserName, Msg = message, Direct = 1 }); // var t2 = model.HubClients.Client(model.ConnectionId).SendAsync(_receiveMsgmethod, sendUserId, message);//new MessageModel() { UserID = sendUserId, Name = sendUserName, Msg = message, Direct = 2 } // //var t3 = this.InsertMessage(1, CurrentUserId, userId, message); // //await Task.WhenAll(t1, t2, t3); // await Task.WhenAll(t2); // } // } //} /// <summary> /// 给指定房间内所有用户发消息 /// </summary> /// <param name="roomid"></param> /// <param name="message"></param> /// <returns></returns> //public async Task SendGroupMessage(string roomid, string message) //{ // if (_hubClients != null) // { // var t1 = _hubClients.Group(roomid).SendAsync("ReceiveGroupMessage", new { UserID = CurrentUserId, Name = CurrentUserName, Msg = message }); // var t2 = this.InsertMessage(2, CurrentUserId, "", message); // await Task.WhenAll(t1, t2); // } //} }
/// <summary> /// 集线器 /// 在线用户库 (多服务器时要存在公共缓存中) /// </summary> public class OnlineUserService { #region 属性成员 private string _className = "OnlineUserService"; /// <summary> /// 单例 /// </summary> private static OnlineUserService _Instance = new OnlineUserService(); /// <summary> /// 已连接的用户信息 /// </summary> private Dictionary<string, IHubCallerClients> _OnlineUserClients { get; set; }// = new Dictionary<string, IHubCallerClients>(); /// <summary> /// 在线用户 /// </summary> private List<OnlineUserModel> _OnlineUser { get; set; }// = new List<OnlineUserModel>(); /// <summary> /// 在线用户 /// </summary> private Dictionary<string, List<OnlineUserModel>> _GroupList { get; set; }// = new Dictionary<string, List<OnlineUserModel>>(); private static IHubCallerClients _hubClients; private System.Threading.Timer _timer = null; private static readonly object _lock = new object(); /// <summary> /// 消息服务 /// </summary> private static IMessageService _serviceMessage = new MessageService(); /// <summary> /// 系统消息发送人 /// </summary> private string _sendUser = "system"; /// <summary> /// 前端接口接收消息的方法名 /// </summary> private string _receiveMsgmethod = "chatHubReceiveMsg"; /// <summary> /// 前端接口注册用户的方法名 /// </summary> private string _registerUserthod = "chatHubRegisterUsert"; /// <summary> /// 用户日程接口 /// </summary> private IUserScheduleRemindService _userScheduleRemindService = null; /// <summary> /// 操作日志 /// </summary> private IOperationLogService _operationLogService = null; /// <summary> /// 用户接口 /// </summary> private IUserService _serviceUser = null; #endregion private OnlineUserService() { _OnlineUserClients = new Dictionary<string, IHubCallerClients>(); _OnlineUser = new List<OnlineUserModel>(); _GroupList = new Dictionary<string, List<OnlineUserModel>>(); _userScheduleRemindService = new UserScheduleRemindService(); _operationLogService = new OperationLogService(); _serviceUser = ServiceLocator.Services.GetService<IUserService>(); } /// <summary> /// 单例只读属性 /// </summary> public static OnlineUserService Instance { get { return _Instance; } } /// <summary> /// 定时器 /// </summary> /// <returns></returns> private void timerSend() { //System.Threading.Timer t = new System.Threading.Timer(SendMessageAsync, null, 0, 1000); if (_timer == null) { lock (_lock) { //需要处理的业务 if (_timer == null) { _timer = new System.Threading.Timer(sendRemindSchedule, null, 0, 60000); } } } } /// <summary> /// 根据用户ID获取Client对象 /// </summary> /// <param name="userId">用户ID</param> /// <returns></returns> public IHubCallerClients GetClient(string userId = "") { IHubCallerClients clients = null; if (string.IsNullOrEmpty(userId)) { clients = _hubClients; } else { var model = _OnlineUser.Find(t => t.F_Id.Equals(userId)); if (model != null) { clients = model.HubClients; } } return clients; } /// <summary> /// 注册在线用户连接对象 /// </summary> /// <param name="connectionId"></param> /// <param name="client"></param> /// <returns></returns> public bool AddClients(string connectionId, IHubCallerClients client) { var isSucceed = false; try { if (!string.IsNullOrEmpty(connectionId) && client != null) { _hubClients = client; if (!_OnlineUserClients.ContainsKey(connectionId)) { _OnlineUserClients.Add(connectionId, client); timerSend(); } } } catch (Exception ex) { //写日志 ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() { Search1 = "AddClients", Search2 = string.Empty, ClassName = _className, Method = "AddClients", Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), RequestModel = string.Empty, ResponseModel = string.Empty, ElapsedTime = 0, Code = InterfaceName.ChatHub_AddClients.GetHashCode(), InterfaceNameEnum = InterfaceName.ChatHub_AddClients, ProjectId = ProjectIdEnum.LDApi.GetHashCode(), ResultCode = 200, Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, RowStatus = TrueOrFalseEnum.True.GetHashCode(), CreatedBy = "system", CreatedOn = DateTime.Now }); } return isSucceed; } /// <summary> /// 移除在线用户连接对象 /// </summary> /// <param name="connectionId"></param> /// <returns></returns> public bool RemoveClients(string connectionId) { var isSucceed = false; try { if (!string.IsNullOrEmpty(connectionId)) { if (_OnlineUserClients.ContainsKey(connectionId)) { //从在线用户连接客户端集合中删除用户 _OnlineUserClients.Remove(connectionId); if (_OnlineUserClients.Count == 0) { _hubClients = null; _timer = null; } //从在用户集合中删除用户 var userModel = _OnlineUser.FirstOrDefault(t => t.ConnectionId.Equals(connectionId)); if (userModel != null) { _OnlineUser.Remove(userModel); isSucceed = true; } //从组中删除用户 foreach (var item in _GroupList) { if (item.Value != null) { var groupUserModel = item.Value.FirstOrDefault(t => !string.IsNullOrEmpty(t.ConnectionId) && t.ConnectionId.Equals(connectionId)); if (groupUserModel != null) { item.Value.Remove(groupUserModel); isSucceed = true; } } } //发送连接成功消息 var msg = string.Format("【{0}】已下线,uid:{1}", userModel.F_RealName, userModel.ConnectionId); SendPublicMsg("chatHubConnectResponse", msg, _sendUser, _sendUser); } } } catch (Exception ex) { //写日志 ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() { Search1 = "RemoveClients", Search2 = string.Empty, ClassName = _className, Method = "RemoveClients", Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), RequestModel = string.Empty, ResponseModel = string.Empty, ElapsedTime = 0, Code = InterfaceName.ChatHub_RemoveClients.GetHashCode(), InterfaceNameEnum = InterfaceName.ChatHub_RemoveClients, ProjectId = ProjectIdEnum.LDApi.GetHashCode(), ResultCode = 200, Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, RowStatus = TrueOrFalseEnum.True.GetHashCode(), CreatedBy = "system", CreatedOn = DateTime.Now }); } return isSucceed; } /// <summary> /// 注册在线用户 /// </summary> /// <param name="userModel"></param> /// <returns></returns> public bool AddOnlineUser(OnlineUserModel userModel) { var isSucceed = false; try { if (userModel != null) { var userObj = _serviceUser.GetById(userModel.F_Id); if (userObj != null) { userModel.F_RealName = userObj.F_RealName; } var model = _OnlineUser.FirstOrDefault(t => t.F_Id == userModel.F_Id); if (model == null) { if (_OnlineUserClients.ContainsKey(userModel.ConnectionId)) { userModel.HubClients = _OnlineUserClients[userModel.ConnectionId]; } _OnlineUser.Add(userModel); } else { _OnlineUser.Remove(userModel); if (_OnlineUserClients.ContainsKey(userModel.ConnectionId)) { userModel.HubClients = _OnlineUserClients[userModel.ConnectionId]; } _OnlineUser.Add(userModel); } isSucceed = true; //发送连接成功消息 var msg = string.Format("【{0}】连接成功,uid:{1}", userModel.F_RealName, userModel.ConnectionId); SendPublicMsg("chatHubConnectResponse", msg, _sendUser, _sendUser); } } catch (Exception ex) { //写日志 ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() { Search1 = "AddOnlineUser", Search2 = string.Empty, ClassName = _className, Method = "AddOnlineUser", Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), RequestModel = string.Empty, ResponseModel = string.Empty, ElapsedTime = 0, Code = InterfaceName.ChatHub_RegisterUser.GetHashCode(), InterfaceNameEnum = InterfaceName.ChatHub_RegisterUser, ProjectId = ProjectIdEnum.LDApi.GetHashCode(), ResultCode = 200, Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, RowStatus = TrueOrFalseEnum.True.GetHashCode(), CreatedBy = "system", CreatedOn = DateTime.Now }); } return isSucceed; } /// <summary> /// 移除在线用户 /// </summary> /// <param name="userModel"></param> /// <returns></returns> public bool RemoveOnlineUser(OnlineUserModel userModel) { var isSucceed = false; try { if (userModel != null) { var model = _OnlineUser.Find(t => t.F_Id == userModel.F_Id); if (model != null) { isSucceed = _OnlineUser.Remove(userModel); isSucceed = _OnlineUserClients.Remove(model.ConnectionId); } } } catch (Exception ex) { //写日志 ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() { Search1 = "RemoveOnlineUser", Search2 = string.Empty, ClassName = _className, Method = "RemoveOnlineUser", Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), RequestModel = string.Empty, ResponseModel = string.Empty, ElapsedTime = 0, Code = InterfaceName.ChatHub_RegisterUser.GetHashCode(), InterfaceNameEnum = InterfaceName.ChatHub_RegisterUser, ProjectId = ProjectIdEnum.LDApi.GetHashCode(), ResultCode = 200, Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, RowStatus = TrueOrFalseEnum.True.GetHashCode(), CreatedBy = "system", CreatedOn = DateTime.Now }); } return isSucceed; } /// <summary> /// 加入案件组 /// </summary> /// <param name="lawcaseId"></param> /// <param name="userId"></param> /// <returns></returns> public bool JoinGroup(string lawcaseId, string userId)//, IGroupManager Groups { var isSucceed = false; try { if (!string.IsNullOrEmpty(lawcaseId) && !string.IsNullOrEmpty(userId)) { var userName = string.Empty; if (_GroupList.ContainsKey(lawcaseId)) { //组存在 var model = _OnlineUser.FirstOrDefault(t => t.F_Id == userId); if (model != null) { //将客户端的连接ID加入到组里面 //Groups.AddToGroupAsync(model.ConnectionId, lawcaseId); userName = model.F_RealName; var userList = _GroupList[lawcaseId]; if (userList != null) { userList = userList.FindAll(t => t != null); var userModel = userList.FirstOrDefault(t => t.F_Id.Equals(userId)); if (userModel == null) { userList.Add(model); _GroupList[lawcaseId] = userList; } } } } else { var model = _OnlineUser.Find(t => t.F_Id == userId); if (model != null) { userName = model.F_RealName; //将客户端的连接ID加入到组里面 //Groups.AddToGroupAsync(model.ConnectionId, lawcaseId); _GroupList.Add(lawcaseId, new List<OnlineUserModel>() { model }); isSucceed = true; } } var tasl = SendPrivateMsg(userId, userName, userName + "用户加入案件组成功", _sendUser, _sendUser); //tasl.Wait(); isSucceed = true; } } catch (Exception ex) { //写日志 ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() { Search1 = "JoinGroup", Search2 = string.Empty, ClassName = _className, Method = "JoinGroup", Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), RequestModel = string.Empty, ResponseModel = "加入案件组", ElapsedTime = 0, Code = InterfaceName.ChatHub_RegisterUser.GetHashCode(), InterfaceNameEnum = InterfaceName.ChatHub_RegisterUser, ProjectId = ProjectIdEnum.LDApi.GetHashCode(), ResultCode = 200, Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, RowStatus = TrueOrFalseEnum.True.GetHashCode(), CreatedBy = "system", CreatedOn = DateTime.Now }); } return isSucceed; } /// <summary> /// 退出案件组 /// </summary> /// <param name="lawcaseId"></param> /// <param name="userId"></param> /// <returns></returns> public bool RemoveGroup(string lawcaseId, string userId)//, IGroupManager Groups { var isSucceed = false; try { if (!string.IsNullOrEmpty(lawcaseId) && !string.IsNullOrEmpty(userId)) { if (_GroupList.ContainsKey(lawcaseId)) { var userList = _GroupList[lawcaseId]; if (userList != null) { var userModel = userList.FirstOrDefault(t => t.F_Id.Equals(userId)); if (userModel == null) { isSucceed = userList.Remove(userModel); //Groups.RemoveFromGroupAsync(userModel.ConnectionId, lawcaseId); var tasl = SendPrivateMsg(userId, userModel.F_RealName, userModel.F_RealName + "用户退出案件组", _sendUser, _sendUser); //tasl.Wait(); } else { //Clients.Client(Context.ConnectionId).showMessage("该房间不存在"); var tasl = SendPrivateMsg(userId, userModel.F_RealName, "该用户不在案件组中", _sendUser, _sendUser); //tasl.Wait(); } } } //else //{ // var tasl = SendPrivateMsg(userId, "该房间不存在", _sendUser, _sendUser); // tasl.Wait(); //} } } catch (Exception ex) { //写日志 ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() { Search1 = "RemoveGroup", Search2 = string.Empty, ClassName = _className, Method = "RemoveGroup", Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), RequestModel = string.Empty, ResponseModel = string.Empty, ElapsedTime = 0, Code = InterfaceName.ChatHub_RegisterUser.GetHashCode(), InterfaceNameEnum = InterfaceName.ChatHub_RegisterUser, ProjectId = ProjectIdEnum.LDApi.GetHashCode(), ResultCode = 200, Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, RowStatus = TrueOrFalseEnum.True.GetHashCode(), CreatedBy = "system", CreatedOn = DateTime.Now }); } return isSucceed; } /// <summary> /// 根扰连接ID获取在线用户对象 /// </summary> /// <param name="connectionId"></param> /// <returns></returns> public OnlineUserModel GetUserByConnectionId(string connectionId) { OnlineUserModel model = null; try { if (!string.IsNullOrEmpty(connectionId)) { model = _OnlineUser.Find(t => t.ConnectionId == connectionId); } } catch (Exception ex) { //写日志 ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() { Search1 = "GetUserByConnectionId", Search2 = string.Empty, ClassName = _className, Method = "GetUserByConnectionId", Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), RequestModel = string.Empty, ResponseModel = string.Empty, ElapsedTime = 0, Code = InterfaceName.ChatHub_RegisterUser.GetHashCode(), InterfaceNameEnum = InterfaceName.ChatHub_RegisterUser, ProjectId = ProjectIdEnum.LDApi.GetHashCode(), ResultCode = 200, Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, RowStatus = TrueOrFalseEnum.True.GetHashCode(), CreatedBy = "system", CreatedOn = DateTime.Now }); } return model; } /// <summary> /// 根扰连接ID获取在线用户对象 /// </summary> /// <param name="userId"></param> /// <returns></returns> public OnlineUserModel GetUserByUserId(string userId) { OnlineUserModel model = null; try { if (!string.IsNullOrEmpty(userId)) { model = _OnlineUser.Find(t => t.F_Id == userId); } } catch (Exception ex) { //写日志 ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() { Search1 = "GetUserByUserId", Search2 = string.Empty, ClassName = _className, Method = "GetUserByUserId", Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), RequestModel = string.Empty, ResponseModel = string.Empty, ElapsedTime = 0, Code = InterfaceName.ChatHub_RegisterUser.GetHashCode(), InterfaceNameEnum = InterfaceName.ChatHub_RegisterUser, ProjectId = ProjectIdEnum.LDApi.GetHashCode(), ResultCode = 200, Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, RowStatus = TrueOrFalseEnum.True.GetHashCode(), CreatedBy = "system", CreatedOn = DateTime.Now }); } return model; } /// <summary> /// 公共消息 /// </summary> /// <param name="message"></param> /// <param name="sendUserId"></param> /// <param name="sendUserName"></param> /// <returns></returns> public bool SendPublicMsg(string message, string sendUserId, string sendUserName) { // 后期考虑后台管理添加系统通知，这里来查 通知到链接的人 var isSucceed = false; var hubClients = GetClient(); if (hubClients != null) { if (string.IsNullOrEmpty(sendUserName)) { sendUserName = _sendUser; } var msgModel = new MessageModel() { SendUserID = sendUserId, SendUserName = sendUserName, Msg = message, Type = MessageTypeEnum.System.GetHashCode() }; var t1 = hubClients.All.SendAsync(_receiveMsgmethod, sendUserName, msgModel);// new { Msg = message, Direct = 0 } this.InsertMessage(0, sendUserId, sendUserName, "ALL", "ALL", message); //添加历史记录 isSucceed = true; //await Task.WhenAll(t1); } return isSucceed; } /// <summary> /// 公共消息 /// </summary> /// <param name="message"></param> /// <param name="sendUserId"></param> /// <param name="sendUserName"></param> /// <returns></returns> public bool SendPublicMsg(string method, string message, string sendUserId, string sendUserName) { // 后期考虑后台管理添加系统通知，这里来查 通知到链接的人 var isSucceed = false; var hubClients = GetClient(); if (hubClients != null) { if (string.IsNullOrEmpty(sendUserName)) { sendUserName = _sendUser; } var msgModel = new MessageModel() { SendUserID = sendUserId, SendUserName = sendUserName, Msg = message, Type = MessageTypeEnum.System.GetHashCode() }; var t1 = hubClients.All.SendAsync(method, sendUserName, msgModel);// new { Msg = message, Direct = 0 } this.InsertMessage(0, sendUserId, sendUserName, "ALL", "ALL", message); //添加历史记录 isSucceed = true; //await Task.WhenAll(t1); } return isSucceed; } /// <summary> /// 私聊 /// </summary> /// <param name="receiveUserId">接收人ID</param> /// <param name="receiveUserName">接收人姓名</param> /// <param name="message">发送的消息</param> /// <param name="sendUserId">发送人ID</param> /// <param name="sendUserName">发送人姓名</param> /// <returns></returns> public bool SendPrivateMsg(string receiveUserId, string receiveUserName, string message, string sendUserId, string sendUserName) { var isSucceed = false; var hubClients = GetClient(receiveUserId); if (hubClients != null && !string.IsNullOrEmpty(receiveUserId) && !string.IsNullOrEmpty(message)) { var model = GetUserByUserId(receiveUserId); if (model != null) { //model.HubClients.Client(model.ConnectionId) ok //var t2 = model.HubClients.Client(model.ConnectionId).SendAsync(_receiveMsgmethod, sendUserName, message);//new MessageModel() { UserID = sendUserId, Name = sendUserName, Msg = message, Direct = 2 } //hubClients.Client(model.ConnectionId) ok //var t1 = hubClients.Client(model.ConnectionId).SendAsync(_receiveMsgmethod, sendUserName, message);// var msgModel = new MessageModel() { SendUserID = sendUserId, SendUserName = sendUserName, Msg = message, Type = MessageTypeEnum.SendMsg.GetHashCode() }; var t1 = hubClients.Client(model.ConnectionId).SendAsync(_receiveMsgmethod, sendUserName, msgModel); this.InsertMessage(1, sendUserId, sendUserName, receiveUserId, receiveUserName, message); //await Task.WhenAll(t1); isSucceed = true; } } return isSucceed; } /// <summary> /// 私聊 /// </summary> /// <param name="receiveUserId">接收人ID</param> /// <param name="receiveUserName">接收人姓名</param> /// <param name="message">发送的消息</param> /// <param name="sendUserId">发送人ID</param> /// <param name="sendUserName">发送人姓名</param> /// <returns></returns> public bool SendPrivateMsg(string receiveUserId, string receiveUserName, MessageModel message, string sendUserId, string sendUserName) { var isSucceed = false; var hubClients = GetClient(receiveUserId); if (hubClients != null && !string.IsNullOrEmpty(receiveUserId) && message != null) { var model = GetUserByUserId(receiveUserId); if (model != null) { var t1 = hubClients.Client(model.ConnectionId).SendAsync(_receiveMsgmethod, sendUserName, message); this.InsertMessage(1, sendUserId, sendUserName, receiveUserId, receiveUserName, JsonConvert.SerializeObject(message)); //await Task.WhenAll(t1); isSucceed = true; } } return isSucceed; } /// <summary> /// 给指定房间内所有用户发消息 /// </summary> /// <param name="groupId">房间ID(组ID)</param> /// <param name="message">发送的消息</param> /// <param name="sendUserId">发送人ID</param> /// <param name="sendUserName">发送姓名</param> /// <returns></returns> public bool SendGroupMsg(string groupId, string message, string sendUserId, string sendUserName) { var isSucceed = false; if (_hubClients != null && _GroupList.ContainsKey(groupId)) { var msgModel = new MessageModel() { SendUserID = sendUserId, SendUserName = sendUserName, Msg = message, Type = MessageTypeEnum.SendMsg.GetHashCode() }; var t1 = _hubClients.Group(groupId).SendAsync(_receiveMsgmethod, "Group(groupId):" + msgModel); //t1.Wait(); var groupUserList = _GroupList[groupId]; if (groupUserList != null && groupUserList.Count > 0) { groupUserList = groupUserList.FindAll(t => t != null && !string.IsNullOrEmpty(t.ConnectionId)); foreach (var item in groupUserList) { var t11 = SendPrivateMsg(item.F_Id, item.F_RealName, msgModel.Msg, sendUserId, sendUserName); this.InsertMessage(2, sendUserId, sendUserName, item.F_Id, item.F_RealName, message); //await Task.WhenAll(t11); } isSucceed = true; } } return isSucceed; } /// <summary> /// 保存消息记录 /// </summary> /// <param name="type"></param> /// <param name="sendUserId"></param> /// <param name="sendUserName"></param> /// <param name="receiveUserId"></param> /// <param name="receiveUserName"></param> /// <param name="msg"></param> /// <returns></returns> /// <exception cref="NotImplementedException"></exception> private bool InsertMessage(int type, string sendUserId, string sendUserName, string receiveUserId, string receiveUserName, string msg) { var isOk = false; try { var msgModel = new Message(); msgModel.Id = Guid.NewGuid().ToString("N"); msgModel.Type = type; msgModel.SendUserId = sendUserId; msgModel.SendUserName = sendUserName; msgModel.ReceiveUserId = receiveUserId; msgModel.ReceiveUserName = receiveUserName; msgModel.MsgContent = msg; msgModel.IsRead = TrueOrFalseEnum.False.GetHashCode(); msgModel.RowStatus = TrueOrFalseEnum.True.GetHashCode(); msgModel.Remark = string.Empty; msgModel.CreatedOn = DateTime.Now; msgModel.CreatedBy = sendUserId; msgModel.UpdatedBy = string.Empty; msgModel.UpdatedOn = SystemConst.DateTimeDefault; //await SqlDapperHelper.ExecuteInsertAsync(msg); isOk = _serviceMessage.AddModel(msgModel); } catch (Exception ex) { //写日志 ApiLogQueueService.Instance.Enqueue(new ApiLogServiceModel() { Search1 = "InsertMessage", Search2 = string.Empty, ClassName = _className, Method = "InsertMessage", Type = ex == null ? ApiLogType.Common.GetHashCode() : ApiLogType.Error.GetHashCode(), RequestModel = string.Empty, ResponseModel = "保存消息记录", ElapsedTime = 0, Code = InterfaceName.ChatHub_RegisterUser.GetHashCode(), InterfaceNameEnum = InterfaceName.ChatHub_RegisterUser, ProjectId = ProjectIdEnum.LDApi.GetHashCode(), ResultCode = 200, Remark = ex != null ? string.Format("errorMsg:{0},Exception:{1}", ex.Message, ex.ToString()) : string.Empty, RowStatus = TrueOrFalseEnum.True.GetHashCode(), CreatedBy = "system", CreatedOn = DateTime.Now }); } return isOk; } /// <summary> /// 发送日程提醒 /// </summary> /// <param name="obj"></param> private void sendRemindSchedule(object obj) { try { //获取需要此人需要提醒的日程 DateTime startTime = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd HH:mm:00")); DateTime endTime = startTime.AddMinutes(5); //发送测试消息 //var msg = "[" + CommonHelp.ServiceIp + "]系统消息:现在是" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); //SendPublicMsg(msg, _sendUser, _sendUser); foreach (var item in _OnlineUser) { if (item != null && !string.IsNullOrEmpty(item.F_Id)) { var remindScheduleList = _userScheduleRemindService.GetRemindSchedule(item.F_Id, startTime, endTime); foreach (var itemRemindSchedule in remindScheduleList) { // IpAddress：日程ID Time：(2 天前 · 日历 · 2021年12月28日 16:00 - 2021年12月28日 18:00) var timestr = Common.DateStringFromNow(itemRemindSchedule.RemindTime) + "· 日历 ·" + itemRemindSchedule.F_StartTime.ToString("yyyy年MM月dd日 HH:00") + " - " + itemRemindSchedule.F_EndTime.ToString("yyyy年MM月dd日 HH:00"); var msgModel = new MessageModel() { SendUserID = item.F_Id, SendUserName = item.F_RealName, Time = timestr, Msg = itemRemindSchedule.F_Title, SendTime = DateTime.Now.ToDateTimeString(), F_Id = itemRemindSchedule.ReminbId.ToString(), Type = MessageTypeEnum.ScheduleRemindMsg.GetHashCode() }; var t = SendPrivateMsg(item.F_Id, item.F_RealName, msgModel, _sendUser, _sendUser); //t.Wait(); //标记为已提醒 _userScheduleRemindService.UpdateRemind(itemRemindSchedule.ReminbId, itemRemindSchedule.IsEdit); } } } } catch (Exception ex) { _operationLogService.AddLogError(_className, "sendRemindSchedule", ex.Message, ex); } } }
调用实例
/// <summary> /// 新建案件事务 提交 /// </summary> /// <param name="pinfo"></param> /// <returns></returns> [HttpPost] [NoLDAPPLoginFilter] public AjaxResult SubmitLawcase([FromBody] SubmitLawcaseViewModel pinfo) { var sw = new Stopwatch(); sw.Start(); Exception exception = null; var rspModel = new AjaxResult(); var loginUserId = CurrentUserId; try { var result = _serviceLawcase.SubmitLawcase(loginUserId, pinfo); if (!result.Item1) { return Error(result.Item2); } var lawcaseId = result.Item2; if (pinfo.JoinList != null && pinfo.JoinList.Count > 0) { //获取案由 string causename = ""; if(!string.IsNullOrEmpty(pinfo.CauseId)) { var causeModel = _serviceCause.GetById(pinfo.CauseId); causename = causeModel.F_Name; } else { causename = pinfo.InputCause; } foreach (var item in pinfo.JoinList) { OnlineUserService.Instance.JoinGroup(lawcaseId, item.UserId); } //var sendMsg = string.Format("{0}案件创建成功", causeModel != null ? causeModel.F_Name : pinfo.Desc); var sendMsg = string.Format("{0}案件创建成功", causename); var task = OnlineUserService.Instance.SendGroupMsg(lawcaseId, sendMsg, loginUserId, CurrentUserName); //task.Wait(); } //return Success(lawcaseId); rspModel.Success(lawcaseId); } catch (System.Exception ex) { //rspModel.Error("用户登录出错：", ex.Message); exception = ex; LogFactory.GetLogger("SubmitLawcase").Info("报错" + ex.Message); //return Error("新建案件事务 提交报错" + ex.Message); } AddLogElapsedTime(InterfaceName.Lawcase_SubmitLawcase, _className, "SubmitLawcase", pinfo, rspModel, rspModel.state, sw, exception, loginUserId); return rspModel; }
Startup 中注册
public void Configure(IApplicationBuilder app, IWebHostEnvironment env, IOptions<SenparcSetting> senparcSetting, IOptions<SenparcWeixinSetting> senparcWeixinSetting) { var apiUrlConfig = Configuration.GetSection("ApiUrl").Value; app.UseEndpoints(endpoints => { endpoints.MapGet("/", async context => { await Task.Run(() => { context.Response.Redirect("/index.html"); }); }); endpoints.MapControllers(); //endpoints.MapHub<ServerHub>("/serverHub").RequireCors(t => t.WithOrigins(new string[] { apiUrlConfig }).AllowAnyMethod().AllowAnyHeader().AllowCredentials()); endpoints.MapHub<ChatHub>("/chatHub").RequireCors(t => t.WithOrigins(new string[] { apiUrlConfig }).AllowAnyMethod().AllowAnyHeader().AllowCredentials()); //endpoints.MapHub<ChatHub>("/serverHub").RequireCors(t => t.WithOrigins(new string[] { apiUrlConfig }).AllowAnyMethod().AllowAnyHeader().AllowCredentials()); //endpoints.MapHub<ServerHub>("/serverHub").RequireCors(t => t.WithOrigins(new string[] { apiUrlConfig }).AllowAnyMethod().AllowAnyHeader().AllowCredentials()); }); }