Skip to content

T
twitter_syncer
Commit 02424b80 authored by vicotor's avatar vicotor
Browse files
Options

udpate syncer

parent 76bc7503
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
core/task.go
View file @ 02424b80
...@@ -118,7 +118,7 @@ func (w *Work) RunJob(t TaskJob) chan<- interface{} { ...@@ -118,7 +118,7 @@ func (w *Work) RunJob(t TaskJob) chan<- interface{} {
fmt.Println(" t.FollowerCount", t.FollowerCount, "maybeFound", maybeFound) fmt.Println(" t.FollowerCount", t.FollowerCount, "maybeFound", maybeFound)
if maybeFound { if maybeFound {
fiveMinutesTicker.Reset(time.Minute * 3) fiveMinutesTicker.Reset(time.Minute * 4)
halfHourTicker.Reset(time.Minute * 30) halfHourTicker.Reset(time.Minute * 30)
if err := Request(cli.GetFollowerList, page, t); err != nil { if err := Request(cli.GetFollowerList, page, t); err != nil {
slog.Error(" page.Request", "task id", t.TaskId, "t.TaskType", t.TaskType, "err", err.Error()) slog.Error(" page.Request", "task id", t.TaskId, "t.TaskType", t.TaskType, "err", err.Error())
...@@ -146,7 +146,7 @@ func (w *Work) RunJob(t TaskJob) chan<- interface{} { ...@@ -146,7 +146,7 @@ func (w *Work) RunJob(t TaskJob) chan<- interface{} {
Date: time.Now(), Date: time.Now(),
FollowCount: fc, FollowCount: fc,
}) })
secondTicker.Reset(time.Minute * 1) secondTicker.Reset(time.Second * 150)
// 先用和like retweet一样的周期模式； // 先用和like retweet一样的周期模式；
......
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 to comment