xwl2023/Yi.Framework
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 修复缓存批量删除

Browse Source
This commit is contained in:
橙子
2024-11-09 00:00:02 +08:00
parent 24cf087320
commit 3b93e8b8ec
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
Yi.Abp.Net8/module/digital-collectibles/Yi.Framework.DigitalCollectibles.Domain/Managers/MiningPoolManager.cs
View File

@@ -282,7 +282,6 @@ public class MiningPoolManager : DomainService
{ {
_logger.LogInformation($"自动挖矿-{onHookItem.Value.UserId},{e.Message}"); _logger.LogInformation($"自动挖矿-{onHookItem.Value.UserId},{e.Message}");
} }
} }
} }
@@ -334,8 +333,9 @@ public class MiningPoolManager : DomainService
public async Task RefreshMiningPoolAsync() public async Task RefreshMiningPoolAsync()
{ {
//获取当前最大的限制 //获取当前最大的限制
// var maximumPoolLimit = int.Parse(await _settingProvider.GetOrNullAsync("MaxPoolLimit")); // var maximumPoolLimit = int.Parse(await _settingProvider.GetOrNullAsync("MaxPoolLimit"));
var poolData = (await _settingProvider.GetOrNullAsync("PoolData")).Split(',').Select(x=>int.Parse(x)).ToList(); var poolData = (await _settingProvider.GetOrNullAsync("PoolData")).Split(',').Select(x => int.Parse(x))
.ToList();
DateTime startTime = DateTime.Today.AddHours(10); DateTime startTime = DateTime.Today.AddHours(10);
DateTime endTime = startTime.AddDays(1); DateTime endTime = startTime.AddDays(1);
// var probabilityValues = RarityEnumExtensions.GetProbabilityArray(); // var probabilityValues = RarityEnumExtensions.GetProbabilityArray();
@@ -368,13 +368,17 @@ public class MiningPoolManager : DomainService
/// </summary> /// </summary>
private string CacheKeyPrefix => LazyServiceProvider.LazyGetRequiredService<IOptions<AbpDistributedCacheOptions>>() private string CacheKeyPrefix => LazyServiceProvider.LazyGetRequiredService<IOptions<AbpDistributedCacheOptions>>()
.Value.KeyPrefix; .Value.KeyPrefix;
/// <summary> /// <summary>
/// 刷新用户挖矿限制 /// 刷新用户挖矿限制
/// </summary> /// </summary>
public async Task RefreshMiningUserLimitAsync() public async Task RefreshMiningUserLimitAsync()
{ {
var needKeys = await RedisClient.KeysAsync($"{CacheKeyPrefix}{MiningCacheConst.UserMiningLimit}*");
await RedisClient.DelAsync($"{CacheKeyPrefix}{MiningCacheConst.UserMiningLimit}*"); foreach (var needKey in needKeys)
{
await RedisClient.DelAsync(needKey);
}
} }
/// <summary> /// <summary>