From 03c1007bab9af6ec05d1d52fa7c1527bb99482ca Mon Sep 17 00:00:00 2001 From: shoopea Date: Tue, 27 Aug 2019 12:50:50 +0800 Subject: [PATCH] test deposit all --- job.go | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/job.go b/job.go index fee66b4..5d8ab21 100644 --- a/job.go +++ b/job.go @@ -806,10 +806,21 @@ 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 : objSubTypeMessageStockAck : %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) + logOnError(err, "jobGDeposit : getMsgParsingRule") + cwm, err := parseSubTypeMessageStockAck(msg, rule) + for i := range cwm.Stock { + for j := range p.ResObjID64 { + if cwm.Stock[i].ItemID64 == p.ResObjID64[j] { + log.Printf("jobGDeposit : objSubTypeMessageStockAck : Matching ItemID %d (%d).\n", p.ResObjID64[j], cwm.Stock[i].Quantity) + } + } + } } err = setJobDone(j.ID64)