Commit 7f60a919 by CaIon

fix: 优化数据看板更新逻辑

parent dd0abc94
...@@ -67,9 +67,10 @@ func main() { ...@@ -67,9 +67,10 @@ func main() {
go model.SyncOptions(common.SyncFrequency) go model.SyncOptions(common.SyncFrequency)
go model.SyncChannelCache(common.SyncFrequency) go model.SyncChannelCache(common.SyncFrequency)
} }
if common.DataExportEnabled {
go model.UpdateQuotaData(common.DataExportInterval) // 数据看板
} go model.UpdateQuotaData()
if os.Getenv("CHANNEL_UPDATE_FREQUENCY") != "" { if os.Getenv("CHANNEL_UPDATE_FREQUENCY") != "" {
frequency, err := strconv.Atoi(os.Getenv("CHANNEL_UPDATE_FREQUENCY")) frequency, err := strconv.Atoi(os.Getenv("CHANNEL_UPDATE_FREQUENCY"))
if err != nil { if err != nil {
......
...@@ -17,11 +17,13 @@ type QuotaData struct { ...@@ -17,11 +17,13 @@ type QuotaData struct {
Quota int `json:"quota" gorm:"default:0"` Quota int `json:"quota" gorm:"default:0"`
} }
func UpdateQuotaData(frequency int) { func UpdateQuotaData() {
for { for {
common.SysLog("正在更新数据看板数据...") if common.DataExportEnabled {
SaveQuotaDataCache() common.SysLog("正在更新数据看板数据...")
time.Sleep(time.Duration(frequency) * time.Minute) SaveQuotaDataCache()
}
time.Sleep(time.Duration(common.DataExportInterval) * time.Minute)
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment