50 lines
1.0 KiB
Go
50 lines
1.0 KiB
Go
package ipstat
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
"videoweb/pub/common/enum/redisconst"
|
|
"videoweb/pub/common/log"
|
|
"videoweb/pub/common/utils"
|
|
"videoweb/pub/models/ipdailystatmod"
|
|
"videoweb/pub/pubdef"
|
|
"videoweb/pub/redis"
|
|
)
|
|
|
|
const syncInterval = 5 * time.Minute
|
|
|
|
func StartSync() {
|
|
go func() {
|
|
syncOnce()
|
|
ticker := time.NewTicker(syncInterval)
|
|
defer ticker.Stop()
|
|
for range ticker.C {
|
|
syncOnce()
|
|
}
|
|
}()
|
|
}
|
|
|
|
func syncOnce() {
|
|
ctx, cancel := context.WithTimeout(context.Background(), 15*time.Second)
|
|
defer cancel()
|
|
|
|
now := time.Now().In(utils.LocBJ)
|
|
appId := int64(pubdef.AppId)
|
|
|
|
for _, offset := range []int{0, -1} {
|
|
date := now.AddDate(0, 0, offset).Format("20060102")
|
|
key := redisconst.IpStatKey(appId, date)
|
|
|
|
count, err := redis.SCard(key)
|
|
if err != nil {
|
|
log.Warn("ipstat sync: SCard failed", log.Any("date", date), log.E(err))
|
|
continue
|
|
}
|
|
|
|
if err := ipdailystatmod.UpsertCount(ctx, appId, date, count); err != nil {
|
|
log.Warn("ipstat sync: UpsertCount failed",
|
|
log.Any("appId", appId), log.Any("date", date), log.E(err))
|
|
}
|
|
}
|
|
}
|