From 7b4954bbf842d0a1661da4362e159d672fbc3e73 Mon Sep 17 00:00:00 2001 From: lwl0608 Date: Wed, 13 Mar 2024 21:06:00 +0800 Subject: [PATCH] fix streamer id --- app/mix/service/logic/vas.go | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/app/mix/service/logic/vas.go b/app/mix/service/logic/vas.go index 9efbf28c..f2cc1638 100644 --- a/app/mix/service/logic/vas.go +++ b/app/mix/service/logic/vas.go @@ -2580,29 +2580,29 @@ func (v *Vas) refundMembership(ctx *gin.Context, order *dbstruct.Order, req *vas // 有分成的情况 if len(incomeChList) > 0 { ch := incomeChList[0] - uid := ch.GetUid() - if uid <= 0 { - err = errors.New("收入uid错误") - logger.Error("invalid uid: %v", uid) + streamerMid := ch.GetMid() + if streamerMid <= 0 { + err = errors.New("收入streamerMid错误") + logger.Error("invalid streamerMid: %v", streamerMid) return err } // 主播钱包 - wallet, err := v.store.GetWalletForUpdate(ctx, tx, uid) + wallet, err := v.store.GetWalletForUpdate(ctx, tx, streamerMid) if err != nil { return err } // 扣主播金币 change := ch.GetChange() - err = v.store.DecDiamonds(ctx, tx, uid, change) + err = v.store.DecDiamonds(ctx, tx, streamerMid, change) if err != nil { return err } // 扣金币的收入记录 chNew := &dbstruct.ConsumeHistory{ - Mid: goproto.Int64(uid), + Mid: goproto.Int64(streamerMid), Uid: goproto.Int64(ch.GetMid()), Did: goproto.String(ch.GetDid()), Type: goproto.Int32(dbstruct.CHTypeIncome), @@ -2623,15 +2623,15 @@ func (v *Vas) refundMembership(ctx *gin.Context, order *dbstruct.Order, req *vas // 如果已结算,扣提现钻石 if isFinish { // 扣提现钻石 - err = v.store.DecWithdrawDiamonds(ctx, tx, uid, change) + err = v.store.DecWithdrawDiamonds(ctx, tx, streamerMid, change) if err != nil { - logger.Error("DecWithdrawDiamonds fail, uid: %v, change: %v, err: %v", uid, change, err) + logger.Error("DecWithdrawDiamonds fail, streamerMid: %v, change: %v, err: %v", streamerMid, change, err) return err } // 提现钻石记录 wh := &dbstruct.WithdrawDiamondsHis{ - Mid: goproto.Int64(uid), + Mid: goproto.Int64(streamerMid), IncomeChId: goproto.Int64(ch.GetId()), OrderId: goproto.String(ch.GetOrderId()), Ct: goproto.Int64(time.Now().Unix()),