add sync stra log
This commit is contained in:
parent
db97453c54
commit
900896c045
|
@ -13,7 +13,6 @@ func SyncStras() {
|
||||||
t1 := time.NewTicker(time.Duration(CHECK_INTERVAL) * time.Second)
|
t1 := time.NewTicker(time.Duration(CHECK_INTERVAL) * time.Second)
|
||||||
|
|
||||||
syncStras()
|
syncStras()
|
||||||
logger.Info("[cron] sync stras start...")
|
|
||||||
for {
|
for {
|
||||||
<-t1.C
|
<-t1.C
|
||||||
syncStras()
|
syncStras()
|
||||||
|
@ -21,6 +20,8 @@ func SyncStras() {
|
||||||
}
|
}
|
||||||
|
|
||||||
func syncStras() {
|
func syncStras() {
|
||||||
|
logger.Info("[cron] sync stras start...")
|
||||||
|
start := time.Now().Unix()
|
||||||
stras, err := models.EffectiveStrasList()
|
stras, err := models.EffectiveStrasList()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logger.Error("sync stras err:", err)
|
logger.Error("sync stras err:", err)
|
||||||
|
@ -91,6 +92,7 @@ func syncStras() {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
StraCache.SetAll(strasMap)
|
StraCache.SetAll(strasMap)
|
||||||
|
logger.Infof("[cron] sync stras done, cost: %dms", time.Now().Sub(start).Milliseconds())
|
||||||
}
|
}
|
||||||
|
|
||||||
func CleanStraLoop() {
|
func CleanStraLoop() {
|
||||||
|
|
Loading…
Reference in New Issue