1. Quadrat
2. Die Quantifizierung der unbegrenzten Gitter-Handelstrategie

Die Quantifizierung der unbegrenzten Gitter-Handelstrategie

Schriftsteller:Quantifizierung, Datum: 29.8.2023
Tags:

---

---

##
# 无限网格交易策略（公开版）
# Author: 子辰量化
# Last Modified: 2024-1-4
##

import time

assetRatio = 0.5 # 资产投资比例

originalTotalMoney = totalInvestment # 基准投资额，总投资额+盈亏后的全部权益
originalAssetMoney = totalInvestment * assetRatio # 基准资产价值
originalCashMoney = totalInvestment * (1 - assetRatio) # 基准现金

remainCashMoney = originalTotalMoney # 当前剩余现金
investAssetMoney = 0 # 当前资产价值
inverstAssetAmount = 0 # 当前资产数量

boolInited = False # 是否完成了首次建仓

i = 0 # tick计算

def num_cut(num, c):
    str_num = str(num)
    return float(str_num[:str_num.index('.') + 1 + c])

def onTick():
    global assetRatio
    global originalTotalMoney
    global originalAssetMoney
    global originalCashMoney
    global remainCashMoney
    global investAssetMoney
    global inverstAssetAmount
    global boolInited
    global i

    ticker = exchange.GetTicker()
    # Log(ticker)
    openTime = time.localtime(ticker.Time / 1000) # ticker time
    openTimeStr = time.strftime("%Y-%m-%dT%H:%M:%S", openTime) 
    price = ticker.Last

    # 初始建仓
    if not boolInited:
        money = originalAssetMoney
        id = exchange.Buy(-1, money) # 市价单
        # Log("order id:", id)
        order = exchange.GetOrder(id)
        Log("buy money:", money)
        Log("order id:", order["Id"], "Price:", order["Price"], "Amount:", order["Amount"], "DealAmount:", order["DealAmount"], "AvgPrice:", order["AvgPrice"], "Status:", order["Status"], "Type:", order["Type"])
        money = order["Amount"] # 成交的money
        dealAmount = order["DealAmount"] # 已扣除手续费的资产数量
        price = order["AvgPrice"] # 成交均价
        remainCashMoney = originalCashMoney
        investAssetMoney = originalAssetMoney
        inverstAssetAmount = dealAmount        
        boolInited = True
        Log(f"use ${investAssetMoney} buy {inverstAssetAmount} asset at price ${price} at time {openTimeStr}")

        Log(f"{i} summary:")
        originalTotalMoney = originalAssetMoney + originalCashMoney
        investAssetMoney = inverstAssetAmount * price
        currentTotalMoney = investAssetMoney + remainCashMoney
        Log(f"originalAssetMoney: ${originalAssetMoney}")
        Log(f"originalCashMoney: ${originalCashMoney}")
        Log(f"originalTotalMoney: ${originalTotalMoney}")
        Log(f"inverstAssetAmount: ${inverstAssetAmount}")
        Log(f"investAssetMoney: ${investAssetMoney}")
        Log(f"remainCashMoney: ${remainCashMoney}")
        Log(f"currentTotalMoney: ${currentTotalMoney}")
        # account = exchange.GetAccount()
        # Log("Balance:", account["Balance"], "FrozenBalance:", account["FrozenBalance"], "Stocks:", account["Stocks"], "FrozenStocks:", account["FrozenStocks"])

    # 买入
    money = inverstAssetAmount * price # pirce
    if money < originalAssetMoney * (1 - buyRatio):
        money = originalAssetMoney * buyRatio # 买入金额
        account = exchange.GetAccount()
        if remainCashMoney > money and account["Balance"] > money: # 判断是否还有足够的现金，双重检查 
            # amount = money / price
            id = exchange.Buy(-1, money) # 市价单
            # Log("order id:", id)
            order = exchange.GetOrder(id)
            Log("buy money:", money)
            Log("order id:", order["Id"], "Price:", order["Price"], "Amount:", order["Amount"], "DealAmount:", order["DealAmount"], "AvgPrice:", order["AvgPrice"], "Status:", order["Status"], "Type:", order["Type"])
            money = order["Amount"] # 成交的money
            dealAmount = order["DealAmount"] # 已扣除手续费的资产数量
            price = order["AvgPrice"] # 成交均价  
            remainCashMoney -= money
            inverstAssetAmount = inverstAssetAmount + dealAmount
            Log(f"bull/bear buy {dealAmount} asset at ${price} at time {openTimeStr}")

            Log(f"{i} summary:")
            originalTotalMoney = originalAssetMoney + originalCashMoney
            investAssetMoney = inverstAssetAmount * price
            currentTotalMoney = investAssetMoney + remainCashMoney
            Log(f"originalAssetMoney: ${originalAssetMoney}")
            Log(f"originalCashMoney: ${originalCashMoney}")
            Log(f"originalTotalMoney: ${originalTotalMoney}")
            Log(f"inverstAssetAmount: ${inverstAssetAmount}")
            Log(f"investAssetMoney: ${investAssetMoney}")
            Log(f"remainCashMoney: ${remainCashMoney}")
            Log(f"currentTotalMoney: ${currentTotalMoney}")
            # account = exchange.GetAccount()
            #Log("Balance:", account["Balance"], "FrozenBalance:", account["FrozenBalance"], "Stocks:", account["Stocks"], "FrozenStocks:", account["FrozenStocks"])

    # 卖出
    money = inverstAssetAmount * price # pirce
    if money > (originalAssetMoney * (1 + sellRatio)):
        money = originalAssetMoney * sellRatio # 卖出金额
        amount = money / price
        id = exchange.Sell(-1, amount) # 市价单
        # Log("order id:", id)
        order = exchange.GetOrder(id)
        Log("sell money:", money)
        Log("sell amount:", amount) 
        Log("order id:", order["Id"], "Price:", order["Price"], "Amount:", order["Amount"], "DealAmount:", order["DealAmount"], "AvgPrice:", order["AvgPrice"], "Status:", order["Status"], "Type:", order["Type"])
        amount = order["Amount"] # 计划卖出资产数量
        dealAmount = order["DealAmount"] # 成交资产数量，这里好像是从balance扣除的手续费吗?
        # 从日志来看amount == dealAmount,所以手续费是从balance扣除的
        price = order["AvgPrice"] # 成交均价
        dealMoney = dealAmount * price # 未扣除手续费
        remainCashMoney += dealMoney # 这里需要减去手续费
        inverstAssetAmount = inverstAssetAmount - dealAmount
        Log(f"bull/bear sell {amount} asset at ${price} at time {openTimeStr}")

        Log(f"{i} summary:")
        originalTotalMoney = originalAssetMoney + originalCashMoney
        investAssetMoney = inverstAssetAmount * price
        currentTotalMoney = investAssetMoney + remainCashMoney
        Log(f"originalAssetMoney: ${originalAssetMoney}")
        Log(f"originalCashMoney: ${originalCashMoney}")
        Log(f"originalTotalMoney: ${originalTotalMoney}")
        Log(f"inverstAssetAmount: ${inverstAssetAmount}")
        Log(f"investAssetMoney: ${investAssetMoney}")
        Log(f"remainCashMoney: ${remainCashMoney}")
        Log(f"currentTotalMoney: ${currentTotalMoney}")
        # account = exchange.GetAccount()
        # Log("Balance:", account["Balance"], "FrozenBalance:", account["FrozenBalance"], "Stocks:", account["Stocks"], "FrozenStocks:", account["FrozenStocks"])

    ##
    # 仓位调整
    ##
    # 当remainCashMoney超过originalCashMoney的10%时，加大投资基准
    if remainCashMoney >= originalCashMoney * 1.1:
        money = (remainCashMoney - originalCashMoney) / 2 # 买入金额
        # amount = money / price
        id = exchange.Buy(-1, money) # 市价单
        # Log("order id:", id)
        order = exchange.GetOrder(id)
        Log("buy money:", money)
        Log("order id:", order["Id"], "Price:", order["Price"], "Amount:", order["Amount"], "DealAmount:", order["DealAmount"], "AvgPrice:", order["AvgPrice"], "Status:", order["Status"], "Type:", order["Type"])
        money = order["Amount"] # 成交的money
        dealAmount = order["DealAmount"] # 已扣除手续费
        price = order["AvgPrice"] # 成交均价  
        remainCashMoney -= money
        inverstAssetAmount = inverstAssetAmount + dealAmount
        originalAssetMoney += money # 增加投资基准
        originalCashMoney += money # 增加投资基准
        Log(f"bull/bear add original invest at time {openTimeStr}")

    # 当remainCashMoney低于originalCashMoney的90%时，减少投资基准
    if remainCashMoney <= originalCashMoney * 0.9:
        money = (originalCashMoney - remainCashMoney) / 2 # 卖出金额
        amount = money / price
        id = exchange.Sell(-1, amount) # 市价单
        # Log("order id:", id)
        order = exchange.GetOrder(id)
        Log("sell money:", money)
        Log("sell amount:", amount)
        Log("order id:", order["Id"], "Price:", order["Price"], "Amount:", order["Amount"], "DealAmount:", order["DealAmount"], "AvgPrice:", order["AvgPrice"], "Status:", order["Status"], "Type:", order["Type"])
        amount = order["Amount"] # 计划卖出资产数量
        dealAmount = order["DealAmount"] # 成交资产数量，这里好像是从balance扣除的手续费吗?
        # 从日志来看amount == dealAmount,所以手续费是从balance扣除的
        price = order["AvgPrice"] # 成交均价
        dealMoney = dealAmount * price # 未扣除手续费
        dealMoney = dealAmount * price # 未扣除手续费
        remainCashMoney += dealMoney # 这里需要减去手续费
        inverstAssetAmount = inverstAssetAmount - dealAmount
        originalAssetMoney -= money # 减少投资基准
        originalCashMoney -= money # 减少投资基准
        Log(f"bull/bear reduce original invest at time {openTimeStr}")

    # tick计算
    i = i + 1

def main():
    Log(totalInvestment, buyRatio, sellRatio)

    while True:
        onTick()
        Sleep(1000) # 1秒

def onexit():
    global inverstAssetAmount

    # 清仓
    Log("清仓")
    if inverstAssetAmount > 0:
        amount = num_cut(inverstAssetAmount * (1-0.0001), 8) # 留0.01%一丢丢，小数位控制
        id = exchange.Sell(-1, amount) # 市价单
        Log("order id:", id)
        order = exchange.GetOrder(id)
        Log("order id:", order["Id"], "Price:", order["Price"], "Amount:", order["Amount"], "DealAmount:", order["DealAmount"], "AvgPrice:", order["AvgPrice"], "Status:", order["Status"], "Type:", order["Type"])        
    # 倒计时
    beginTime = time.time() * 1000
    while True:
        ts = time.time() * 1000
        Log("程序停止倒计时...，已经过去：", (ts - beginTime) / 1000, "秒！")
        Sleep(1000) # 1秒

---

• NTPCVerzögerung des UDP-Clients und des Exchange-Servers
• VWMA + SMA Bollinger Bands + RSI-Strategie: Analyse der Korrelation zwischen Preis und Volumen
• EMA200 und Stochastische RSI-Strategie
• Trade05-K-Leitung unterstützt Widerstand + ATR-Stopp
• Trade04- Doppel-Gleichlinie + ATR-Kanal + Hoch-Tiefpunkt
• Trade01 Hoch- und Tiefbahn + Mittelbahn
• Trade03- Doppel-Gleichlinie + Schwankungsrate
• Trade02-Aaron-Indikator + Ma-Strategie
• Ma-Kreuzung
• EMA-Cross-JC Intraday mit Trailing SL
• Die Handelsstrategie der Quantifizierung von Channon-Gitter
• Nachweisroboter V1.0 (eine gleiche Börse erforderlich, mehrere Benutzer können nachweisen, die Anzahl der Nachweise kann festgelegt werden)
• Die Strategie von Brin und Martinger
• JavaScript-Version zur Abfrage von K-Linien-Historischen Datentemplates (Lehre)
• OKX-Teiltransaktionsverpackungen
• Binance Teiltransaktionsverpackung Beispiel
• Intelligente Intervall-Doppel-Betting-Strategien (verkauft)
• Zufälliges Zählen
• Der Test von Martin Gill