diff --git a/apps/user/internal/model/walletsmodel.go b/apps/user/internal/model/walletsmodel.go index 89ecb57..185ca27 100644 --- a/apps/user/internal/model/walletsmodel.go +++ b/apps/user/internal/model/walletsmodel.go @@ -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) {