From 5ef6955d4849bd15e5592b06a03bbfd848e4c432 Mon Sep 17 00:00:00 2001 From: fengzhiqiang Date: Wed, 23 Dec 2020 13:41:46 +0800 Subject: [PATCH] update telegram --- utils/sqlite.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/utils/sqlite.go b/utils/sqlite.go index c370901..a607032 100644 --- a/utils/sqlite.go +++ b/utils/sqlite.go @@ -90,10 +90,12 @@ func InsertTelegram(teleString string) { } func LoadUnprocessed() { + log.Println("loading telegram") db := getDb() defer db.Close() for { num := countTelegram() + log.Println("unprocessed : ", num) if num < 1 { break } @@ -103,7 +105,7 @@ func LoadUnprocessed() { defer rows.Close() for rows.Next() { var t telegram - err := rows.Scan(&t) + err := rows.Scan(&t.id, &t.text) checkDbErr(err, "error in scan telegram") if WriteToClient(t.text) == nil { processed(t)