diff --git a/business/jxcallback/orderman/order.go b/business/jxcallback/orderman/order.go
index 45ef08056..3c84f20ed 100644
--- a/business/jxcallback/orderman/order.go
+++ b/business/jxcallback/orderman/order.go
@@ -627,7 +627,7 @@ func (c *OrderManager) RefreshHistoryOrdersEarningPrice(ctx *jxcontext.Context,
 		return errors.New(fmt.Sprintf("查询间隔时间不允许大于10天！时间范围：[%v]  至  [%v]", fromDate, toDate))
 	}
 
-	orderList, _ := dao.QueryOrders(db, []int{vendorOrderId}, 0, fromDateParm, toDateParm)
+	orderList, _ := dao.QueryOrders(db, []int{}, 0, fromDateParm, toDateParm)
 	if len(orderList) == 0 {
 		return errors.New(fmt.Sprintf("未查询到订单！时间范围：[%v]  至  [%v]", fromDate, toDate))
 	}
@@ -642,7 +642,7 @@ func (c *OrderManager) RefreshHistoryOrdersEarningPrice(ctx *jxcontext.Context,
 						updateSingleOrderEarningPrice(order, db)
 						for _, value := range order.Skus {
 							dao.Begin(db)
-							_, err := dao.UpdateOrderSkuEariningPrice(db, value, v.StoreID, fromDateParm, toDateParm)
+							_, err := dao.UpdateOrderSkuEariningPrice(db, value, v.StoreID, fromDateParm, toDateParm, vendorOrderId)
 							if err == nil {
 								dao.Commit(db)
 							}
diff --git a/business/model/dao/dao_order.go b/business/model/dao/dao_order.go
index c1274e932..cd8f46a51 100644
--- a/business/model/dao/dao_order.go
+++ b/business/model/dao/dao_order.go
@@ -590,7 +590,7 @@ func GetRiskOrderCount(db *DaoDB, dayNum int, includeToday bool) (storeOrderList
 	return storeOrderList, GetRows(db, &storeOrderList, sql, sqlParams)
 }
 
-func UpdateOrderSkuEariningPrice(db *DaoDB, skus *model.OrderSku, storeID int, fromDateParm, toDateParm time.Time) (num int64, err error) {
+func UpdateOrderSkuEariningPrice(db *DaoDB, skus *model.OrderSku, storeID int, fromDateParm, toDateParm time.Time, vendorOrderId int) (num int64, err error) {
 	sql := `
 	UPDATE order_sku t1
 	JOIN goods_order tt1 ON tt1.vendor_order_id = t1.vendor_order_id
@@ -600,6 +600,7 @@ func UpdateOrderSkuEariningPrice(db *DaoDB, skus *model.OrderSku, storeID int, f
 	AND tt1.order_created_at BETWEEN ? and ?
 	SET t1.earning_price = ?,t1.store_sub_id = ?
 	WHERE t1.store_sub_id = 0 
+	AND tt1.vendor_order_id = ?
 	`
 	sqlParams := []interface{}{
 		skus.VendorID,
@@ -609,6 +610,7 @@ func UpdateOrderSkuEariningPrice(db *DaoDB, skus *model.OrderSku, storeID int, f
 		toDateParm,
 		skus.EarningPrice,
 		skus.StoreSubID,
+		vendorOrderId,
 	}
 	return ExecuteSQL(db, sql, sqlParams...)
 }