diff --git a/workers.go b/workers.go index 254a3f3..08e03f7 100644 --- a/workers.go +++ b/workers.go @@ -185,7 +185,7 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) { cwm.ObjID64 = objId err = insertMsgAuctionAnnounce(cwm) logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : insertMsgAuctionAnnounce") - if cwm.End.Add(15*time.Second).After(time.Now()) || + if cwm.End.Add(1*time.Minute).After(time.Now().UTC()) || (cwm.End.Before(time.Now()) && strings.Compare(cwm.Status, `#active`) == 0) { p := JobPayloadMsgRefresh{ ObjID64: m.ObjID64,