From b9f7f6688802f799d8bb943471c0748690c22dd3 Mon Sep 17 00:00:00 2001 From: shoopea Date: Tue, 11 Jun 2019 14:22:04 +0800 Subject: [PATCH] test --- workers.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/workers.go b/workers.go index 421cdd2..be63bf3 100644 --- a/workers.go +++ b/workers.go @@ -190,8 +190,9 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) { p := JobPayloadMsgRefresh{ ObjID64: m.ObjID64, } + log.Printf("SQLIdentifyMsgWorker[%d] : Auction %d ending at %s but it's %s already.\n", id, cwm.LotID, cwm.End.Format(time.RFC3339), time.Now().UTC().Format(time.RFC3339)) b, _ := json.Marshal(&p) - _, err = createJob(objSubTypeJobMsgRefresh, objJobPriority, m.UserID64, cwm.End.Add(15*time.Second), b) + _, err = createJob(objSubTypeJobMsgRefresh, objJobPriority, m.UserID64, cwm.End.Add(1*time.Minute), b) } case objSubTypeMessageTimeAck: _, err := fromChatWarsDate(r.ReplaceAllString(m.Text, "${Day}") + " " + r.ReplaceAllString(m.Text, "${Month}") + " " + r.ReplaceAllString(m.Text, "${Year}") + " " + r.ReplaceAllString(m.Text, "${Hour}") + ":" + r.ReplaceAllString(m.Text, "${Minute}")) @@ -228,7 +229,7 @@ func SQLJobWorker() { func JobWorker(id int, jobs <-chan Job) { //log.Printf("jobWorker[" + strconv.Itoa(id) + "] : Starting.") for j := range jobs { - log.Printf("JobWorker[%d] : Starting job %d.\n", id, j.ID64) + //log.Printf("JobWorker[%d] : Starting job %d.\n", id, j.ID64) switch j.JobTypeID { case objSubTypeJobRescanMsg: jobRescan(j)