新京东账号

business/partner/purchase/jdshop/callback.go

@@ -43,8 +43,9 @@ func OnCallbackMsg(msg *jdshopapi.CallBackResult) (err error) {
 		})
 	case jcqapi.TopicOrderOut:
 		utils.CallFuncAsync(func() {
-			order := getRealOrderID(msg.OrderID)
-			if order != nil {
+			orders := getAllRealOrderID(msg.OrderID)
+			if len(orders) > 0 {
+				for _, order := range orders {
 					if order.ActualPayPrice == 0 {
 						if jxutils.StandardPrice2Int(utils.Str2Float64(msg.OrderPayment)) == 0 {
 							order.ActualPayPrice = jxutils.StandardPrice2Int(utils.Str2Float64(msg.OrderTotalPrice) + utils.Str2Float64(msg.FreightPrice) - utils.Str2Float64(msg.SellerDiscount))
@@ -55,6 +56,7 @@ func OnCallbackMsg(msg *jdshopapi.CallBackResult) (err error) {
 						partner.CurOrderManager.UpdateOrderFields(order, []string{"ActualPayPrice", "TotalShopMoney"})
 					}
 				}
+			}
 		})
 	default:
 		return fmt.Errorf("暂不支持的topic类型！topic: %v", msgType)
@@ -255,3 +257,17 @@ func getRealOrderID(orderID string) (order *model.GoodsOrder) {
 	dao.GetRow(db, &order, sql, sqlParams)
 	return order
 }
+
+func getAllRealOrderID(orderID string) (orders []*model.GoodsOrder) {
+	var (
+		db = dao.GetDB()
+	)
+	sql := `
+		SELECT * FROM goods_order WHERE vendor_order_id2 = ? 
+	`
+	sqlParams := []interface{}{
+		orderID,
+	}
+	dao.GetRows(db, &orders, sql, sqlParams)
+	return orders
+}