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);
        }
    }
}