From df71b249eaea06d71d5669424283ba81ad856623 Mon Sep 17 00:00:00 2001 From: shoopea Date: Sun, 26 Jan 2020 22:07:13 +0800 Subject: [PATCH] test --- job.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/job.go b/job.go index a0a6af2..981707b 100644 --- a/job.go +++ b/job.go @@ -196,7 +196,7 @@ func setJobPayload(jobID64 int64, payload []byte) error { cacheObjJob[jobID64] = j muxObjJob.Unlock() - log.Printf("setJobPayload[%d] : %s\n", string(payload)) + //log.Printf("setJobPayload[%d] : %s\n", jobID64, string(payload)) return nil } @@ -1734,7 +1734,7 @@ func jobGWithdraw(j Job) { b2, _ := json.Marshal(p2) createJobCallback(cacheObjSubType[`job_gwithdraw`], j.UserID64, cacheObjSubType[`msg_gstock_any_ack`], b, time.Minute) createJobCallback(cacheObjSubType[`job_msg_del`], j.UserID64, p2.MsgTypeID64, b2, time.Minute) - clientSendCWMsg(j.UserID64, `/g_stock_part`) + clientSendCWMsg(j.UserID64, `/g_stock_parts`) } else if (p.Status & reqTab[cacheObjSubType[`item_other`]]) == reqTab[cacheObjSubType[`item_other`]] { log.Printf("jobGWithdraw[%d] : Requesting other.\n", j.ID64) p.Status = p.Status &^ reqTab[cacheObjSubType[`item_other`]] @@ -2035,7 +2035,7 @@ func jobGetVault(j Job) { setJobCallback(j.ID64, j.UserID64, cacheObjSubType[`msg_gstock_part_req`]) setJobCallback(j.ID64, j.UserID64, cacheObjSubType[`msg_gstock_any_ack`]) rescheduleJob(j.ID64, 0, time.Unix(maxUnixTimestamp, 0).UTC()) - clientSendCWMsg(j.UserID64, `/g_stock_part`) + clientSendCWMsg(j.UserID64, `/g_stock_parts`) return } else if (p.Status & reqTab[cacheObjSubType[`item_other`]]) == reqTab[cacheObjSubType[`item_other`]] { log.Printf("jobGetVault[%d] : Requesting other.\n", j.ID64)