chtwrs/chirpnest
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
shoopea 2019-06-11 14:06:26 +08:00
parent 89e50f06a5
commit 4999e1220c
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
workers.go
View File

@ -186,7 +186,7 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
err = insertMsgAuctionAnnounce(cwm) err = insertMsgAuctionAnnounce(cwm)
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : insertMsgAuctionAnnounce") logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : insertMsgAuctionAnnounce")
if cwm.End.Add(1*time.Minute).After(time.Now().UTC()) || 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{ p := JobPayloadMsgRefresh{
ObjID64: m.ObjID64, ObjID64: m.ObjID64,
} }
@ -228,7 +228,7 @@ func SQLJobWorker() {
func JobWorker(id int, jobs <-chan Job) { func JobWorker(id int, jobs <-chan Job) {
//log.Printf("jobWorker[" + strconv.Itoa(id) + "] : Starting.") //log.Printf("jobWorker[" + strconv.Itoa(id) + "] : Starting.")
for j := range jobs { 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 { switch j.JobTypeID {
case objSubTypeJobRescanMsg: case objSubTypeJobRescanMsg:
jobRescan(j) jobRescan(j)