From 0e6f79c28ed2a29abc3146b7a8fbc0bd74cf7516 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=A9=99=E5=AD=90?= <454313500@qq.com> Date: Sat, 2 Nov 2024 15:48:28 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E8=B0=83=E6=95=B4=E6=8A=BD=E5=A5=96?= =?UTF-8?q?=E6=A6=82=E7=8E=87=EF=BC=8C=E6=8F=90=E9=AB=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Services/Integral/LuckyService.cs | 12 +++-------- .../BbsNoticeSendEventHandler.cs | 20 ++++++++++++++----- 2 files changed, 18 insertions(+), 14 deletions(-) diff --git a/Yi.Abp.Net8/module/bbs/Yi.Framework.Bbs.Application/Services/Integral/LuckyService.cs b/Yi.Abp.Net8/module/bbs/Yi.Framework.Bbs.Application/Services/Integral/LuckyService.cs index 9a2631c9..22efc4a2 100644 --- a/Yi.Abp.Net8/module/bbs/Yi.Framework.Bbs.Application/Services/Integral/LuckyService.cs +++ b/Yi.Abp.Net8/module/bbs/Yi.Framework.Bbs.Application/Services/Integral/LuckyService.cs @@ -16,7 +16,7 @@ namespace Yi.Framework.Bbs.Application.Services.Integral /// /// 大转盘 - /// Todo: 可放入领域层 + /// Todo: 可放入领域层，但是太简单了，不重要 /// /// [Authorize] @@ -32,13 +32,7 @@ namespace Yi.Framework.Bbs.Application.Services.Integral int[] values = new int[10] { 0, 10, 30, 50, 60, 80, 90, 100, 200, 666 }; var index = GetWheelIndex(); var value = values[index] - 50; - - ////不存在负数钱钱 - //if (value < 0) - //{ - // value = 0; - //} - + //修改钱钱，如果钱钱不足，直接会丢出去,那本次抽奖将无效 await _localEventBus.PublishAsync(new MoneyChangeEventArgs { UserId = CurrentUser.Id!.Value, Number = value }, false); @@ -47,7 +41,7 @@ namespace Yi.Framework.Bbs.Application.Services.Integral private int GetWheelIndex() { - int[] probabilities = { 30, 40, 30, 15, 15, 10, 4, 3, 2, 1 }; + int[] probabilities = {5 , 30, 40, 30, 20, 10, 4, 3, 2, 1 }; int total = 0; foreach (var prob in probabilities) diff --git a/Yi.Abp.Net8/module/bbs/Yi.Framework.Bbs.Domain/EventHandlers/BbsNoticeSendEventHandler.cs b/Yi.Abp.Net8/module/bbs/Yi.Framework.Bbs.Domain/EventHandlers/BbsNoticeSendEventHandler.cs index 8975592e..dc3043c6 100644 --- a/Yi.Abp.Net8/module/bbs/Yi.Framework.Bbs.Domain/EventHandlers/BbsNoticeSendEventHandler.cs +++ b/Yi.Abp.Net8/module/bbs/Yi.Framework.Bbs.Domain/EventHandlers/BbsNoticeSendEventHandler.cs @@ -25,14 +25,17 @@ namespace Yi.Framework.Bbs.Domain.EventHandlers } public async Task HandleEventAsync(BbsNoticeEventArgs eventData) { - //离线存储 - var entity= await _repository.InsertReturnEntityAsync(new BbsNoticeAggregateRoot(eventData.NoticeType, eventData.Message, eventData.AcceptUserId)); - switch (eventData.NoticeType) + + + //是否需要离线存储 + bool isStore = true; + var now = DateTime.Now; + switch (eventData.NoticeType) { case Shared.Enums.NoticeTypeEnum.Personal: if (BbsNoticeHub.HubUserModels.TryGetValue(eventData.AcceptUserId.ToString(), out var hubUserModel)) { - _hubContext.Clients.Client(hubUserModel.ConnnectionId).SendAsync(NoticeTypeEnum.Personal.ToString(), eventData.Message,entity.CreationTime); + _hubContext.Clients.Client(hubUserModel.ConnnectionId).SendAsync(NoticeTypeEnum.Personal.ToString(), eventData.Message,now); } break; case Shared.Enums.NoticeTypeEnum.Broadcast: @@ -42,13 +45,20 @@ namespace Yi.Framework.Bbs.Domain.EventHandlers case Shared.Enums.NoticeTypeEnum.Money: if (BbsNoticeHub.HubUserModels.TryGetValue(eventData.AcceptUserId.ToString(), out var hubUserModel2)) { - _hubContext.Clients.Client(hubUserModel2.ConnnectionId).SendAsync(NoticeTypeEnum.Money.ToString(), eventData.Message,entity.CreationTime); + _hubContext.Clients.Client(hubUserModel2.ConnnectionId).SendAsync(NoticeTypeEnum.Money.ToString(), eventData.Message,now); } + + isStore = false; break; default: break; } + if (isStore) + { //离线存储 + var entity= await _repository.InsertReturnEntityAsync(new BbsNoticeAggregateRoot(eventData.NoticeType, eventData.Message, eventData.AcceptUserId){CreationTime = now}); + } + } } }