Просмотр исходного кода

😁调整在线用户和消息发送相关代码

zuohuaijun 2 лет назад
Родитель
Сommit
54585d7b28

+ 1 - 1
Admin.NET/Admin.NET.Core/Admin.NET.Core.csproj

@@ -37,7 +37,7 @@
     <PackageReference Include="OnceMi.AspNetCore.OSS" Version="1.1.9" />
     <PackageReference Include="SKIT.FlurlHttpClient.Wechat.Api" Version="2.34.0" />
     <PackageReference Include="SKIT.FlurlHttpClient.Wechat.TenpayV3" Version="2.20.1" />
-    <PackageReference Include="SqlSugarCore" Version="5.1.4.113" />
+    <PackageReference Include="SqlSugarCore" Version="5.1.4.114" />
     <PackageReference Include="System.Linq.Dynamic.Core" Version="1.3.5" />
     <PackageReference Include="UAParser" Version="3.1.47" />
     <PackageReference Include="Yitter.IdGenerator" Version="1.0.14" />

+ 2 - 2
Admin.NET/Admin.NET.Core/EventBus/AppEventSubscriber.cs

@@ -29,8 +29,8 @@ public class AppEventSubscriber : IEventSubscriber, ISingleton, IDisposable
     [EventSubscribe("Add:ExLog")]
     public async Task CreateExLog(EventHandlerExecutingContext context)
     {
-        var _rep = _serviceScope.ServiceProvider.GetRequiredService<SqlSugarRepository<SysLogEx>>();
-        await _rep.InsertAsync((SysLogEx)context.Source.Payload);
+        var rep = _serviceScope.ServiceProvider.GetRequiredService<SqlSugarRepository<SysLogEx>>();
+        await rep.InsertAsync((SysLogEx)context.Source.Payload);
     }
 
     /// <summary>

+ 6 - 6
Admin.NET/Admin.NET.Core/Hub/OnlineUserHub.cs

@@ -61,9 +61,9 @@ public class OnlineUserHub : Hub<IOnlineUserHub>
             TenantId = string.IsNullOrWhiteSpace(tenantId) ? 0 : Convert.ToInt64(tenantId),
         };
         await _sysOnlineUerRep.InsertAsync(user);
-        //缓存
         _sysCacheService.Set(CacheConst.KeyUserOnline + user.UserId, user);
-        // 以租户Id分组方便区分
+
+        // 以租户Id进行分组
         var groupName = $"{GROUP_ONLINE}{user.TenantId}";
         await _onlineUserHubContext.Groups.AddToGroupAsync(Context.ConnectionId, groupName);
 
@@ -114,7 +114,7 @@ public class OnlineUserHub : Hub<IOnlineUserHub>
     }
 
     /// <summary>
-    /// 前端调用发送方法(发送信息给某个人
+    /// 发送信息给某个人
     /// </summary>
     /// <param name="message"></param>
     /// <returns></returns>
@@ -124,7 +124,7 @@ public class OnlineUserHub : Hub<IOnlineUserHub>
     }
 
     /// <summary>
-    /// 前端调用发送方法(发送信息给所有人
+    /// 发送信息给所有人
     /// </summary>
     /// <param name="message"></param>
     /// <returns></returns>
@@ -134,7 +134,7 @@ public class OnlineUserHub : Hub<IOnlineUserHub>
     }
 
     /// <summary>
-    /// 前端调用发送方法(发送消息给除了发送人的其他人)
+    /// 发送消息给某些人(除了本人)
     /// </summary>
     /// <param name="message"></param>
     /// <returns></returns>
@@ -144,7 +144,7 @@ public class OnlineUserHub : Hub<IOnlineUserHub>
     }
 
     /// <summary>
-    /// 前端调用发送方法(发送消息给某些人
+    /// 发送消息给某些人
     /// </summary>
     /// <param name="message"></param>
     /// <returns></returns>