钱包缓存修复
This commit is contained in:
parent
34c1ba777f
commit
5a9af63ffb
@ -78,6 +78,13 @@ func (m *customWalletsModel) UpdateBalance(session sqlx.Session, ctx context.Con
|
||||
if rowsAffected == 0 {
|
||||
return ErrVersionMismatch
|
||||
}
|
||||
|
||||
walletsUserIdKey := fmt.Sprintf("%s%v", cacheWalletsUserIdPrefix, userId)
|
||||
cacheErrors := m.DelCacheCtx(ctx, walletsUserIdKey)
|
||||
if cacheErrors != nil {
|
||||
return cacheErrors
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
func (m *customWalletsModel) InsertWalletsTrans(ctx context.Context, wallets *Wallets, session sqlx.Session) (sql.Result, error) {
|
||||
|
Loading…
Reference in New Issue
Block a user