From 96bfcd8a3c8a5f7d383d2c890e0c9b59ee34b7c1 Mon Sep 17 00:00:00 2001
From: dengjunjie <dengjunjie@hnkhzn.com>
Date: 星期六, 01 十一月 2025 19:22:35 +0800
Subject: [PATCH] 优化代码
---
新建文件夹/WIDESEA_WMSServer/WIDESEA_Core/Extensions/WebSocketHostedService.cs | 44 ++++++++++++++++++++++----------------------
1 files changed, 22 insertions(+), 22 deletions(-)
diff --git "a/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/WIDESEA_Core/Extensions/WebSocketHostedService.cs" "b/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/WIDESEA_Core/Extensions/WebSocketHostedService.cs"
index 686f7e5..07e73f2 100644
--- "a/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/WIDESEA_Core/Extensions/WebSocketHostedService.cs"
+++ "b/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/WIDESEA_Core/Extensions/WebSocketHostedService.cs"
@@ -57,28 +57,28 @@
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;
}
--
Gitblit v1.9.3