From 7ab893e5176a5fc328d3c0926ffc95fe3c73d57e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=82=B9=E6=BD=87=E9=98=B3?= <wanna_zxy@yeah.net>
Date: Fri, 26 Jan 2024 18:06:48 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0websocket=E6=97=A5=E5=BF=97?=
 =?UTF-8?q?=E8=BE=93=E5=87=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 24Hour/Controllers/Common/WebSocketController.cs | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git a/24Hour/Controllers/Common/WebSocketController.cs b/24Hour/Controllers/Common/WebSocketController.cs
index b750e16..486d91a 100644
--- a/24Hour/Controllers/Common/WebSocketController.cs
+++ b/24Hour/Controllers/Common/WebSocketController.cs
@@ -25,7 +25,7 @@ namespace _24Hour.Controllers.Common
     {
         private readonly SqlSugarClient _db;//数据库
         App_Sys_UserModel _userdata = new App_Sys_UserModel();//当前用户
-        private readonly ILogger<LoginController> _logger;//日志
+        private readonly ILogger<LoginController> logger;//日志
         private readonly IConfiguration _configuration;
         private static object obj = new object();
         private readonly WechatMessagerClient _wechatMessagerClient;
@@ -33,10 +33,13 @@ namespace _24Hour.Controllers.Common
         private static Dictionary<string, WebSocket> CONNECT_POOL = new Dictionary<string, WebSocket>();//用户连接池
         private static Dictionary<string, Addressda> meeting_pool = new Dictionary<string, Addressda>();//会议连接池
         private static Dictionary<string, string> userzx = new Dictionary<string, string>();//检察官在线池
+
+
+        
         //private static Dictionary<string, List<MessageInfo>> MESSAGE_POOL = new Dictionary<string, List<MessageInfo>>();//离线消息池
-        public WebSocketController(ILogger<LoginController> logger, SqlSugarClient db, User userdata, WechatMessagerClient wechatMessagerClient, IConfiguration configuration)
+        public WebSocketController(ILogger<LoginController> _logger, SqlSugarClient db, User userdata, WechatMessagerClient wechatMessagerClient, IConfiguration configuration)
         {
-            _logger = logger;
+            logger = _logger;
             _db = db;
             _userdata = userdata.Userdata();
             _configuration = configuration;
@@ -71,7 +74,7 @@ namespace _24Hour.Controllers.Common
                     if (socket != CONNECT_POOL[user])//当前对象不一致，更新
                     CONNECT_POOL[user] = socket;
                 #endregion
-
+                logger.LogInformation($"{user} connected");
                 string descUser = string.Empty;//目的用户
                 while (true)
                 {
@@ -96,10 +99,12 @@ namespace _24Hour.Controllers.Common
                         {
                             var data = Encoding.UTF8.GetString(buffer);
                             Console.WriteLine(data);
+                            logger.LogInformation($"{user} disconnected");
                         }
                     }
                     else
                     {
+                        logger.LogInformation($"{user} disconnected");
                         Console.WriteLine("断开连接");
                         break;
                     }
@@ -123,6 +128,7 @@ namespace _24Hour.Controllers.Common
         {
             try
             {
+                logger.LogInformation($"send data [{Sendingdata.ConvertToJsonStr()}]");
                 //获取发送人连接
                 var socket = CONNECT_POOL.Where(q => q.Key == _userdata.Id).Select(q => q.Value).FirstOrDefault();
                 if (socket!=null&&socket.State == WebSocketState.Open)