From 3f278b02a00fff1dd240d48e6690edf395bc922f Mon Sep 17 00:00:00 2001 From: shoopea Date: Thu, 29 Aug 2019 19:08:13 +0800 Subject: [PATCH] debug g deposit --- job.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/job.go b/job.go index f778f72..903c89d 100644 --- a/job.go +++ b/job.go @@ -78,8 +78,6 @@ func setJobCallback(jobID64 int64, userID64 int64, msgTypeID64 int64) { } func setJobTimeout(jobID64 int64, d time.Duration) error { - log.Printf("setJobTimeout(%d) : %s.\n", jobID64, time.Now().UTC().Add(d)) - stmt, err := db.Prepare(`UPDATE obj_job j SET j.timeout = ? WHERE j.obj_id = ?;`) logOnError(err, "setJobTimeout : prepare update obj_job") if err != nil { @@ -837,9 +835,10 @@ func jobGDeposit(j Job) { return } else if p.Status == 1 { /* handle that one resource from the objSubTypeMessageOrderbookAck msg */ - log.Printf("jobGDeposit : objSubTypeMessageStockAck : %d.\n", j.Trigger) + log.Printf("jobGDeposit : 1 : %d.\n", j.Trigger) } else if p.Status == objSubTypeMessageStockAck { + log.Printf("jobGDeposit : objSubTypeMessageStockAck : %d.\n", j.Trigger) msg, err := getObjMsg(j.Trigger) logOnError(err, "jobGDeposit : getObjMsg") rule, err := getMsgParsingRule(msg)