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)