diff --git a/app/mix/service/logic/vas_zone.go b/app/mix/service/logic/vas_zone.go index f3b53452..023fe06e 100644 --- a/app/mix/service/logic/vas_zone.go +++ b/app/mix/service/logic/vas_zone.go @@ -492,19 +492,15 @@ func (v *Vas) calcAndUpdateIncome(ctx *gin.Context, tx *sqlx.Tx, streamerMid, ui } logger.Info("incomeList: %v", util.ToJson(list)) - // 检查所有人钱包 - for _, ii := range list { - _, exists := v.CheckWalletExist(ctx, tx, ii.Mid) - if !exists { - err = errs.ErrVasWalletNotExist - return make([]IncomeInfo, 0), err - } - } - // 写记录 for _, ii := range list { // 写消费记录 wallet, _ := v.CheckWalletExist(ctx, tx, ii.Mid) + if wallet == nil { + logger.Error("CheckWalletExist fail, mid: %v", ii.Mid) + err = errs.ErrVasWalletNotExist + return make([]IncomeInfo, 0), err + } ch := &dbstruct.ConsumeHistory{ Mid: goproto.Int64(ii.Mid), Uid: goproto.Int64(uid),