ہیج حکمت عملی ڈیزائن ریسرچ & زیر التواء اسپاٹ اور فیوچر آرڈرز کی مثال

ہیج حکمت عملی ڈیزائن ریسرچ & زیر التواء اسپاٹ اور فیوچر آرڈرز کی مثال

طویل عرصے سے ، فیوچر اور اسپاٹ ہیج عام طور پر قیمت کے پھیلاؤ کا پتہ لگانے کے لئے ڈیزائن کیا گیا ہے ، اور جب قیمت کا پھیلاؤ پورا ہوتا ہے تو ہیج کرنے کے لئے آرڈر لیتے ہیں۔ کیا زیر التواء آرڈر ہیج ڈیزائن کیا جاسکتا ہے؟ جواب ہاں ہے۔ آج ، میں قارئین کو زیر التواء آرڈر ہیج کے لئے ڈیزائن آئیڈیا اور کوڈ پروٹو ٹائپ لاتا ہوں۔

زیر التواء آرڈر ہیج کے بارے میں سوچنا

ایک ہی یا ایک ہی قسم کے مضامین کی مختلف منڈیوں میں ، ہیجنگ کے مواقع اس وقت پیدا ہوتے ہیں جب دو مارکیٹوں کے مابین خرید و فروخت کے احکامات میں بہت بڑا فرق ہوتا ہے۔ عام طور پر ، ہم زیر التواء احکامات لیں گے جو قیمت کے پھیلاؤ کو پورا کرتے ہیں اور پھر ہیجنگ پوزیشن رکھتے ہیں۔ لہذا ، ہیجنگ کے دو مقاصد ہیں۔ پہلا آرڈر پوزیشنوں کے خلاف ہیجنگ کرنا ہے ، اور دوسرا یہ یقینی بنانا ہے کہ خرید و فروخت کے مابین قیمت کا پھیلاؤ ہماری توقعات کو زیادہ سے زیادہ پورا کرتا ہے۔ اس سلسلے میں زیر التواء آرڈر ٹریڈنگ کا فائدہ یہ ہے کہ فیس کم ہے۔ نقصان یہ ہے کہ احکامات کو انجام دینا آسان نہیں ہے ، اور سنگل پوزیشن کے احکامات کو انجام دینا آسان ہے۔

اس کے بعد ، ہم تجارتی خیال کو ڈیزائن کرتے ہیں کہ مارکیٹ اے آرڈر بک کے خرید آرڈر میں خرید آرڈر کا انتظار کریں ، اور مارکیٹ بی آرڈر بک کے فروخت آرڈر میں فروخت آرڈر کا انتظار کریں ، اور پھر اپنے اکاؤنٹ کے زیر التواء آرڈرز کا پتہ لگائیں ، اور زیر التواء آرڈر پر عمل درآمد کے لئے اگلے مرحلے پر آگے بڑھیں۔ مثال کے طور پر ، جب زیر التواء آرڈر کی تبدیلی کا پتہ چلتا ہے تو ، فوری طور پر فیوچر اور اسپاٹ کی موجودہ ہیج پوزیشنوں کو متوازن کریں۔ فیوچر اور اسپاٹ پوزیشنوں کے اوور فلو کے لئے ، کھولیں خریدیں یا بند کریں۔ ہیج پوزیشنوں کے اضافے کے مطابق ، مارکیٹ میں اگلے زیر التواء آرڈر اور مارکیٹ کی پہلی سطح کے درمیان فاصلے کو ایڈجسٹ کریں ، آہستہ آہستہ سب سے بڑا پھیلاؤ حاصل کرنے کے لئے ہیج کریں۔

ہیجنگ منطق

کوڈ ڈیزائن

تبصرے براہ راست کوڈ میں لکھے گئے ہیں۔ یہ مثال صرف ڈیزائن ریفرنس کے لئے استعمال کی جاتی ہے اور صرف OKEX V5 تخروپن بوٹ پر مختصر طور پر تجربہ کیا گیا ہے۔ مثال ایک مکمل حکمت عملی نہیں ہے ، لہذا براہ کرم اسے صرف حوالہ کے لئے استعمال کریں۔

// temporary parameters 
var fuContractType = "quarter"    // futures contract
var fuSymbol = "ETH_USDT"         // futures trading pair 
var spSymbol = "ETH_USDT"         // spot trading pair 
var minAmount = 0.1               // trading amount of each time, minimum trading amount, currency amount 
var step = 40                     // step length of spread 
var buff = 5                      // buffer spread 
var balanceType = "open"          // when the single-position execution is balanced, open buy or close  

var depthManager = function(fuEx, spEx, fuCt, fuSymbol, spSymbol) {
    var self = {}
    self.fuExDepth = null
    self.spExDepth = null 
    self.plusPrice = null
    self.minusPrice = null 

    self.update = function() {        
        spEx.SetCurrency(spSymbol)
        if (!IsVirtual()) {
            fuEx.SetCurrency(fuSymbol)
        }        
        fuEx.SetContractType(fuCt)

        var fuRoutine = fuEx.Go("GetDepth")
        var spRoutine = spEx.Go("GetDepth")
        var fuDepth = fuRoutine.wait()
        var spDepth = spRoutine.wait()
        if (!fuDepth || !spDepth) {
            return false 
        }
        self.fuExDepth = fuDepth
        self.spExDepth = spDepth

        if (fuDepth.Bids.length == 0 || fuDepth.Asks.length == 0 || spDepth.Bids.length == 0 || spDepth.Asks.length == 0) {
            return false 
        }
        self.plusPrice = fuDepth.Bids[0].Price - spDepth.Asks[0].Price   // futures Bid - spot Ask
        self.minusPrice = fuDepth.Asks[0].Price - spDepth.Bids[0].Price  // futures Ask - spot Bid
        return true 
    }

    self.getData = function() {       
        return {
            "fuExDepth" : self.fuExDepth,
            "spExDepth" : self.spExDepth,
            "plusPrice" : self.plusPrice,
            "minusPrice" : self.minusPrice
        }
    }
    return self 
}

var positionManager = function(fuEx, spEx, fuCt, fuSymbol, spSymbol, step, buffDiff, balanceType, initSpAcc) {
    var self = {}
    self.balanceType = balanceType
    self.depth = null 
    self.level = 1
    self.lastUpdateTs = 0
    self.fuPos = []
    self.spPos = []
    self.initSpAcc = initSpAcc
    self.spAcc = null
    self.hedgePos = null
    self.hedgePosPrice = 0
    self.minAmount = 0.01
    self.offset = ["", 0]

    self.update = function() {
        spEx.SetCurrency(spSymbol)
        if (!IsVirtual()) {
            fuEx.SetCurrency(fuSymbol)
        }        
        fuEx.SetContractType(fuCt)

        self.offset = ["", 0]
        var fuRoutine = fuEx.Go("GetPosition")
        var spRoutine = spEx.Go("GetAccount")
        var fuPos = fuRoutine.wait()
        var spAcc = spRoutine.wait()
        if (!fuPos || !spAcc) {
            return false 
        }
        self.fuPos = fuPos
        self.spAcc = spAcc
        if (!self.initSpAcc) {
            return false 
        }
        self.spPos = (spAcc.Stocks + spAcc.FrozenStocks) - (self.initSpAcc.Stocks + self.initSpAcc.FrozenStocks)   // the current one minus the initial one; if the result is a positive number, make long
        // detect fuPos
        if (fuPos.length > 1) {
            return false 
        }
        fuPosAmount = fuPos.length == 0 ? 0 : (fuPos[0].Type == PD_LONG ? fuPos[0].Amount : -fuPos[0].Amount)
        if ((fuPosAmount > 0 && self.spPos > 0) || (fuPosAmount < 0 && self.spPos < 0)) {
            return false 
        }

        fuPosAmount = self.piece2Coin(fuPosAmount)

        self.hedgePos = (fuPosAmount == 0 || self.spPos == 0) ? 0 : (fuPosAmount < 0 && self.spPos > 0 ? Math.min(Math.abs(fuPosAmount), Math.abs(self.spPos)) : -Math.min(Math.abs(fuPosAmount), Math.abs(self.spPos)))
        var diffBalance = (spAcc.Balance + spAcc.FrozenBalance) - (self.initSpAcc.Balance + self.initSpAcc.FrozenBalance)
        if (self.hedgePos == 0) {
            self.hedgePosPrice = 0    
        } else {
            self.hedgePosPrice = fuPos[0].Price - (Math.abs(diffBalance) / Math.abs(self.spPos))
        }
        self.offset[1] = fuPosAmount + self.spPos  // positive number represents long position overflow; negative number represents short position overflow  
        if (fuPosAmount > 0 && self.spPos < 0) {   // reverse arbitrage 
            self.offset[0] = "minus"
        } else if (fuPosAmount < 0 && self.spPos > 0) {
            self.offset[0] = "plus"
        } else if (fuPosAmount == 0 && self.spPos < 0) {
            self.offset[0] = "minus"
        } else if (fuPosAmount > 0 && self.spPos == 0) {
            self.offset[0] = "minus"
        } else if (fuPosAmount == 0 && self.spPos > 0) {
            self.offset[0] = "plus"
        } else if (fuPosAmount < 0 && self.spPos == 0) {
            self.offset[0] = "plus"
        }
        return true 
    }

    self.getData = function() {
        return {
            "fuPos" : self.fuPos,
            "spPos" : self.spPos,
            "initSpAcc" : self.initSpAcc,
            "spAcc" : self.spAcc,
            "hedgePos" : self.hedgePos,
            "hedgePosPrice" : self.hedgePosPrice,
        }
    }

    self.keepBalance = function(depth) {
        var fuDepth = depth.fuExDepth
        var spDepth = depth.spExDepth
        if (self.offset[0] == "plus") {
            if (self.offset[1] >= self.minAmount) {
                if (self.balanceType == "close") {
                    // the spot long position amount is large; close spot long positions 
                    spEx.Sell(-1, self.offset[1])
                } else if (self.balanceType == "open") {
                    // the spot long position amount is large; open futures short positions 
                    fuEx.SetDirection("sell")
                    fuEx.Sell(-1, self.coin2Piece(Math.abs(self.offset[1])))
                }
            } else if (self.offset[1] <= -self.minAmount) {
                if (self.balanceType == "close") {
                    // the futures short position amount is large; close futures short positions  
                    fuEx.SetDirection("closesell")
                    fuEx.Buy(-1, self.coin2Piece(Math.abs(self.offset[1])))
                } else if (self.balanceType == "open") {
                    // the futures short position amount is large; open spot long positions  
                    spEx.Buy(-1, spDepth.Asks[0].Price * Math.abs(self.offset[1]))
                }
            }
            return false 
        } else if (self.offset[0] == "minus") {
            if (self.offset[1] >= self.minAmount) {
                if (self.balanceType == "close") {
                    // the futures long position amount is large; close futures long positions 
                    fuEx.SetDirection("closebuy")
                    fuEx.Sell(-1, self.coin2Piece(self.offset[1]))
                } else if (self.balanceType == "open") {
                    // the futures long position amount is large; open spot short positions 
                    spEx.Sell(-1, self.offset[1])
                }
            } else if (self.offset[1] <= -self.minAmount) {
                if (self.balanceType == "close") {
                    // the spot short position amount is large; close spot short positions 
                    spEx.Buy(-1, spDepth.Asks[0].Price * Math.abs(self.offset[1]))
                } else if (self.balanceType == "open") {
                    // the spot short position amount is large; open futures long positions 
                    fuEx.SetDirection("buy")
                    fuEx.Buy(-1, self.coin2Piece(Math.abs(self.offset[1])))
                }
            }
            return false 
        }
        return true 
    }

    self.process = function(depthManager) {
        var ts = new Date().getTime()
        var depth = depthManager.getData()
        var orders = self.getOrders()
        if (!orders) {
            return 
        }
        self.depth = depth
        var fuOrders = orders[0]
        var spOrders = orders[1]
        
        if (fuOrders.length == 0 && spOrders.length == 0) {
            // reset level
            if (self.hedgePos == 0) {
                self.level = 1
            } else {
                self.level = Math.max(1, _N(self.hedgePos / self.minAmount, 0))
            }

            // limit the maximum position amount 
            if (Math.abs(self.hedgePos) > 1) {
                return 
            }

            // pend orders 
            var fuDepth = depth.fuExDepth
            var spDepth = depth.spExDepth
            self.update()

            if (self.hedgePos >= 0 && fuDepth.Bids[0].Price - spDepth.Asks[0].Price > 0) {        // positive arbitrage 
                var distance = (step * self.level - (fuDepth.Asks[0].Price - spDepth.Bids[0].Price)) / 2          
                fuEx.SetDirection("sell")
                fuEx.Sell(fuDepth.Asks[0].Price + distance, self.coin2Piece(self.minAmount), fuDepth.Asks[0].Price, "pending order spread:", fuDepth.Asks[0].Price + distance - (spDepth.Bids[0].Price - distance))
                spEx.Buy(spDepth.Bids[0].Price - distance, self.minAmount, spDepth.Bids[0].Price)
            } else if (self.hedgePos <= 0 && spDepth.Bids[0].Price - fuDepth.Asks[0].Price > 0) { // reverse arbitrage
                var distance = (step * self.level - (spDepth.Asks[0].Price - fuDepth.Bids[0].Price)) / 2          
                fuEx.SetDirection("buy")
                fuEx.Buy(fuDepth.Bids[0].Price - distance, self.coin2Piece(self.minAmount), fuDepth.Bids[0].Price, "pending order spread:", spDepth.Asks[0].Price + distance - (fuDepth.Bids[0].Price - distance))
                spEx.Sell(spDepth.Asks[0].Price + distance, self.minAmount, spDepth.Asks[0].Price)
            }
        } else if (fuOrders.length == 1 && spOrders.length == 1) {
            var fuDepth = depth.fuExDepth
            var spDepth = depth.spExDepth            
            // judge location
            var isCancelAll = false 
            if (self.hedgePos >= 0 && fuDepth.Bids[0].Price - spDepth.Asks[0].Price > 0) {        // positive arbitrage
                var distance = (step * self.level - (fuDepth.Asks[0].Price - spDepth.Bids[0].Price)) / 2
                if (Math.abs(fuOrders[0].Price - (fuDepth.Asks[0].Price + distance)) > buffDiff || Math.abs(spOrders[0].Price - (spDepth.Bids[0].Price - distance)) > buffDiff) {
                    isCancelAll = true 
                }
            } else if (self.hedgePos <= 0 && spDepth.Bids[0].Price - fuDepth.Asks[0].Price > 0) { // reverse arbitrage
                var distance = (step * self.level - (spDepth.Asks[0].Price - fuDepth.Bids[0].Price)) / 2
                if (Math.abs(spOrders[0].Price - (spDepth.Asks[0].Price + distance)) > buffDiff || Math.abs(fuOrders[0].Price - (fuDepth.Bids[0].Price - distance)) > buffDiff) {
                    isCancelAll = true 
                }
            } else {
                isCancelAll = true 
            }
            if (isCancelAll) {
                self.cancelAll(fuEx, fuOrders)
                self.cancelAll(spEx, spOrders)
                self.lastUpdateTs = 0
            }
        } else {            
            self.cancelAll(fuEx, fuOrders)
            self.cancelAll(spEx, spOrders)       
            self.lastUpdateTs = 0
        }

        if (ts - self.lastUpdateTs > 1000 * 60 * 2) {
            self.update()
            self.keepBalance(depth)
            self.update()
            self.lastUpdateTs = ts 
        }
        LogStatus(_D())   // the status bar can be designed to export the data and the information that need to be observed 
    }

    self.getOrders = function() {
        spEx.SetCurrency(spSymbol)
        if (!IsVirtual()) {
            fuEx.SetCurrency(fuSymbol)
        }        
        fuEx.SetContractType(fuCt)

        var fuRoutine = fuEx.Go("GetOrders")
        var spRoutine = spEx.Go("GetOrders")
        var fuOrders = fuRoutine.wait()
        var spOrders = spRoutine.wait()
        if (!fuOrders || !spOrders) {
            return false 
        }
        return [fuOrders, spOrders]
    }
    
    // convert currency into contract amount
    self.coin2Piece = function(amount) {
        if (IsVirtual()) {
            if (fuEx.GetName() == "Futures_Binance") {
                return amount
            } else if (fuEx.GetName() == "Futures_OKCoin") {
                var price = (self.depth.fuExDepth.Bids[0].Price + self.depth.fuExDepth.Asks[0].Price) / 2
                return _N(amount / (100 / price), 0)
            } else {
                throw "not support"
            }            
        }
        if (fuEx.GetName() == "Futures_OKCoin") {
            if (fuEx.GetQuoteCurrency() == "USDT") {
                return _N(amount * 10, 0)
            } else if (fuEx.GetQuoteCurrency() == "USD") {
                var price = (self.depth.fuExDepth.Bids[0].Price + self.depth.fuExDepth.Asks[0].Price) / 2
                return _N(amount / (100 / price), 0)
            } else {
                throw "not support"
            }
        } else {
            throw "not support"
        }
    }
    
    // convert contract amount to currency 
    self.piece2Coin = function(amount) {
        if (IsVirtual()) {
            if (fuEx.GetName() == "Futures_Binance") {
                return amount
            } else if (fuEx.GetName() == "Futures_OKCoin") {
                var price = (self.depth.fuExDepth.Bids[0].Price + self.depth.fuExDepth.Asks[0].Price) / 2
                return amount * 100 / price
            } else {
                throw "not support"
            }            
        }
        if (fuEx.GetName() == "Futures_OKCoin") {
            if (fuEx.GetQuoteCurrency() == "USDT") {
                return amount * 0.1
            } else if (fuEx.GetQuoteCurrency() == "USD") {
                var price = (self.depth.fuExDepth.Bids[0].Price + self.depth.fuExDepth.Asks[0].Price) / 2
                return amount * 100 / price
            } else {
                throw "not support"
            }
        } else {
            throw "not support"
        }
    }

    self.cancelAll = function(e, orders) {
        var isFirst = true 
        while (true) {
            Sleep(500)
            if (orders && isFirst) {
                isFirst = false 
            } else {
                orders = e.GetOrders()
            }
            if (!orders) {
                continue
            } else {
                for (var i = 0 ; i < orders.length ; i++) {
                    e.CancelOrder(orders[i].Id, orders[i])
                }
            }
            if (orders.length == 0) {
                break
            }
        }
    }

    self.CoverAll = function() {
        // close all 
        // the one-click function of closing positions can be realized here
    }

    self.setMinAmount = function(minAmount) {
        self.minAmount = minAmount
    }

    self.init = function() {
        while(!self.spAcc) {
            self.update()
            Sleep(1000)
        }
        if (!self.initSpAcc) {  
            var positionManager_initSpAcc = _G("positionManager_initSpAcc")
            if (!positionManager_initSpAcc) {
                self.initSpAcc = self.spAcc
                _G("positionManager_initSpAcc", self.initSpAcc)
            } else {
                self.initSpAcc = positionManager_initSpAcc
            }
        } else {
            _G("positionManager_initSpAcc", self.initSpAcc)
        }
        // print the initial information
        Log("self.initSpAcc:", self.initSpAcc.Balance, self.initSpAcc.FrozenBalance, self.initSpAcc.Stocks, self.initSpAcc.FrozenStocks)
    }
    self.init()
    return self
}

function main() {
    _G(null)       // vacuum the persistent data  
    LogReset(1)    // rest logs 

    // use the following code to switch to OKEX simulated bot
    // exchanges[0].IO("simulate", true)
    // exchanges[1].IO("simulate", true)

    var dm = depthManager(exchanges[0], exchanges[1], fuContractType, fuSymbol, spSymbol)
    var pm = positionManager(exchanges[0], exchanges[1], fuContractType, fuSymbol, spSymbol, step, buff, balanceType)
    pm.setMinAmount(minAmount)

    while (true) {
        if (!dm.update()) {
            Sleep(3000)
            continue
        }

        var cmd = GetCommand()
        if (cmd) {
            // handle interaction 
            Log("interactive command:", cmd)
            var arr = cmd.split(":") 
            if (arr[0] == "") {
                pm.CoverAll()
            }            
        }

        pm.process(dm)
        Sleep(5000)
    }
}

بیک ٹسٹ تجزیہ

یہ دیکھا جاسکتا ہے کہ زیر التوا اور منسوخی بہت کثرت سے ہوتی ہے۔ بیک ٹیسٹ سسٹم کے اعدادوشمار سے ، فیوچر پلیٹ فارم اکاؤنٹ نے 0.01666 ETH کھوئے ، اور اسپاٹ ایکسچینج نے 842.23758 USDT کا منافع کمایا۔ بیک ٹیسٹ کے اختتام پر 4252USDT کی ETH اسپاٹ قیمت کے مطابق ، یعنی-0.01666 * 4252 = -70.83832000000001نتیجہ اور اسپاٹ منافع مجموعی طور پر منافع بخش ہے۔

تاہم، یہ صرف ایک بیک ٹیسٹ ہے، اور مزید تفصیلی مسائل کو ایک حقیقی بوٹ میں سنبھالا جائے گا.