FMZ परिमाणीकरण पर आधारित ऑर्डर सिंक्रोनाइज़ेशन प्रबंधन प्रणाली का डिज़ाइन (1)

एफएमजेड लाइब्रेरी के पिछले लेखों में, हमने कई ऑर्डर और स्थिति सिंक्रनाइज़ेशन रणनीतियों को डिज़ाइन किया है।

• एक सरल डिजिटल मुद्रा स्पॉट ट्रेडिंग रोबोट को कार्यान्वित करें
• डिजिटल मुद्रा अनुबंध सरल कॉपी ट्रेडिंग रोबोट

इनका उद्देश्य ऑर्डर और पोजीशन को प्रबंधित करने और सिंक्रनाइज़ करने के लिए संदर्भ खाते और सिंक्रोनाइज़ेशन खाते को एक रणनीति में रखना है। आज हम एक अलग डिज़ाइन की कोशिश करेंगे। FMZ क्वांटिटेटिव ट्रेडिंग प्लेटफ़ॉर्म के शक्तिशाली विस्तारित API इंटरफ़ेस के आधार पर, हम एक ऑर्डर सिंक्रोनाइज़ेशन मैनेजमेंट सिस्टम डिज़ाइन करेंगे।

डिजाइन विचार

सबसे पहले हमें कुछ अच्छे सुझावों और जरूरतों की जरूरत है। उपरोक्त दो पिछली ऑर्डर और पोजीशन सिंक्रोनाइजेशन रणनीतियों में कई स्पष्ट दर्द बिंदु हैं। आइए उन पर एक साथ चर्चा करें:

• 1. सिंक्रोनाइज़ेशन रणनीति के कार्यान्वयनकर्ता के पास संदर्भ खाते की एक्सचेंज API कुंजी और सिंक्रोनाइज़ेशन खाते की एक्सचेंज API कुंजी होनी चाहिए। इस प्रश्न का उपयोग परिदृश्य यह है: यदि आपके अन्य एक्सचेंज खाते आपके किसी खाते का अनुसरण करें तो इसमें कोई समस्या नहीं है। लेकिन यदि संदर्भ खाते और सिंक्रोनाइज़ेशन खाते का स्वामी एक ही न हो तो यह परेशानी वाली बात होगी। कभी-कभी, सुरक्षा संबंधी चिंताओं के कारण, सिंक्रोनाइज़्ड खाते का स्वामी अपने एक्सचेंज खाते की API कुंजी प्रदान करने के लिए तैयार नहीं होता है। लेकिन मैं API कुंजी प्रदान किए बिना सिंक्रोनस रूप से ऑर्डर कैसे दे सकता हूं?

समाधान: FMZ के विस्तारित API इंटरफ़ेस का उपयोग करते हुए, सिंक्रोनाइज़ेशन खाते के मालिक (अनुयायी) को केवल FMZ मात्रात्मक ट्रेडिंग प्लेटफ़ॉर्म को पंजीकृत करना होगा और फिर एक रणनीति चलानी होगी (इस लेख में डिज़ाइन की गई प्रणाली में:订单同步管理系统（Synchronous Server）रणनीति वास्तविक बाजार). फिर संदर्भ खाते के स्वामी (ऑर्डर लाने वाले व्यक्ति) को FMZ विस्तारित API कुंजी (ध्यान दें, एक्सचेंज खाते की API कुंजी नहीं) और ऑर्डर सिंक्रोनाइजेशन प्रबंधन प्रणाली (सिंक्रोनस सर्वर) की वास्तविक समय आईडी प्रदान करें। . खाता स्वामी (जिसके पास आदेश है) के वास्तविक आदेश का संदर्भ देते समय (इस लेख में डिज़ाइन की गई प्रणाली में)订单同步管理系统类库（Single Server）) सिग्नल भेजता है, तो सिंक्रोनाइज्ड खाता स्वामी का वास्तविक खाता ट्रेडिंग सिग्नल प्राप्त करेगा और उसके बाद स्वचालित रूप से ऑर्डर दे देगा।

• 1. कई डेवलपर्स के पास बेहतर रणनीतियाँ हैं, लेकिन वे ऊपर वर्णित दो पुराने ऑर्डर और स्थिति सिंक्रनाइज़ेशन रणनीतियों का उपयोग नहीं कर सकते हैं। क्योंकि इसके लिए इन समन्वय रणनीतियों के साथ अपनी रणनीति को एकीकृत करने की आवश्यकता होगी, और रणनीति में आमूलचूल परिवर्तन की आवश्यकता होगी, जो समय लेने वाला और श्रमसाध्य होगा। क्या मेरी कुछ परिपक्व रणनीतियों को सीधे ऑर्डर सिंक्रोनाइज़ेशन फ़ंक्शन में अपग्रेड करने का कोई अच्छा तरीका है? समाधान: आप एक ऑर्डर सिंक्रोनाइज़ेशन टेम्प्लेट लाइब्रेरी (इस आलेख में डिज़ाइन की गई प्रणाली) डिज़ाइन कर सकते हैं订单同步管理系统类库（Single Server）रणनीति), संदर्भ खाते के मालिक (वह व्यक्ति जो ऑर्डर लेता है) को ऑर्डर और स्थिति सिंक्रनाइज़ेशन फ़ंक्शन को प्राप्त करने के लिए इस टेम्पलेट लाइब्रेरी को सीधे अपनी रणनीति में एम्बेड करने की अनुमति देता है।
• 1. एक अतिरिक्त वास्तविक ऑर्डर कम करें। अंतिम समस्या यह है कि यदि आप ऊपर वर्णित दो पुराने ऑर्डर और स्थिति समन्वयन रणनीतियों का उपयोग करते हैं। संदर्भ खाते (एकल खाते के साथ) की स्थिति की निगरानी के लिए एक अतिरिक्त वास्तविक खाता खोलना आवश्यक है। समाधान: संदर्भ खाता रणनीतियों में कार्यक्षमता एम्बेड करने के लिए टेम्पलेट लाइब्रेरी का उपयोग करें।

इस प्रणाली में दो भाग हैं: 1. ऑर्डर सिंक्रोनाइज़ेशन प्रबंधन प्रणाली क्लास लाइब्रेरी (एकल सर्वर) 2. ऑर्डर सिंक्रोनस मैनेजमेंट सिस्टम (सिंक्रोनस सर्वर)

अब जब आवश्यकताएं स्पष्ट हो गई हैं, तो चलिए डिजाइनिंग शुरू करते हैं!

डिज़ाइन 1: ऑर्डर सिंक्रोनाइज़ेशन मैनेजमेंट सिस्टम क्लास लाइब्रेरी (एकल सर्वर)

ध्यान रखें कि यह कोई रणनीति नहीं है। यह FMZ की एक टेम्पलेट क्लास लाइब्रेरी है। टेम्पलेट क्लास लाइब्रेरी की अवधारणा को FMZ API दस्तावेज़ में खोजा जा सकता है, इसलिए मैं यहाँ विवरण में नहीं जाऊँगा।

टेम्पलेट लाइब्रेरी कोड:

// 全局变量
var keyName_label = "label"
var keyName_robotId = "robotId"
var keyName_extendAccessKey = "extendAccessKey"
var keyName_extendSecretKey = "extendSecretKey"
var fmzExtendApis = parseConfigs([config1, config2, config3, config4, config5])
var mapInitRefPosAmount = {}

function parseConfigs(configs) {
    var arr = []
    _.each(configs, function(config) {
        if (config == "") {
            return 
        }
        var strArr = config.split(",")
        if (strArr.length != 4) {
            throw "configs error!"
        }
        var obj = {}
        obj[keyName_label] = strArr[0]
        obj[keyName_robotId] = strArr[1]
        obj[keyName_extendAccessKey] = strArr[2]
        obj[keyName_extendSecretKey] = strArr[3]
        arr.push(obj)
    })
    return arr 
}

function getPosAmount(pos, ct) {
    var longPosAmount = 0
    var shortPosAmount = 0
    _.each(pos, function(ele) {
        if (ele.ContractType == ct && ele.Type == PD_LONG) {
            longPosAmount = ele.Amount
        } else if (ele.ContractType == ct && ele.Type == PD_SHORT) {
            shortPosAmount = ele.Amount
        }
    })
    var timestamp = new Date().getTime()
    return {ts: timestamp, long: longPosAmount, short: shortPosAmount}
}

function sendCommandRobotMsg (robotId, accessKey, secretKey, msg) {
    // https://www.fmz.com/api/v1?access_key=xxx&secret_key=yyyy&method=CommandRobot&args=[186515,"ok12345"]
    var url = "https://www.fmz.com/api/v1?access_key=" + accessKey + "&secret_key=" + secretKey + "&method=CommandRobot&args=[" + robotId + ',"' + msg + '"]'
    Log(url)
    var ret = HttpQuery(url)
    return ret 
}

function follow(nowPosAmount, symbol, ct, type, delta) {
    var msg = ""
    var nowAmount = type == PD_LONG ? nowPosAmount.long : nowPosAmount.short
    if (delta > 0) {
        // 开仓
        var tradeDirection = type == PD_LONG ? "buy" : "sell"
        // 发送信号
        msg = symbol + "," + ct + "," + tradeDirection + "," + Math.abs(delta)        
    } else if (delta < 0) {
        // 平仓
        var tradeDirection = type == PD_LONG ? "closebuy" : "closesell"
        if (nowAmount <= 0) {
            Log("未检测到持仓")
            return 
        }
        // 发送信号
        msg = symbol + "," + ct + "," + tradeDirection + "," + Math.abs(delta)
    } else {
        throw "错误"
    }
    if (msg) {
        _.each(fmzExtendApis, function(extendApiConfig) {
            var ret = sendCommandRobotMsg(extendApiConfig[keyName_robotId], extendApiConfig[keyName_extendAccessKey], extendApiConfig[keyName_extendSecretKey], msg)
            Log("调用CommandRobot接口，", "label:", extendApiConfig[keyName_label], "， msg:", msg, "， ret:", ret)
            Sleep(1000)
        })
    }
}

$.PosMonitor = function(exIndex, symbol, ct) {    
    var ts = new Date().getTime()
    var ex = exchanges[exIndex]
    // 判断ex类型
    var exName = ex.GetName()
    var isFutures = exName.includes("Futures_")
    var exType = isFutures ? "futures" : "spot"
    if (!isFutures) {
        throw "仅支持期货跟单"
    }

    if (exType == "futures") {
        // 缓存 symbol ct
        var buffSymbol = ex.GetCurrency()
        var buffCt = ex.GetContractType()

        // 切换到对应的交易对、合约代码
        ex.SetCurrency(symbol)
        if (!ex.SetContractType(ct)) {
            throw "SetContractType failed"
        }

        // 监控持仓
        var keyInitRefPosAmount = "refPos-" + exIndex + "-" + symbol + "-" + ct    // refPos-exIndex-symbol-contractType
        var initRefPosAmount = mapInitRefPosAmount[keyInitRefPosAmount]
        if (!initRefPosAmount) {
            // 没有初始化数据，初始化          
            mapInitRefPosAmount[keyInitRefPosAmount] = getPosAmount(_C(ex.GetPosition), ct)
            initRefPosAmount = mapInitRefPosAmount[keyInitRefPosAmount]
        }

        // 监控
        var nowRefPosAmount = getPosAmount(_C(ex.GetPosition), ct)
        // 计算仓位变动
        var longPosDelta = nowRefPosAmount.long - initRefPosAmount.long
        var shortPosDelta = nowRefPosAmount.short - initRefPosAmount.short

        // 检测变动
        if (!(longPosDelta == 0 && shortPosDelta == 0)) {
            // 执行多头动作
            if (longPosDelta != 0) {
                Log(ex.GetName(), ex.GetLabel(), symbol, ct, "执行多头跟单，变动量：", longPosDelta)
                follow(nowRefPosAmount, symbol, ct, PD_LONG, longPosDelta)
            }
            // 执行空头动作
            if (shortPosDelta != 0) {
                Log(ex.GetName(), ex.GetLabel(), symbol, ct, "执行空头跟单，变动量：", shortPosDelta)
                follow(nowRefPosAmount, symbol, ct, PD_SHORT, shortPosDelta)
            }

            // 执行跟单操作后，更新
            mapInitRefPosAmount[keyInitRefPosAmount] = nowRefPosAmount
        }

        // 恢复 symbol ct
        ex.SetCurrency(buffSymbol)
        ex.SetContractType(buffCt)
    } else if (exType == "spot") {
        // 现货
    }
}

$.getTbl = function() {
    var tbl = {
        "type" : "table", 
        "title" : "同步数据", 
        "cols" : [], 
        "rows" : []
    }
    // 构造表头
    tbl.cols.push("监控账户:refPos-exIndex-symbol-contractType")
    tbl.cols.push(`监控持仓:{"时间戳":xxx,"多头持仓量":xxx,"空头持仓量":xxx}`)
    _.each(fmzExtendApis, function(extendApiData, index) {
        tbl.cols.push(keyName_robotId + "-" + index)
    })
    
    // 写入数据
    _.each(mapInitRefPosAmount, function(initRefPosAmount, key) {
        var arr = [key, JSON.stringify(initRefPosAmount)]
        _.each(fmzExtendApis, function(extendApiData) {
            arr.push(extendApiData[keyName_robotId])
        })
        tbl.rows.push(arr)
    })

    return tbl
}

// 引用该模板类库的策略调用范例
function main() {
    // 清除所有日志
    LogReset(1)

    // 切换到OKEX 模拟盘测试
    exchanges[0].IO("simulate", true)

    // 设置合约
    exchanges[0].SetCurrency("ETH_USDT")
    exchanges[0].SetContractType("swap")

    // 定时交易时间间隔
    var tradeInterval = 1000 * 60 * 3        // 三分钟交易一次，用于观察跟单信号
    var lastTradeTS = new Date().getTime()
    
    while (true) {
        // 策略其它逻辑...

        // 用于测试的模拟交易触发
        var ts = new Date().getTime()
        if (ts - lastTradeTS > tradeInterval) {
            Log("模拟带单策略发生交易，持仓变化", "#FF0000")
            exchanges[0].SetDirection("buy")
            exchanges[0].Buy(-1, 1)
            lastTradeTS = ts
        }

        // 使用模板的接口函数
        $.PosMonitor(0, "ETH_USDT", "swap")    // 可以设置多个监控，监控带单策略上的不同的exchange对象  
        var tbl = $.getTbl()
        
        // 显示状态栏
        LogStatus(_D(), "\n" + "`" + JSON.stringify(tbl) + "`")
        Sleep(1000)
    }
}

डिज़ाइन बहुत सरल है, इस क्लास लाइब्रेरी में 2 कार्यात्मक कार्य हैं। जब FMZ प्लेटफॉर्म पर एक प्रोग्रामेटिक ट्रेडिंग रणनीति संदर्भित होती है订单同步管理系统类库（Single Server）टेम्पलेट लाइब्रेरी के बाद. यह रणनीति निम्नलिखित फ़ंक्शन का उपयोग कर सकती है।

• $.PosMonitor इसका कार्य रणनीति में एक्सचेंज ऑब्जेक्ट की स्थिति में परिवर्तन की निगरानी करना है, और फिर टेम्पलेट के मापदंडों में निर्धारित वास्तविक बाजार में ट्रेडिंग सिग्नल भेजना है: ऑर्डर सिंक्रोनाइजेशन मैनेजमेंट सिस्टम क्लास लाइब्रेरी (एकल सर्वर)।

• $.getTbl मॉनिटर किए गए सिंक्रनाइज़ेशन डेटा को लौटाता है.

उपयोग का उदाहरण इस प्रकार है: ऑर्डर सिंक्रोनाइज़ेशन मैनेजमेंट सिस्टम क्लास लाइब्रेरी (सिंगल सर्वर) टेम्पलेटmainसमारोह में:

// 引用该模板类库的策略调用范例
function main() {
    // 清除所有日志
    LogReset(1)

    // 切换到OKEX 模拟盘测试
    exchanges[0].IO("simulate", true)

    // 设置合约
    exchanges[0].SetCurrency("ETH_USDT")
    exchanges[0].SetContractType("swap")

    // 定时交易时间间隔
    var tradeInterval = 1000 * 60 * 3        // 三分钟交易一次，用于观察跟单信号
    var lastTradeTS = new Date().getTime()
    
    while (true) {
        // 策略其它逻辑...

        // 用于测试的模拟交易触发
        var ts = new Date().getTime()
        if (ts - lastTradeTS > tradeInterval) {
            Log("模拟带单策略发生交易，持仓变化", "#FF0000")
            exchanges[0].SetDirection("buy")
            exchanges[0].Buy(-1, 1)
            lastTradeTS = ts
        }

        // 使用模板的接口函数
        $.PosMonitor(0, "ETH_USDT", "swap")    // 可以设置多个监控，监控带单策略上的不同的exchange对象  
        var tbl = $.getTbl()
        
        // 显示状态栏
        LogStatus(_D(), "\n" + "`" + JSON.stringify(tbl) + "`")
        Sleep(1000)
    }
}

एक टेम्पलेट लाइब्रेरी स्वयं भी वास्तविक रणनीतियाँ बना सकती है, जिसका उपयोग आमतौर पर टेम्पलेट लाइब्रेरी का परीक्षण करने के लिए किया जाता है। उदाहरण के लिए, इस टेम्पलेट का एक परीक्षण. आप टेम्पलेट को समझ सकते हैंmainएक फ़ंक्शन आपकी अपनी एक रणनीति है।mainसमारोह।

परीक्षण कोड OKEX सिमुलेशन डिस्क परीक्षण का उपयोग करने के लिए लिखा गया है। FMZ पर OKEX सिमुलेशन डिस्क API KEY को संदर्भ खाते (ऑर्डर के साथ) के रूप में कॉन्फ़िगर करना और मुख्य फ़ंक्शन में सिमुलेशन डिस्क पर स्विच करना शुरू करना आवश्यक है। फिर ट्रेडिंग जोड़ी को ETH_USDT पर और अनुबंध को स्थायी (स्वैप) पर सेट करें। फिर while लूप में प्रवेश करें। रणनीति व्यापार के ट्रिगरिंग का अनुकरण करने के लिए चक्र में हर 3 मिनट में एक ऑर्डर दिया जाता है। while लूप कॉल करता है$.PosMonitor(0, "ETH_USDT", "swap")इस फ़ंक्शन का पहला पैरामीटर 0 के रूप में पास किया जाता है, जो मॉनिटरिंग एक्सचेंजों को इंगित करता है[0] यह एक्सचेंज ऑब्जेक्ट ETH_USDT ट्रेडिंग जोड़ी और स्वैप अनुबंध की निगरानी करता है। फिर कॉल करो$.getTbl()चार्ट जानकारी प्राप्त करने के लिए, उपयोग करेंLogStatus(_D(), "\n" + "” + JSON.stringify(tbl) + “")चार्ट डेटा को स्टेटस बार पर प्रदर्शित करने में सक्षम बनाता है।

तो आप देखिए, जब तक आप इसका उपयोग ऐसी नीति में करते हैं जो इस टेम्पलेट का संदर्भ देती है$.PosMonitor(0, "ETH_USDT", "swap")रणनीति को किसी निश्चित उत्पाद की स्थिति की निगरानी करने और स्थिति में परिवर्तन के आधार पर संदेश भेजने के कार्य से सुसज्जित किया जा सकता है।

परीक्षण से पहले, कृपया समझाएं订单同步管理系统类库（Single Server）रणनीति पैरामीटर डिजाइन: मैंने अभी-अभी इस बारे में बात की कि रणनीति उन्नयन को एकल फ़ंक्शन प्रदान करने के लिए टेम्पलेट इंटरफ़ेस फ़ंक्शन का उपयोग कैसे किया जाए। तो जब स्थिति बदलती है तो संकेत किसे भेजा जाता है? यह प्रश्न किसको भेजा जाएगा, इसका निर्धारण इस बात से होता है订单同步管理系统类库（Single Server）कॉन्फ़िगर करने के लिए पैरामीटर.

आप देख सकते हैं कि इसमें 5 पैरामीटर हैं, जो 5 पुश तक का समर्थन करते हैं (यदि आपको इसे बढ़ाने की आवश्यकता है तो आप इसे विस्तारित कर सकते हैं), और पैरामीटर डिफ़ॉल्ट रूप से रिक्त स्ट्रिंग पर सेट होता है, जिसका अर्थ है कि इसे संसाधित नहीं किया गया है। कॉन्फ़िगरेशन स्ट्रिंग प्रारूप: लेबल, रोबोटआईडी, एक्सेसकी, सीक्रेटकी

• label सिंक्रनाइज़ खाते के लेबल का उपयोग किसी निश्चित खाते को चिह्नित करने के लिए किया जाता है, और नाम इच्छानुसार सेट किया जा सकता है।

• robotId वास्तविक आईडी, सिंक्रोनाइजेशन खाते के स्वामी द्वारा बनाई गई订单同步管理系统（Synchronous Server）वास्तविक लेनदेन की आईडी.

• accessKey FMZ की विस्तारित API एक्सेसकी

• secretKey FMZ की विस्तारित API secretKey

अब हम एक सरल परीक्षण कर सकते हैं।

ऑर्डर सिंक्रोनाइजेशन मैनेजमेंट सिस्टम क्लास लाइब्रेरी (एकल सर्वर) वास्तविक डिस्क ऑपरेशन:

ऑर्डर सिंक्रोनाइजेशन प्रबंधन प्रणाली (सिंक्रोनस सर्वर) को संकेत प्राप्त हुआ: हमने अभी तक ऑर्डर सिंक्रोनाइज़ेशन मैनेजमेंट सिस्टम (सिंक्रोनस सर्वर) का डिज़ाइन पूरा नहीं किया है। आइए पहले इसे एक सरल कोड के साथ लागू करें जो लेनदेन नहीं करता है बल्कि केवल सिग्नल प्रिंट करता है:

ऑर्डर सिंक्रोनाइजेशन प्रबंधन प्रणाली का अस्थायी कोड (सिंक्रोनस सर्वर):

function main() {
    LogReset(1)
    while (true) {
        var cmd = GetCommand()
        if (cmd) {
            // cmd: ETH_USDT,swap,buy,1
            Log("cmd: ", cmd)
        }
        Sleep(1000)
    }
}

आप देख सकते हैं कि सिंक्रोनाइज़ेशन खाता स्वामी के वास्तविक खाते को जानकारी प्राप्त हुई है:ETH_USDT,swap,buy,1。 इस तरह, अगला कदम जानकारी में ट्रेडिंग जोड़ी, अनुबंध कोड, ट्रेडिंग दिशा और मात्रा के आधार पर स्वचालित रूप से ऑर्डर का पालन करना है।

वर्तमान में订单同步管理系统（Synchronous Server）यह सिर्फ अस्थायी कोड है, हम अगले अंक में इसके डिजाइन पर चर्चा जारी रखेंगे।