liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

- fk

Browse Source
This commit is contained in:
gazebo
2019-04-27 18:27:04 +08:00
parent 5bd457c143
commit 730136bbb0
1 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
business/jxutils/tasks/configrefresh.go
View File

@@ -74,7 +74,7 @@ func RefreshConfig(configKey string, expiresTime time.Duration, configGetter fun
handleType = 2 handleType = 2
} else { } else {
configSetter(curConfig.Token) configSetter(curConfig.Token)
if curConfig.Date <= utils.Time2Str(time.Now().Add(-needRefreshGap)) || IsGetWXTokenFromRemote() { if curConfig.Date <= utils.Time2Str(time.Now().Add(-needRefreshGap)) {
handleType = 1 handleType = 1
} }
} }
@@ -88,7 +88,6 @@ func RefreshConfig(configKey string, expiresTime time.Duration, configGetter fun
} }
return sleepDuration return sleepDuration
} }
globals.SugarLogger.Debugf("RefreshConfig refresh %s, value:%s", configKey, curConfig.Token)
configSetter(curConfig.Token) configSetter(curConfig.Token)
if curConfig.Date == "" { if curConfig.Date == "" {
curConfig.Date = utils.GetCurTimeStr() curConfig.Date = utils.GetCurTimeStr()
@@ -112,14 +111,13 @@ func RefreshConfig(configKey string, expiresTime time.Duration, configGetter fun
} else if sleepDuration > maxRefreshGap { } else if sleepDuration > maxRefreshGap {
sleepDuration = maxRefreshGap sleepDuration = maxRefreshGap
} }
if IsGetWXTokenFromRemote() {
sleepDuration = minRefreshGap
}
return sleepDuration return sleepDuration
} }
utils.CallFuncAsync(func() { utils.CallFuncAsync(func() {
sleepGap := refreshFunc() for {
time.Sleep(sleepGap) sleepGap := refreshFunc()
time.Sleep(sleepGap)
}
}) })
return nil return nil
} }