server/CloudGaming
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改问题

Browse Source
This commit is contained in:
zpc 2024-11-13 22:36:33 +08:00
parent a5c5fc72db
commit c57a377d7a
3 changed files with 42 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/CloudGaming/Code/CloudGaming.Code/Account/AccountBLL.cs
View File

@ -129,10 +129,9 @@ namespace CloudGaming.Code.Account
//创建设备号
var dev = await ManageUserDevicesAsync(user, account, jwt.AccessToken);
var key = $"user:login:{user.Id}";
var accountUserLoginInfos = await RedisCache.StringGetAsync<List<AccountUserLoginInfo>>(key);
accountUserLoginInfos ??= new List<AccountUserLoginInfo>();
//创建redis缓存
await RedisCache.StringSetAsync(key, $"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}", TimeSpan.FromHours(1));
await RedisCache.StringSetAsync(key, $"1", TimeSpan.FromHours(1));
//accountUserLoginInfos.Add(new AccountUserLoginInfo());
T_User_Login_Log login_Log = new T_User_Login_Log()
{
@ -221,7 +220,7 @@ namespace CloudGaming.Code.Account
}
// 管理用户设备
private async Task<T_User_Token> ManageUserDevicesAsync(T_User user, IUserAccount account, string accessToken)
private async Task<List<T_User_Token>> ManageUserDevicesAsync(T_User user, IUserAccount account, string accessToken)
{
var currentTime = DateTime.Now;
var dev = string.IsNullOrEmpty(account.DeviceNumber)
@ -265,7 +264,7 @@ namespace CloudGaming.Code.Account
TokenMd5 = MD5Encryption.ComputeMD5Hash(accessToken)
};
await Dao.DaoUser.Context.T_User_Token.AddAsync(existingDevice);
userLoginList.Add(existingDevice);
}
}
else
@ -275,7 +274,7 @@ namespace CloudGaming.Code.Account
}
await Dao.DaoUser.Context.SaveChangesAsync();
return existingDevice;
return userLoginList;
}
// 更新设备令牌信息

6
src/CloudGaming/Model/CloudGaming.Model/DbSqlServer/Db_Phone/CloudGamingPhoneContext.cs
View File

@ -1,5 +1,6 @@
using System;
using System;
using System.Collections.Generic;
using Microsoft.EntityFrameworkCore;
namespace CloudGaming.Model.DbSqlServer.Db_Phone;
@ -144,7 +145,8 @@ public partial class CloudGamingPhoneContext : MultiTenantDbContext//DbContext
public virtual DbSet<T_Videos> T_Videos { get; set; }
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
=> optionsBuilder.UseSqlServer("Server=192.168.1.17;Database=CloudGamingPhone;User Id=sa;Password=Dbt@com@123;TrustServerCertificate=true;");
{ }
//=> optionsBuilder.UseSqlServer("Server=192.168.1.17;Database=CloudGamingPhone;User Id=sa;Password=Dbt@com@123;TrustServerCertificate=true;");
protected override void OnModelCreating(ModelBuilder modelBuilder)
{

34
src/CloudGaming/Utile/HuanMeng.DotNetCore/Redis/RedisConnection.cs
View File

@ -25,6 +25,8 @@ namespace HuanMeng.DotNetCore.Redis
/// </summary>
public static ConcurrentDictionary<string, IDatabase> Redis { get; set; } = new ConcurrentDictionary<string, IDatabase>();
public static ConcurrentDictionary<string, IServer> RedisServer { get; set; } = new ConcurrentDictionary<string, IServer>();
/// <summary>
///
@ -37,11 +39,29 @@ namespace HuanMeng.DotNetCore.Redis
{
var redis = ConnectionMultiplexer.Connect(redisConnection);
database = redis.GetDatabase();
//server.key
//redis.GetServer()
Redis.TryAdd(redisConnection, database);
}
return database;
}
/// <summary>
///
/// </summary>
/// <param name="redisConnection"></param>
/// <returns></returns>
public static IServer GetServer(string redisConnection)
{
if (!RedisServer.TryGetValue(redisConnection, out var server))
{
var redis = ConnectionMultiplexer.Connect(redisConnection);
server = redis.GetServer("", "");
//server.key
//redis.GetServer()
RedisServer.TryAdd(redisConnection, server);
}
return server;
}
/// <summary>
///
@ -112,5 +132,17 @@ namespace HuanMeng.DotNetCore.Redis
// 将 RedisValue 转换为 T 类型
return JsonConvert.DeserializeObject<T>(value);
}
/// <summary>
/// 模糊查询key
/// </summary>
/// <param name="server"></param>
/// <param name="pattern"></param>
/// <param name="pageSize"></param>
/// <returns></returns>
public static List<string> ScanKeys(this IServer server, string pattern, int pageSize = 100)
{
var matchingKeys = server.Keys(pattern: pattern).Select(it => it.ToString()).ToList();
return matchingKeys;
}
}
}