diff options
| author | horus | 2018-02-19 21:27:41 +0100 |
|---|---|---|
| committer | horus | 2018-02-19 21:27:41 +0100 |
| commit | c2bf9dc1d1cccc2d4cf7a1a2e1ce15eea7da6624 (patch) | |
| tree | b2ca49a7d2f01b8b338edc2ee02412d9a6ecf818 | |
| parent | f497a52ba4d650f35da00d26be9fe43be3bab111 (diff) | |
| download | alkobote-c2bf9dc1d1cccc2d4cf7a1a2e1ce15eea7da6624.tar.gz | |
Bugfix. (crawler)
| -rw-r--r-- | crawler/database.go | 6 | ||||
| -rw-r--r-- | crawler/main.go | 1 | ||||
| -rw-r--r-- | crawler/post_process.go | 2 |
3 files changed, 6 insertions, 3 deletions
diff --git a/crawler/database.go b/crawler/database.go index 01813e0..c5e2291 100644 --- a/crawler/database.go +++ b/crawler/database.go @@ -128,7 +128,11 @@ func (app *App) save_offer(W []Angebot) error { o.error_msg = err.Error() o.error_ctx = fmt.Sprintf(strings.Replace(detect_duplicate_query, "?", `"%s"`, 1), o.Name) WarnOffer(o, "database.go: Duplicate query failed") - } + } /* else { + o.error_msg = "database.go: Duplicate detected" + o.error_ctx = fmt.Sprintf(strings.Replace(detect_duplicate_query, "?", `"%s"`, 1), o.Name) + DebugOffer(o, "database.go: Duplicate detected") + }*/ } //return app.remove_expired(W) diff --git a/crawler/main.go b/crawler/main.go index 811f4d0..b75c21a 100644 --- a/crawler/main.go +++ b/crawler/main.go @@ -1,7 +1,6 @@ package main import ( - "encoding/json" "fmt" "time" diff --git a/crawler/post_process.go b/crawler/post_process.go index 608592f..052115e 100644 --- a/crawler/post_process.go +++ b/crawler/post_process.go @@ -118,7 +118,7 @@ func (app *App) fix_db() error { } if update_name || update_age { - log.Debug(`UPDATE angebot SET name = "%s", age = %d WHERE id = %d`, offer_db.Name, offer_db.Age, offer_db.Id) + log.Debug(fmt.Sprintf(`UPDATE angebot SET name = "%s", age = %d WHERE id = %d`, offer_db.Name, offer_db.Age, offer_db.Id)) _, err = app.DB.Exec(update_query, offer_db.Name, offer_db.Age, offer_db.Id) if err != nil { offer_db.error_msg = err.Error() |