This commit is contained in:
shoopea 2019-10-11 09:49:31 +08:00
parent 007c3c0f62
commit 3c2be4892b

View File

@ -365,6 +365,7 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
cwm, err := parseSubTypeMessageWithdrawRcv(m, rule.re) cwm, err := parseSubTypeMessageWithdrawRcv(m, rule.re)
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageWithdrawRcv.") logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageWithdrawRcv.")
for _, i := range cwm.ItemList { for _, i := range cwm.ItemList {
log.Printf("SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : pushing %d x %d\n", i.ItemID64, i.Quantity)
err = insertMsgItem(cwm.Msg.ObjID64, i.ItemID64, i.Quantity) err = insertMsgItem(cwm.Msg.ObjID64, i.ItemID64, i.Quantity)
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Inserting objSubTypeMessageWithdrawRcv.") logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Inserting objSubTypeMessageWithdrawRcv.")
} }