- return proper msg for ebai.

This commit is contained in:
gazebo
2018-09-28 11:06:29 +08:00
parent d81e8e1644
commit 64087ea640

View File

@@ -150,17 +150,20 @@ func (c *PurchaseHandler) onOrderMsg(msg *ebaiapi.CallbackMsg) (retVal *ebaiapi.
} else { } else {
status := c.callbackMsg2Status(msg) status := c.callbackMsg2Status(msg)
err := partner.CurOrderManager.OnOrderStatusChanged(status) err := partner.CurOrderManager.OnOrderStatusChanged(status)
retVal = api.EbaiAPI.Err2CallbackResponse(msg.Cmd, err, status.VendorStatus) retVal = api.EbaiAPI.Err2CallbackResponse(msg.Cmd, err, nil)
} }
return retVal return retVal
} }
func (c *PurchaseHandler) onOrderNew(msg *ebaiapi.CallbackMsg) (response *ebaiapi.CallbackResponse) { func (c *PurchaseHandler) onOrderNew(msg *ebaiapi.CallbackMsg) (response *ebaiapi.CallbackResponse) {
order, err := c.GetOrder(msg.Body["order_id"].(string)) vendorOrderID := msg.Body["order_id"].(string)
order, err := c.GetOrder(vendorOrderID)
if err == nil { if err == nil {
err = partner.CurOrderManager.OnOrderNew(order, order.VendorStatus) err = partner.CurOrderManager.OnOrderNew(order, order.VendorStatus)
} }
return api.EbaiAPI.Err2CallbackResponse(msg.Cmd, err, "ebai onOrderNew") return api.EbaiAPI.Err2CallbackResponse(msg.Cmd, err, map[string]interface{}{
"source_order_id": vendorOrderID,
})
} }
func (c *PurchaseHandler) callbackMsg2Status(msg *ebaiapi.CallbackMsg) *model.OrderStatus { func (c *PurchaseHandler) callbackMsg2Status(msg *ebaiapi.CallbackMsg) *model.OrderStatus {