From c47ec52a820aef99d366b061853f9850794605a7 Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 23 Aug 2019 14:08:45 +0800 Subject: [PATCH] fix job --- job.go | 39 ++++++++++++++++++++------------------- 1 file changed, 20 insertions(+), 19 deletions(-) diff --git a/job.go b/job.go index b9bc95c..4395cdb 100644 --- a/job.go +++ b/job.go @@ -738,29 +738,30 @@ func jobGDeposit(j Job) { } } } - - - p2 := JobPayloadGDeposit{ - MsgID64: p.MsgID64, - ChatID64: p.ChatID64, - ResObjID64: nil, - Status: 1, + /* + + p2 := JobPayloadGDeposit{ + MsgID64: p.MsgID64, + ChatID64: p.ChatID64, + ResObjID64: nil, + Status: 1, + } + p2.ResObjID64 = append(p2.ResObjID64, obj.ObjID64) + b2, _ := json.Marshal(&p2) + err = createJobCallback(objSubTypeJobGDeposit, j.UserID64, objSubTypeMessageOrderbookAck, b2) + clientSendCWMsg(p.ChatID64, fmt.Sprintf("/t_%s", obj.Code)) + logOnError(err, "jobGDeposit : createJobCallback") } - p2.ResObjID64 = append(p2.ResObjID64, obj.ObjID64) - b2, _ := json.Marshal(&p2) - err = createJobCallback(objSubTypeJobGDeposit, j.UserID64, objSubTypeMessageOrderbookAck, b2) - clientSendCWMsg(p.ChatID64, fmt.Sprintf("/t_%s", obj.Code)) + + p.ResObjID64 = p.ResObjID64[1:] + } + if len(p.ResObjID64) > 0 { + b, _ := json.Marshal(&p) + err = createJobCallback(objSubTypeJobGDeposit, j.UserID64, objSubTypeMessageOrderbookAck, b) logOnError(err, "jobGDeposit : createJobCallback") } - - p.ResObjID64 = p.ResObjID64[1:] - } - if len(p.ResObjID64) > 0 { - b, _ := json.Marshal(&p) - err = createJobCallback(objSubTypeJobGDeposit, j.UserID64, objSubTypeMessageOrderbookAck, b) - logOnError(err, "jobGDeposit : createJobCallback") - } + */ return } else if p.Status == 1 { /* handle that one resource from the objSubTypeMessageOrderbookAck msg */