Design de um sistema de gerenciamento de pedidos sincronizados baseado no FMZ

Design de um sistema de gerenciamento de pedidos sincronizados baseado no FMZ

Sistema de gestão de pedidos sincronizados (Synchronous Server)

Continuamos com o artigo anterior:Design de um sistema de gerenciamento de pedidos sincronizados baseado em FMZA discussão começou com a elaboração de uma estratégia para a sincronização das listas.

Considerem algumas questões de design:

• 1, se você não quiser sincronizar a lista temporariamente, você pode pausar. Uma vez que a pausa é proibida de iniciar a partir da API de extensão, o uso de autenticação de senha. Para implementar esta função, são adicionadas duas variáveis globais:

  var isStopFollow = false   // 用于标记当前是否跟单
  var reStartPwd = null      // 用于记录重启密码
  

  

  Em seguida, na página de edição da política, adicione um controle interativo para pausar/reiniciar a política (não para esta unidade, apenas pausa lógica, não segue a lista, não faz nada).订单同步管理系统类库（Single Server）O disco rígido também não consegue acordar sua política. Ao reiniciar o menu, digite o password predefinido para acordar a função de seguimento. Código de implementação para funções relacionadas:

  ...
            // 判断交互指令
            if (arr.length == 2) {
            	// 带控件的按钮
            	if (arr[0] == "stop/restart") {
            		// 暂停/重启跟单
            		if (!isStopFollow) {
            		    isStopFollow = true
            		    reStartPwd = arr[1]
            		    Log("已经停止跟单，", "设置的重启密码为：", reStartPwd, "#FF0000")
            		} else if (isStopFollow && arr[1] == reStartPwd) {
            			isStopFollow = false 
            			reStartPwd = null 
            			Log("已经重启跟单，", "清空重启密码。", "#FF0000")
            		} else if (isStopFollow && arr[1] != reStartPwd) {
            			Log("重启密码错误！")
            		}
            	}
            	continue 
            }
  

• 2, pode especificar a quantidade de unidades da lista ou pode ser multiplicado em escala Adicionar parâmetros à política:

  

  specifiedAmount: especifica o número de contas, por defeito -1, ou seja, não especifica. zoomAmountRatio: A escalação do volume inferior do sinal enviado, por exemplo:ETH_USDT,swap,buy,1, multiplicando o valor da menor unidade por zoomAmountRatio. O padrão é -1, ou seja, não escalar.

      var amount = specifiedAmount == -1 ? action.amount : specifiedAmount
      amount = zoomAmountRatio == -1 ? amount : amount * zoomAmountRatio
  

  Aqui, a quantidade de sinal recebido é reduzida para a quantidade necessária.A escalaçãoOuEspecificar valores específicos。

• O código deve ser o mais simples possível e o processamento deve ser feito usando outras bibliotecas de modelos.

  A lista de usuários de subscrições de cartão de crédito:https://www.fmz.com/strategy/10989A lista de classes de futuros que são usados:https://www.fmz.com/strategy/203258

    function trade(action) {
        // 切换交易对，设置合约
        exchange.SetCurrency(action.symbol)
        if (action.ct != "spot") {
            exchange.SetContractType(action.ct)        
        }        
  
        var retTrade = null 
        var amount = specifiedAmount == -1 ? action.amount : specifiedAmount
        amount = zoomAmountRatio == -1 ? amount : amount * zoomAmountRatio    
  
        if (action.direction == "buy") {
            retTrade = action.ct == "spot" ? $.Buy(amount) : $.OpenLong(exchange, action.ct, amount)
        } else if (action.direction == "sell") {
            retTrade = action.ct == "spot" ? $.Sell(amount) : $.OpenShort(exchange, action.ct, amount)
        } else if (action.direction == "closebuy") {
            retTrade = action.ct == "spot" ? $.Sell(amount) : $.CoverLong(exchange, action.ct, amount)
        } else if (action.direction == "closesell") {
            retTrade = action.ct == "spot" ? $.Buy(amount) : $.CoverShort(exchange, action.ct, amount)
        }
        return retTrade
    }
  

  O que você vê aqui é que a lista só precisa de uma frase:$.Sell(amount) 、$.Buy(amount) 、 $.OpenLong(exchange, action.ct, amount)... e assim por diante.

O código da estratégia:

Anterior订单同步管理系统（Synchronous Server）O código provisório é o seguinte:

Agora, comece a redesenhar.订单同步管理系统（Synchronous Server）：

// 全局变量
var isStopFollow = false
var reStartPwd = null 

function trade(action) {
    // 切换交易对，设置合约
    exchange.SetCurrency(action.symbol)
    if (action.ct != "spot") {
        exchange.SetContractType(action.ct)        
    }    

    var retTrade = null 
    var amount = specifiedAmount == -1 ? action.amount : specifiedAmount
    amount = zoomAmountRatio == -1 ? amount : amount * zoomAmountRatio

    if (action.direction == "buy") {
        retTrade = action.ct == "spot" ? $.Buy(amount) : $.OpenLong(exchange, action.ct, amount)
    } else if (action.direction == "sell") {
    	retTrade = action.ct == "spot" ? $.Sell(amount) : $.OpenShort(exchange, action.ct, amount)
    } else if (action.direction == "closebuy") {
    	retTrade = action.ct == "spot" ? $.Sell(amount) : $.CoverLong(exchange, action.ct, amount)
    } else if (action.direction == "closesell") {
    	retTrade = action.ct == "spot" ? $.Buy(amount) : $.CoverShort(exchange, action.ct, amount)
    }
    return retTrade
}

function parseCmd(cmd) {
	var objAction = {}
	// 解析cmd ，例如：ETH_USDT,swap,buy,1
    var arr = cmd.split(",")
    if (arr.length != 4) {
    	return null 
    }
    objAction.symbol = arr[0]
    objAction.ct = arr[1]
    objAction.direction = arr[2]
    objAction.amount = arr[3]
    return objAction
}

function main() {
	// 清除所有日志
    LogReset(1)  

    if (isSimulateOKEX) {
    	exchange.IO("simulate", true)
    	Log("切换到OKEX模拟盘！")
    }

    // 设置精度
    exchange.SetPrecision(pricePrecision, amountPrecision)

    // 检查缩放、指定不能同时设置
    if (specifiedAmount != -1 && zoomAmountRatio != -1) {
    	throw "不能同时指定同步量和缩放量"
    }

    while (true) {
        var cmd = GetCommand()
        if (cmd) {
            Log("cmd: ", cmd)
            var arr = cmd.split(":")

            // 判断交互指令
            if (arr.length == 2) {
            	// 带控件的按钮
            	if (arr[0] == "stop/restart") {
            		// 暂停/重启跟单
            		if (!isStopFollow) {
            		    isStopFollow = true
            		    reStartPwd = arr[1]
            		    Log("已经停止跟单，", "设置的重启密码为：", reStartPwd, "#FF0000")
            		} else if (isStopFollow && arr[1] == reStartPwd) {
            			isStopFollow = false 
            			reStartPwd = null 
            			Log("已经重启跟单，", "清空重启密码。", "#FF0000")
            		} else if (isStopFollow && arr[1] != reStartPwd) {
            			Log("重启密码错误！")
            		}
            	}
            	continue 
            }
            
            // 允许跟单
            if (!isStopFollow) {
                // 解析跟单信号交互指令
                var objAction = parseCmd(cmd)
                if (objAction) {
            	    // 解析正确
            	    var ret = trade(objAction)
                } else {
                	Log("错误的信号指令 cmd:", cmd)
                }
            }
        }
        
        // 显示跟单情况
        LogStatus(_D(), isStopFollow ? "停止同步" : "保持同步", "\n")

        Sleep(1000)
    }
}

Testes

Esta vez, a conta de faixa é testada no disco Binance, e a conta de faixa é testada no disco OKEX.订单同步管理系统类库（Single Server）Em um modelomainFunções) ⋅

Mas nós mudamos a direção do negócio para zero, e o volume do negócio é 0.003 ((Binance USDT em local pode fazer uma quantidade decimal de transações) ‒ Mas a conta da conta OKEX deve ser inteira (a conta da troca OKEX deve ser inteira), então o parâmetro é que eu especifico o parâmetro da estratégia.specifiedAmountÉ igual a 1⁄4.

订单同步管理系统类库（Single Server）A função de teste do disco real desencadeia a transação.

A estratégia do disco real recebe um sinal e executa a ação do disco:

A troca foi feita através de uma ordem correspondente.

Em seguida, teste o equilíbrio, alterando a direção da linha inferior da função principal do teste para o equilíbrio da posição vazia 0.003.

O disco rígido que é responsável pela faixa é novamente executado.订单同步管理系统类库（Single Server））。

O mesmo foi feito com o disco rígido:

A estratégia é endereçada:Sistema de gestão de sincronização de pedidos (Single Server) Sistema de gestão de pedidos sincronizados (Synchronous Server)

O design estratégico é apenas para a aprendizagem de intercâmbio, a produção real precisa ser modificada, ajustada e otimizada por si mesma.