test/intimate
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

fix: update_interval = 0 if that is error

Browse Source
This commit is contained in:
eson 2020-09-15 10:39:34 +08:00
parent 072468005c
commit 36c277c3ce
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
extractor/twitch_extractor/tiwtch_extractor.go
View File

@ -189,9 +189,11 @@ func main() {
for _, streamer := range streamers { for _, streamer := range streamers {
Extractor(wd, streamer) Extractor(wd, streamer)
streamer.UpdateTime = &sql.NullTime{Time: time.Now(), Valid: true}
if err = intimate.TStreamer.InsertOrUpdate(streamer, if err = intimate.TStreamer.InsertOrUpdate(streamer,
intimate.DUpdate{Field: "tags"}, intimate.DUpdate{Field: "tags"},
intimate.DUpdate{Field: "update_time"}, intimate.DUpdate{Field: "update_time"},
intimate.DUpdate{Field: "update_interval"},
); err != nil { ); err != nil {
log.Println(err) log.Println(err)
} }
@ -254,13 +256,15 @@ func Extractor(wd selenium.WebDriver, streamer *intimate.Streamer) {
if err == nil { if err == nil {
log.Println(*streamer.UserId, "may be cancell") log.Println(*streamer.UserId, "may be cancell")
streamer.Operator = 5 streamer.Operator = 5
streamer.UpdateTime = &sql.NullTime{Time: time.Now(), Valid: true}
intimate.TStreamer.UpdateError(streamer, fmt.Errorf(*streamer.UserId, "may be cancell")) intimate.TStreamer.UpdateError(streamer, fmt.Errorf(*streamer.UserId, "may be cancell"))
} }
return return
} }
err = extractFollowers(wd, clog) err = extractFollowers(wd, clog)
if err != nil { if err != nil {
// log.Println(err)
streamer.UpdateInterval += 30
return return
} }