FIX: [xmaker] fix aggregatePrice method

pkg/strategy/xmaker/strategy.go

@@ -167,29 +167,23 @@ func (s *Strategy) CrossSubscribe(sessions map[string]*bbgo.ExchangeSession) {
 }
 
 func aggregatePrice(pvs types.PriceVolumeSlice, requiredQuantity fixedpoint.Value) (price fixedpoint.Value) {
-	q := requiredQuantity
-	totalAmount := fixedpoint.Zero
-
 	if len(pvs) == 0 {
 		price = fixedpoint.Zero
 		return price
-	} else if pvs[0].Volume.Compare(requiredQuantity) >= 0 {
-		return pvs[0].Price
 	}
 
+	sumAmount := fixedpoint.Zero
+	sumQty := fixedpoint.Zero
 	for i := 0; i < len(pvs); i++ {
 		pv := pvs[i]
-		if pv.Volume.Compare(q) >= 0 {
-			totalAmount = totalAmount.Add(q.Mul(pv.Price))
+		sumQty = sumQty.Add(pv.Volume)
+		sumAmount = sumAmount.Add(pv.Volume.Mul(pv.Price))
+		if sumQty.Compare(requiredQuantity) >= 0 {
 			break
 		}
-
-		q = q.Sub(pv.Volume)
-		totalAmount = totalAmount.Add(pv.Volume.Mul(pv.Price))
 	}
 
-	price = totalAmount.Div(requiredQuantity)
-	return price
+	return sumAmount.Div(sumQty)
 }
 
 func (s *Strategy) Initialize() error {
@@ -573,6 +567,7 @@ func (s *Strategy) updateQuote(ctx context.Context) {
 			}
 
 			if i == 0 {
+				s.logger.Infof("maker best bid price %f", bidPrice.Float64())
 				makerBestBidPriceMetrics.With(labels).Set(bidPrice.Float64())
 			}
 
@@ -640,6 +635,7 @@ func (s *Strategy) updateQuote(ctx context.Context) {
 			}
 
 			if i == 0 {
+				s.logger.Infof("maker best ask price %f", askPrice.Float64())
 				makerBestAskPriceMetrics.With(labels).Set(askPrice.Float64())
 			}