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)