lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-09-20 08:11:08 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #1551 from c9s/edwin/okx/rm-redundant-code

Browse Source 
DELETE: [okx] rm redundant codes
This commit is contained in:
bailantaotao 2024-03-01 16:13:12 +08:00 committed by GitHub
commit 6123a4a14e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 0 additions and 85 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

85
pkg/exchange/okex/convert.go
View File

@ -5,9 +5,6 @@ import (
"strconv"
"strings"
"github.com/pkg/errors"
"go.uber.org/multierr"
"github.com/c9s/bbgo/pkg/exchange/okex/okexapi"
"github.com/c9s/bbgo/pkg/fixedpoint"
"github.com/c9s/bbgo/pkg/types"
@ -124,31 +121,6 @@ func toLocalSideType(side types.SideType) okexapi.SideType {
return okexapi.SideType(strings.ToLower(string(side)))
}
func segmentOrderDetails(orderDetails []okexapi.OrderDetails) (trades, orders []okexapi.OrderDetails) {
for _, orderDetail := range orderDetails {
if len(orderDetail.LastTradeID) > 0 {
trades = append(trades, orderDetail)
}
orders = append(orders, orderDetail)
}
return trades, orders
}
func toGlobalTrades(orderDetails []okexapi.OrderDetails) ([]types.Trade, error) {
var trades []types.Trade
var err error
for _, orderDetail := range orderDetails {
trade, err2 := toGlobalTrade(&orderDetail)
if err2 != nil {
err = multierr.Append(err, err2)
continue
}
trades = append(trades, *trade)
}
return trades, nil
}
func tradeToGlobal(trade okexapi.Trade) types.Trade {
side := toGlobalSide(trade.Side)
return types.Trade{
@ -246,22 +218,6 @@ func orderDetailToGlobal(order *okexapi.OrderDetail) (*types.Order, error) {
}, nil
}
func toGlobalOrders(orderDetails []okexapi.OrderDetails) ([]types.Order, error) {
var orders []types.Order
var err error
for _, orderDetail := range orderDetails {
o, err2 := toGlobalOrder(&orderDetail)
if err2 != nil {
err = multierr.Append(err, err2)
continue
}
orders = append(orders, *o)
}
return orders, err
}
func toGlobalOrderStatus(state okexapi.OrderState) (types.OrderStatus, error) {
switch state {
case okexapi.OrderStateCanceled:
@ -395,44 +351,3 @@ func toGlobalOrder(okexOrder *okexapi.OrderDetails) (*types.Order, error) {
IsIsolated: false,
}, nil
}
func toGlobalTrade(orderDetail *okexapi.OrderDetails) (*types.Trade, error) {
// Should use tradeId, but okex use billId to perform pagination, so use billID as tradeID instead.
billID := orderDetail.BillID
orderID, err := strconv.ParseInt(orderDetail.OrderID, 10, 64)
if err != nil {
return nil, errors.Wrapf(err, "error parsing ordId value: %s", orderDetail.OrderID)
}
side := toGlobalSide(orderDetail.Side)
isMargin := false
if orderDetail.InstrumentType == okexapi.InstrumentTypeMARGIN {
isMargin = true
}
isFuture := false
if orderDetail.InstrumentType == okexapi.InstrumentTypeFutures {
isFuture = true
}
return &types.Trade{
ID: uint64(billID),
OrderID: uint64(orderID),
Exchange: types.ExchangeOKEx,
Price: orderDetail.LastFilledPrice,
Quantity: orderDetail.LastFilledQuantity,
QuoteQuantity: orderDetail.LastFilledPrice.Mul(orderDetail.LastFilledQuantity),
Symbol: toGlobalSymbol(orderDetail.InstrumentID),
Side: side,
IsBuyer: side == types.SideTypeBuy,
IsMaker: orderDetail.ExecutionType == "M",
Time: types.Time(orderDetail.LastFilledTime),
Fee: orderDetail.LastFilledFee,
FeeCurrency: orderDetail.LastFilledFeeCurrency,
IsMargin: isMargin,
IsFutures: isFuture,
IsIsolated: false,
}, nil
}