diff --git a/workers.go b/workers.go index f4bad64..421cdd2 100644 --- a/workers.go +++ b/workers.go @@ -186,7 +186,7 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) { err = insertMsgAuctionAnnounce(cwm) logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : insertMsgAuctionAnnounce") if cwm.End.Add(1*time.Minute).After(time.Now().UTC()) || - (cwm.End.Before(time.Now()) && strings.Compare(cwm.Status, `#active`) == 0) { + (cwm.End.Add(1*time.Minute).Before(time.Now().UTC()) && strings.Compare(cwm.Status, `#active`) == 0) { p := JobPayloadMsgRefresh{ ObjID64: m.ObjID64, } @@ -228,7 +228,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)