41 lines
1.7 KiB
C#
41 lines
1.7 KiB
C#
using Volo.Abp;
|
||
using Volo.Abp.DependencyInjection;
|
||
using Volo.Abp.EventBus;
|
||
using Volo.Abp.EventBus.Local;
|
||
using Yi.Framework.Bbs.Domain.Entities;
|
||
using Yi.Framework.Bbs.Domain.Shared.Consts;
|
||
using Yi.Framework.Bbs.Domain.Shared.Enums;
|
||
using Yi.Framework.Bbs.Domain.Shared.Etos;
|
||
using Yi.Framework.SqlSugarCore.Abstractions;
|
||
|
||
namespace Yi.Framework.Bbs.Domain.EventHandlers
|
||
{
|
||
public class MoneyChangeEventHandler : ILocalEventHandler<MoneyChangeEventArgs>, ITransientDependency
|
||
{
|
||
private ISqlSugarRepository<BbsUserExtraInfoEntity> _userInfoRepository;
|
||
private ILocalEventBus _localEventBus;
|
||
public MoneyChangeEventHandler(ISqlSugarRepository<BbsUserExtraInfoEntity> userInfoRepository, ILocalEventBus localEventBus)
|
||
{
|
||
_userInfoRepository = userInfoRepository;
|
||
_localEventBus = localEventBus;
|
||
}
|
||
public async Task HandleEventAsync(MoneyChangeEventArgs eventData)
|
||
{
|
||
var userIfno = await _userInfoRepository.GetFirstAsync(x => x.UserId == eventData.UserId);
|
||
|
||
//如果变化后的钱钱少于0，直接丢出去
|
||
if ((userIfno.Money + eventData.Number)<0)
|
||
{
|
||
throw new UserFriendlyException(MoneyConst.Money_Low_Zero);
|
||
}
|
||
//原子性sql
|
||
await _userInfoRepository._Db.Updateable<BbsUserExtraInfoEntity>()
|
||
.SetColumns(it => it.Money == it.Money + eventData.Number)
|
||
.Where(x => x.UserId == eventData.UserId).ExecuteCommandAsync();
|
||
|
||
|
||
await _localEventBus.PublishAsync(new BbsNoticeEventArgs(NoticeTypeEnum.Money, eventData.UserId,eventData.Number.ToString()), false);
|
||
}
|
||
}
|
||
}
|