संसाधन लोड हो रहा है... लोड करना...

तीन बड़े एक्सचेंजों ने स्टॉप-लॉस इंटीग्रेटेड लाइब्रेरी बनाई

लेखक:लाइटफ्लाय, दिनांक: 2021-03-11 22:37:54
टैगःऔजार

fmz प्लेटफॉर्म में स्टॉपलॉस सुविधा नहीं है, स्टॉपलॉस को सेट करने के लिए एक्सचेंज के अन्य फ़ंक्शन इंटरफेस को कॉल करना आवश्यक है, जबकि विभिन्न एक्सचेंजों में स्टॉपलॉस सेटिंग्स अलग-अलग हैं, इसलिए निम्नलिखित पैकेज किया गया है। यह विशेष रूप से महत्वपूर्ण है, क्योंकि यह बाजार मूल्य के बिना ट्रिगर किए गए उच्च प्रसंस्करण शुल्क से बचता है और चरम परिस्थितियों में विस्फोट की संभावना से बचता है। यह फ़ंक्शन स्टॉक के पूरे स्टॉक को ध्यान में रखता है, और यू-बिट सिक्के के स्थान को भी ध्यान में रखता है।


import json

# 对合约进行止盈止损   cangType=0默认逐仓  =1全仓
def zhiyingzhisun(ex, amount, directionStr, zhiying, zhisun, cangType = 0):
    if ex.GetName().find('OK') >= 0 :
        # okex
        return okexSwap(ex, amount, directionStr, zhiying, zhisun)
    elif ex.GetName().find('Huobi') >= 0 :
        # huobi
        return huobiSwap(ex, amount, directionStr, zhiying, zhisun, cangType)
    elif ex.GetName().find('Binance') >= 0 :
        # bian
        return bianSwap(ex, amount, directionStr, zhiying, zhisun)
    else:
        return False

# 发送请求
def AsynIo(ex, paramList):
        if (len(paramList) == 3):
            arrRoutine = ex.Go("IO", paramList[0], paramList[1], paramList[2])
        elif (len(paramList) == 4):
            arrRoutine = ex.Go("IO", paramList[0], paramList[1], paramList[2], paramList[3])
        elif (len(paramList) == 5):
            arrRoutine = ex.Go("IO", paramList[0], paramList[1], paramList[2], paramList[3], paramList[4])
        data, ok = arrRoutine.wait()
        return data
# 火币合约
def huobiSwap(ex, amount, directionStr, zhiying, zhisun, cangType):
    instrument_id = ex.GetCurrency().replace('_',"-")
    # 根据全仓或逐仓 与 U本位或币本位,设置请求url
    if instrument_id.find('USDT') >= 0 :
        if cangType == 0:
            url = "/linear-swap-api/v1/swap_tpsl_order"
        elif cangType == 1:
            url = '/linear-swap-api/v1/swap_cross_tpsl_order'
        else:
            return False
    elif instrument_id.find('USD') >= 0 :
        url = "/swap-api/v1/swap_tpsl_order"
    else:
        return False
    # 发送请求
    data = AsynIo(ex, ['api', 'POST', url, '', json.dumps({
        "contract_code": instrument_id,
        "direction": directionStr,
        "volume" : amount,
        "tp_order_price": zhiying,
        "tp_trigger_price": zhiying,
        "sl_trigger_price": zhisun,
        "sl_order_price": zhisun,
    })])
    if data["status"] == 'ok':
        return True
    else:
        return False

# 币安合约
def bianSwap(ex, amount, directionStr, zhiying, zhisun):
    instrument_id = ex.GetCurrency().replace('_',"")
    # U本位或币本位,设置请求url
    if instrument_id.find('USDT') >= 0 :
        url = "/fapi/v1/order"
    elif instrument_id.find('USD') >= 0 :
        url = '/dapi/v1/order'
    else:
        return False
    # 止损
    zhisunData = AsynIo(ex, ['api', 'POST', url , '', json.dumps({
        "symbol": instrument_id,
        "side": directionStr,
        "type": "STOP",
        "quantity": amount,
        "price": zhisun,
        "stopPrice": zhisun,
        "timestamp": str(int(round(time.time() * 1000)))
    })])
    if int(zhisunData['stopPrice']) != int(zhisun):
        return False
    # 止盈
    zhiyingData = AsynIo(ex, ['api', 'POST', url , '', json.dumps({
        "symbol": instrument_id,
        "side": direction,
        "type": "TAKE_PROFIT",
        "quantity": amount,
        "price": zhiying,
        "stopPrice": zhiying,
        "timestamp": str(int(round(time.time() * 1000)))
    })])
    if int(zhiyingData['stopPrice']) != int(zhiying):
        return False
    return True


# 欧易合约
def okexSwap(ex, amount, directionStr, zhiying, zhisun):
    instrument_id = ex.GetCurrency().replace('_',"-") + '-SWAP'
    # 获取仓位方向
    if directionStr == 'buy':
        direction = '4'
    elif directionStr == 'sell':
        direction = '3'
    else:
        return False
    data =  AsynIo(ex, ['api', 'POST', '/v1/order/orders/place', '', json.dumps({
        "instrument_id": instrument_id,
        "type": direction,
        "order_type": '5',
        "size": amount,
        "tp_trigger_price": zhiying,
        "tp_price": zhiying,
        "sl_trigger_price": zhisun,
        "sl_price": zhisun
    })])
    if data["error_code"] == "0":
        return True
    else:
        return False
    
ext.zhiyingzhisun = zhiyingzhisun

संबंधित

अधिक

मिंग्सी1005क्या मैं अपने मौजूदा रणनीति रोबोट में एकीकृत कर सकता हूं?

दीव31सीखा

xxs1xxs1मैं टिप्पणियों को हटाना चाहता हूं।

xxs1xxs1और अगर आप इसे बंद करने के लिए नहीं है, तो आप इसे उपयोग करने की जरूरत नहीं है, बस एक वाक्य लिखने के लिए है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है, और आप इसे बंद करने के लिए नहीं है।