| | |
|---|
| | | |
|---|
| | | public async Task StartAsync(CancellationToken cancellationToken) |
|---|
| | | { |
|---|
| | | WebSocketSession? webSocketSession = _webSocketServer.OnlineSessions.FirstOrDefault(x => x.Url.Contains(App.User.UserName)); |
|---|
| | | string MessageInfo = _cacheService.Get("MessageInfo"); |
|---|
| | | if (!string.IsNullOrEmpty(MessageInfo)) |
|---|
| | | { |
|---|
| | | List<Message>? messages = JsonConvert.DeserializeObject<List<Message>>(MessageInfo); |
|---|
| | | if (messages != null && messages.Count > 0) |
|---|
| | | { |
|---|
| | | foreach (var item in messages) |
|---|
| | | { |
|---|
| | | object obj = new |
|---|
| | | { |
|---|
| | | title = item.MessageGroupBy, |
|---|
| | | name = item.MessageName, |
|---|
| | | message = item.MessageInfo, |
|---|
| | | date = item.Date, |
|---|
| | | }; |
|---|
| | | //_webSocketServer.PublishAllClientPayload(obj.Serialize()); |
|---|
| | | if (webSocketSession != null) |
|---|
| | | _webSocketServer.SendClientPayload(webSocketSession, obj.Serialize()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //WebSocketSession? webSocketSession = _webSocketServer.OnlineSessions.FirstOrDefault(x => x.Url.Contains(App.User.UserName)); |
|---|
| | | //string MessageInfo = _cacheService.Get("MessageInfo"); |
|---|
| | | //if (!string.IsNullOrEmpty(MessageInfo)) |
|---|
| | | //{ |
|---|
| | | // List<Message>? messages = JsonConvert.DeserializeObject<List<Message>>(MessageInfo); |
|---|
| | | // if (messages != null && messages.Count > 0) |
|---|
| | | // { |
|---|
| | | // foreach (var item in messages) |
|---|
| | | // { |
|---|
| | | // object obj = new |
|---|
| | | // { |
|---|
| | | // title = item.MessageGroupBy, |
|---|
| | | // name = item.MessageName, |
|---|
| | | // message = item.MessageInfo, |
|---|
| | | // date = item.Date, |
|---|
| | | // }; |
|---|
| | | // //_webSocketServer.PublishAllClientPayload(obj.Serialize()); |
|---|
| | | // if (webSocketSession != null) |
|---|
| | | // _webSocketServer.SendClientPayload(webSocketSession, obj.Serialize()); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | //} |
|---|
| | | await Task.CompletedTask; |
|---|
| | | } |
|---|
| | | |
|---|
