code

app/jobs/examples.go

@@ -29,6 +29,7 @@ func InitJob() {
 		"InitSpotSymbol":            InitSpotSymbol{},            //定时更新现货交易对
 		"ClearLogJob":               ClearLogJob{},               //定时清理日志
 		"AutoPlaceOrder":            AutoPlaceOrder{},            //定时下单
+		"LimitOrderTimeoutDuration": LimitOrderTimeoutDuration{}, //定时取消限价单改下市价单
 	}
 }
 

app/jobs/jobs.go

@@ -4,6 +4,7 @@ import (
 	"errors"
 	"fmt"
 	"github.com/jinzhu/copier"
+	"github.com/shopspring/decimal"
 	"go-admin/app/admin/models"
 	"go-admin/app/admin/service"
 	"go-admin/app/admin/service/dto"
@@ -34,7 +35,7 @@ type ClearLogJob struct {
 type AutoPlaceOrder struct {
 }
 
-type CancelOrderByTime struct {
+type LimitOrderTimeoutDuration struct {
 }
 
 // 初始化合约交易对
@@ -133,7 +134,7 @@ func (t AutoPlaceOrder) Exec(arg interface{}) error {
 	return nil
 }
 
-func (t CancelOrderByTime) Exec(arg interface{}) error {
+func (t LimitOrderTimeoutDuration) Exec(arg interface{}) error {
 
 	str := time.Now().Format(timeFormat) + " [INFO] JobCore ClearLogJob exec success"
 	defer logger.Info(str)
@@ -161,12 +162,38 @@ func (t CancelOrderByTime) Exec(arg interface{}) error {
 		return err
 	}
 	spotApi := binanceservice.SpotRestApi{}
+	futApi := binanceservice.FutRestApi{}
 	for _, order := range orders {
 		var apiUserinfo models.LineApiUser
 		db.Model(&models.LineApiUser{}).Where("id = ?", order.ApiId).Find(&apiUserinfo)
 		//现货
 		if order.SymbolType == global.SYMBOL_SPOT {
 			if order.ExchangeType == global.EXCHANGE_BINANCE {
+				err := t.ReSpotOrderPlace(db, order, apiUserinfo, spotApi)
+				if err != nil {
+					continue
+				}
+			}
+
+		}
+
+		//合约
+		if order.SymbolType == global.SYMBOL_FUTURES {
+			if order.ExchangeType == global.EXCHANGE_BINANCE {
+				err := t.ReFutOrderPlace(db, order, apiUserinfo, futApi)
+				if err != nil {
+					continue
+				}
+			}
+		}
+
+	}
+	return nil
+}
+
+// ReSpotOrderPlace 重下现货市价单
+func (t LimitOrderTimeoutDuration) ReSpotOrderPlace(db *gorm.DB, order models.LinePreOrder, apiUserinfo models.LineApiUser, spotApi binanceservice.SpotRestApi) error {
+	var err error
 	for i := 0; i < 3; i++ {
 		err := spotApi.CancelOpenOrderByOrderSn(apiUserinfo, order.Symbol, order.OrderSn)
 		if err == nil || strings.Contains(err.Error(), "该交易对没有订单") {
@@ -175,7 +202,7 @@ func (t CancelOrderByTime) Exec(arg interface{}) error {
 	}
 	if err != nil {
 		logger.Error(fmt.Sprintf("取消现货委托失败:order_sn:%s err:%+v", order.OrderSn, err))
-					continue
+		return err
 	} else {
 		newClientOrderId := snowflakehelper.GetOrderId()
 
@@ -188,7 +215,7 @@ func (t CancelOrderByTime) Exec(arg interface{}) error {
 		err = db.Model(&models.LinePreOrder{}).Create(&newOrder).Error
 		if err != nil {
 			logger.Error(fmt.Sprintf("生成新市价单失败 err:%+v", err))
-						continue
+			return err
 		}
 		params := binanceservice.OrderPlacementService{
 			ApiId:            order.ApiId,
@@ -206,19 +233,63 @@ func (t CancelOrderByTime) Exec(arg interface{}) error {
 
 			if err != nil {
 				logger.Error("下单失败后修改订单失败")
-							continue
+				return err
-						}
 			}
 		}
 	}
 
-		}
-
-		//合约
-		if order.SymbolType == global.SYMBOL_FUTURES {
-
-		}
-
-	}
 	return nil
 }
+
+// ReFutOrderPlace 重下合约市价单
+func (t LimitOrderTimeoutDuration) ReFutOrderPlace(db *gorm.DB, order models.LinePreOrder, apiUserinfo models.LineApiUser, futApi binanceservice.FutRestApi) error {
+	var err error
+	for i := 0; i < 3; i++ {
+		err := futApi.CancelFutOrder(apiUserinfo, order.Symbol, order.OrderSn)
+		if err == nil || strings.Contains(err.Error(), "该交易对没有订单") {
+			break
+		}
+	}
+	if err != nil {
+		logger.Error(fmt.Sprintf("取消现货委托失败:order_sn:%s err:%+v", order.OrderSn, err))
+		return err
+	} else {
+		newClientOrderId := snowflakehelper.GetOrderId()
+
+		var newOrder models.LinePreOrder
+		copier.Copy(&newOrder, order)
+		newOrder.Id = 0
+		newOrder.OrderSn = utility.Int64ToString(newClientOrderId)
+		newOrder.CreatedAt = time.Now()
+		newOrder.MainOrderType = "MARKET"
+		err = db.Model(&models.LinePreOrder{}).Create(&newOrder).Error
+		if err != nil {
+			logger.Error(fmt.Sprintf("生成合约新市价单失败 err:%+v", err))
+			return err
+		}
+
+		params := binanceservice.FutOrderPlace{
+			ApiId:            order.ApiId,
+			Symbol:           order.Symbol,
+			Side:             order.Site,
+			Quantity:         utility.StringToDecimal(order.Num),
+			Price:            utility.StringToDecimal(order.Price),
+			SideType:         "MARKET",
+			OpenOrder:        0,
+			Profit:           decimal.Decimal{},
+			StopPrice:        decimal.Decimal{},
+			OrderType:        "MARKET",
+			NewClientOrderId: utility.Int64ToString(newClientOrderId),
+		}
+
+		if err := futApi.OrderPlace(db, params); err != nil {
+			logger.Error(fmt.Sprintf("重新下合约市价单失败 err:%+v", err))
+			err := db.Model(&models.LinePreOrder{}).Where("id = ? AND status = 0", newOrder.Id).Updates(map[string]interface{}{"status": "2", "desc": err.Error()}).Error
+			if err != nil {
+				logger.Error("下单失败后修改订单失败")
+				return err
+			}
+		}
+	}
+	return err
+}