|
|
@@ -48,12 +48,14 @@ public class SysMessageService : IDynamicApiController, ITransient
|
|
|
{
|
|
|
var cacheKey = CacheConst.KeyUserOnline + input.UserId;
|
|
|
// 是否开启单用户登录
|
|
|
- if (await _sysConfigService.GetConfigValue<bool>(CommonConst.SysSingleLogin))
|
|
|
+ if (await _sysConfigService.GetConfigValue<bool>(CommonConst.SysSingleLogin))
|
|
|
{
|
|
|
var user = _sysCacheService.Get<SysOnlineUser>(cacheKey);
|
|
|
if (user == null) return;
|
|
|
await _chatHubContext.Clients.AllExcept(user.ConnectionId).ReceiveMessage(input);
|
|
|
- } else {
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
var _cacheKeys = _sysCacheService.GetKeyList().Where(u => u.StartsWith(cacheKey)).ToArray();
|
|
|
foreach (var _cacheKey in _cacheKeys)
|
|
|
{
|
|
|
@@ -74,13 +76,13 @@ public class SysMessageService : IDynamicApiController, ITransient
|
|
|
{
|
|
|
var cacheKey = CacheConst.KeyUserOnline + input.UserId;
|
|
|
// 是否开启单用户登录
|
|
|
- if (await _sysConfigService.GetConfigValue<bool>(CommonConst.SysSingleLogin))
|
|
|
+ if (await _sysConfigService.GetConfigValue<bool>(CommonConst.SysSingleLogin))
|
|
|
{
|
|
|
var user = _sysCacheService.Get<SysOnlineUser>(cacheKey);
|
|
|
if (user == null) return;
|
|
|
await _chatHubContext.Clients.Client(user.ConnectionId).ReceiveMessage(input);
|
|
|
- }
|
|
|
- else
|
|
|
+ }
|
|
|
+ else
|
|
|
{
|
|
|
var _cacheKeys = _sysCacheService.GetKeyList().Where(u => u.StartsWith(cacheKey)).ToArray();
|
|
|
foreach (var _cacheKey in _cacheKeys)
|
|
|
@@ -105,12 +107,12 @@ public class SysMessageService : IDynamicApiController, ITransient
|
|
|
{
|
|
|
var cacheKey = CacheConst.KeyUserOnline + userId;
|
|
|
// 是否开启单用户登录
|
|
|
- if (await _sysConfigService.GetConfigValue<bool>(CommonConst.SysSingleLogin))
|
|
|
+ if (await _sysConfigService.GetConfigValue<bool>(CommonConst.SysSingleLogin))
|
|
|
{
|
|
|
var user = _sysCacheService.Get<SysOnlineUser>(cacheKey);
|
|
|
if (user != null) userList.Add(user.ConnectionId);
|
|
|
}
|
|
|
- else
|
|
|
+ else
|
|
|
{
|
|
|
var _cacheKeys = _sysCacheService.GetKeyList().Where(u => u.StartsWith(cacheKey)).ToArray();
|
|
|
foreach (var _cacheKey in _cacheKeys)
|