刷新历史订单

business/jxcallback/orderman/order.go

@@ -628,6 +628,9 @@ func (c *OrderManager) RefreshHistoryOrdersEarningPrice(ctx *jxcontext.Context,
 	}
 
 	orderList, _ := dao.QueryOrders(db, []int{vendorOrderId}, 0, fromDateParm, toDateParm)
+	if len(orderList) == 0 {
+		return errors.New(fmt.Sprintf("未查询到订单！时间范围：[%v]  至  [%v]", fromDate, toDate))
+	}
 	task := tasksch.NewSeqTask("按订单刷新历史订单结算价", ctx,
 		func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
 			switch step {
@@ -640,7 +643,7 @@ func (c *OrderManager) RefreshHistoryOrdersEarningPrice(ctx *jxcontext.Context,
 						for _, value := range order.Skus {
 							dao.Begin(db)
 							_, err := dao.UpdateOrderSkuEariningPrice(db, value, v.StoreID, fromDateParm, toDateParm)
-							if err == nil{
+							if err == nil {
 								dao.Commit(db)
 							}
 							if err != nil && !isContinueWhenError {