From 7c34ee16c52be897c6134434ef110e648974b6b2 Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 13 Dec 2019 19:26:11 +0800 Subject: [PATCH] fix append stocks --- job.go | 20 +++++++++++++++----- 1 file changed, 15 insertions(+), 5 deletions(-) diff --git a/job.go b/job.go index b3458ed..ff6f758 100644 --- a/job.go +++ b/job.go @@ -718,7 +718,9 @@ func jobGStock(j Job) { rule, err := getMsgParsingRule(msg) logOnError(err, "jobGStock : getMsgParsingRule") cwm, err := parseSubTypeMessageGStockAnyAck(msg, rule.re) - p.Stock = append(p.Stock, cwm.Stock) + for _, v := range cwm.Stock { + p.Stock = append(p.Stock, v) + } p.Progress = 2 b, _ := json.Marshal(&p) err = createJobCallback(objSubTypeJobGStock, c.TGUserID64, objSubTypeMessageGStockAnyAck, b, 1*time.Minute) @@ -730,7 +732,9 @@ func jobGStock(j Job) { rule, err := getMsgParsingRule(msg) logOnError(err, "jobGStock : getMsgParsingRule") cwm, err := parseSubTypeMessageGStockAnyAck(msg, rule.re) - p.Stock = append(p.Stock, cwm.Stock) + for _, v := range cwm.Stock { + p.Stock = append(p.Stock, v) + } p.Progress = 3 b, _ := json.Marshal(&p) err = createJobCallback(objSubTypeJobGStock, c.TGUserID64, objSubTypeMessageGStockAnyAck, b, 1*time.Minute) @@ -742,7 +746,9 @@ func jobGStock(j Job) { rule, err := getMsgParsingRule(msg) logOnError(err, "jobGStock : getMsgParsingRule") cwm, err := parseSubTypeMessageGStockAnyAck(msg, rule.re) - p.Stock = append(p.Stock, cwm.Stock) + for _, v := range cwm.Stock { + p.Stock = append(p.Stock, v) + } p.Progress = 4 b, _ := json.Marshal(&p) err = createJobCallback(objSubTypeJobGStock, c.TGUserID64, objSubTypeMessageGStockAnyAck, b, 1*time.Minute) @@ -754,7 +760,9 @@ func jobGStock(j Job) { rule, err := getMsgParsingRule(msg) logOnError(err, "jobGStock : getMsgParsingRule") cwm, err := parseSubTypeMessageGStockAnyAck(msg, rule.re) - p.Stock = append(p.Stock, cwm.Stock) + for _, v := range cwm.Stock { + p.Stock = append(p.Stock, v) + } p.Progress = 5 b, _ := json.Marshal(&p) err = createJobCallback(objSubTypeJobGStock, c.TGUserID64, objSubTypeMessageGStockAnyAck, b, 1*time.Minute) @@ -766,7 +774,9 @@ func jobGStock(j Job) { rule, err := getMsgParsingRule(msg) logOnError(err, "jobGStock : getMsgParsingRule") cwm, err := parseSubTypeMessageGStockAnyAck(msg, rule.re) - p.Stock = append(p.Stock, cwm.Stock) + for _, v := range cwm.Stock { + p.Stock = append(p.Stock, v) + } p.Progress = 6 b, _ := json.Marshal(&p) err = createJobCallback(objSubTypeJobGStock, c.TGUserID64, objSubTypeMessageGStockAnyAck, b, 1*time.Minute)