update telegram

2020-12-23 13:41:46 +08:00
parent 0df588f587
commit 5ef6955d48
1 changed files with 3 additions and 1 deletions
@@ -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)