@@ -133,7 +133,7 @@ func GetTokenById(id int) (*Token, error) {
133133 token := Token {Id : id }
134134 var err error = nil
135135 err = DB .First (& token , "id = ?" , id ).Error
136- if err != nil {
136+ if shouldUpdateRedis ( true , err ) {
137137 gopool .Go (func () {
138138 if err := cacheSetToken (token ); err != nil {
139139 common .SysError ("failed to update user status cache: " + err .Error ())
@@ -176,7 +176,7 @@ func (token *Token) Insert() error {
176176// Update Make sure your token's fields is completed, because this will update non-zero values
177177func (token * Token ) Update () (err error ) {
178178 defer func () {
179- if common . RedisEnabled && err == nil {
179+ if shouldUpdateRedis ( true , err ) {
180180 gopool .Go (func () {
181181 err := cacheSetToken (* token )
182182 if err != nil {
@@ -192,7 +192,7 @@ func (token *Token) Update() (err error) {
192192
193193func (token * Token ) SelectUpdate () (err error ) {
194194 defer func () {
195- if common . RedisEnabled && err == nil {
195+ if shouldUpdateRedis ( true , err ) {
196196 gopool .Go (func () {
197197 err := cacheSetToken (* token )
198198 if err != nil {
@@ -207,7 +207,7 @@ func (token *Token) SelectUpdate() (err error) {
207207
208208func (token * Token ) Delete () (err error ) {
209209 defer func () {
210- if common . RedisEnabled && err == nil {
210+ if shouldUpdateRedis ( true , err ) {
211211 gopool .Go (func () {
212212 err := cacheDeleteToken (token .Key )
213213 if err != nil {
@@ -267,12 +267,14 @@ func IncreaseTokenQuota(id int, key string, quota int) (err error) {
267267 if quota < 0 {
268268 return errors .New ("quota 不能为负数!" )
269269 }
270- gopool .Go (func () {
271- err := cacheIncrTokenQuota (key , int64 (quota ))
272- if err != nil {
273- common .SysError ("failed to increase token quota: " + err .Error ())
274- }
275- })
270+ if common .RedisEnabled {
271+ gopool .Go (func () {
272+ err := cacheIncrTokenQuota (key , int64 (quota ))
273+ if err != nil {
274+ common .SysError ("failed to increase token quota: " + err .Error ())
275+ }
276+ })
277+ }
276278 if common .BatchUpdateEnabled {
277279 addNewRecord (BatchUpdateTypeTokenQuota , id , quota )
278280 return nil
@@ -295,12 +297,14 @@ func DecreaseTokenQuota(id int, key string, quota int) (err error) {
295297 if quota < 0 {
296298 return errors .New ("quota 不能为负数!" )
297299 }
298- gopool .Go (func () {
299- err := cacheDecrTokenQuota (key , int64 (quota ))
300- if err != nil {
301- common .SysError ("failed to decrease token quota: " + err .Error ())
302- }
303- })
300+ if common .RedisEnabled {
301+ gopool .Go (func () {
302+ err := cacheDecrTokenQuota (key , int64 (quota ))
303+ if err != nil {
304+ common .SysError ("failed to decrease token quota: " + err .Error ())
305+ }
306+ })
307+ }
304308 if common .BatchUpdateEnabled {
305309 addNewRecord (BatchUpdateTypeTokenQuota , id , - quota )
306310 return nil
0 commit comments