This commit is contained in:
lwl0608 2024-04-16 22:09:15 +08:00
parent 89bc85b415
commit d731659a50
1 changed files with 5 additions and 9 deletions

View File

@ -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),