- fk ebai order_id,GetOrderIDFromMsg

business/partner/purchase/ebai/callback.go

@@ -8,12 +8,7 @@ import (
 )
 
 func OnCallbackMsg(msg *ebaiapi.CallbackMsg) (response *ebaiapi.CallbackResponse) {
-	orderID := ""
+	orderID := GetOrderIDFromMsg(msg)
-	if true { //msg.Cmd == ebaiapi.CmdOrderCreate { // 与测试时情况不一样，好像线上全改成string了
-		orderID = msg.Body["order_id"].(string)
-	} else {
-		orderID = utils.Int64ToStr(utils.MustInterface2Int64(msg.Body["order_id"]))
-	}
 	jxutils.CallMsgHandler(func() {
 		switch msg.Cmd {
 		case ebaiapi.CmdOrderCreate, ebaiapi.CmdOrderStatus:
@@ -24,3 +19,10 @@ func OnCallbackMsg(msg *ebaiapi.CallbackMsg) (response *ebaiapi.CallbackResponse
 	}, jxutils.ComposeUniversalOrderID(orderID, model.VendorIDEBAI))
 	return response
 }
+
+func GetOrderIDFromMsg(msg *ebaiapi.CallbackMsg) string {
+	if tryOrderID, ok := msg.Body["order_id"].(string); ok {
+		return tryOrderID
+	}
+	return utils.Int64ToStr(utils.MustInterface2Int64(msg.Body["order_id"]))
+}

business/partner/purchase/ebai/order.go

@@ -171,7 +171,7 @@ func (c *PurchaseHandler) onOrderMsg(msg *ebaiapi.CallbackMsg) (retVal *ebaiapi.
 }
 
 func (c *PurchaseHandler) onOrderNew(msg *ebaiapi.CallbackMsg) (response *ebaiapi.CallbackResponse) {
-	vendorOrderID := msg.Body["order_id"].(string)
+	vendorOrderID := GetOrderIDFromMsg(msg)
 	order, err := c.GetOrder(vendorOrderID)
 	if err == nil {
 		err = partner.CurOrderManager.OnOrderNew(order, order.VendorStatus)
@@ -184,7 +184,7 @@ func (c *PurchaseHandler) onOrderNew(msg *ebaiapi.CallbackMsg) (response *ebaiap
 func (c *PurchaseHandler) callbackMsg2Status(msg *ebaiapi.CallbackMsg) *model.OrderStatus {
 	body := msg.Body
 	vendorStatus := utils.Int64ToStr(utils.MustInterface2Int64(body["status"]))
-	orderID := utils.Int64ToStr(utils.MustInterface2Int64(msg.Body["order_id"]))
+	orderID := GetOrderIDFromMsg(msg)
 	orderStatus := &model.OrderStatus{
 		VendorOrderID:    orderID,
 		VendorID:         model.VendorIDEBAI,