From 3b93e8b8ec58f490e2b0070462386c28231b6e04 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=A9=99=E5=AD=90?= <454313500@qq.com> Date: Sat, 9 Nov 2024 00:00:02 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E7=BC=93=E5=AD=98?= =?UTF-8?q?=E6=89=B9=E9=87=8F=E5=88=A0=E9=99=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Managers/MiningPoolManager.cs | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) diff --git a/Yi.Abp.Net8/module/digital-collectibles/Yi.Framework.DigitalCollectibles.Domain/Managers/MiningPoolManager.cs b/Yi.Abp.Net8/module/digital-collectibles/Yi.Framework.DigitalCollectibles.Domain/Managers/MiningPoolManager.cs index f4bf728d..6e0a19a2 100644 --- a/Yi.Abp.Net8/module/digital-collectibles/Yi.Framework.DigitalCollectibles.Domain/Managers/MiningPoolManager.cs +++ b/Yi.Abp.Net8/module/digital-collectibles/Yi.Framework.DigitalCollectibles.Domain/Managers/MiningPoolManager.cs @@ -282,7 +282,6 @@ public class MiningPoolManager : DomainService { _logger.LogInformation($"自动挖矿-{onHookItem.Value.UserId},{e.Message}"); } - } } @@ -334,8 +333,9 @@ public class MiningPoolManager : DomainService public async Task RefreshMiningPoolAsync() { //获取当前最大的限制 - // var maximumPoolLimit = int.Parse(await _settingProvider.GetOrNullAsync("MaxPoolLimit")); - var poolData = (await _settingProvider.GetOrNullAsync("PoolData")).Split(',').Select(x=>int.Parse(x)).ToList(); + // var maximumPoolLimit = int.Parse(await _settingProvider.GetOrNullAsync("MaxPoolLimit")); + var poolData = (await _settingProvider.GetOrNullAsync("PoolData")).Split(',').Select(x => int.Parse(x)) + .ToList(); DateTime startTime = DateTime.Today.AddHours(10); DateTime endTime = startTime.AddDays(1); // var probabilityValues = RarityEnumExtensions.GetProbabilityArray(); @@ -368,13 +368,17 @@ public class MiningPoolManager : DomainService /// private string CacheKeyPrefix => LazyServiceProvider.LazyGetRequiredService>() .Value.KeyPrefix; + /// /// 刷新用户挖矿限制 /// public async Task RefreshMiningUserLimitAsync() { - - await RedisClient.DelAsync($"{CacheKeyPrefix}{MiningCacheConst.UserMiningLimit}*"); + var needKeys = await RedisClient.KeysAsync($"{CacheKeyPrefix}{MiningCacheConst.UserMiningLimit}*"); + foreach (var needKey in needKeys) + { + await RedisClient.DelAsync(needKey); + } } ///