From 2cfac56ec5ea87a71bcf30a9f94c461e0aa275f8 Mon Sep 17 00:00:00 2001 From: zhiqiang feng Date: Mon, 28 Dec 2020 16:09:08 +0800 Subject: [PATCH] sleep 0.5 sec every telegram --- utils/sqlite.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/utils/sqlite.go b/utils/sqlite.go index 8d5be3a..5ffb06c 100644 --- a/utils/sqlite.go +++ b/utils/sqlite.go @@ -100,6 +100,7 @@ func LoadUnprocessed() { } for _, t := range telegrams { if WriteToClient(t.text) == nil { + time.Sleep(500 * time.Millisecond) processed(db, t) } } @@ -137,8 +138,8 @@ func processed(db *sql.DB, t telegram) { checkDbErr(err, "error in create update statement") result, err := stmt.Exec(t.id) checkDbErr(err, "error in update telegram status") - id, _ := result.RowsAffected() - Log.Info("telegram update : %t", zap.Int64("id", id), zap.Bool("result", id > 0)) + rows, _ := result.RowsAffected() + Log.Info("telegram update : %t", zap.Int64("id", t.id), zap.Bool("result", rows > 0)) isWriting = false Log.Info("release lock") tx.Commit()