数字货币现货多品种双均线策略（教学）
Author: 发明者量化-小小梦, Created: 2021-12-06 17:53:51, Updated: 2023-09-15 20:56:36
数字货币现货多品种双均线策略（教学）
应社区用户的要求，希望有一个多品种双均线策略做设计参考。那么本期就实现一个多品种的双均线策略。注释会写在策略代码上便于理解策略，方便学习。让更多的程序化、量化交易新同学快速入门。
策略思路
双均线策略逻辑很简单，即两条均线。一条参数周期小的均线（快线），一条参数周期大的均线（慢线）。两条线发生金叉（快线由下上穿慢线）做多买入，两条线发生死叉（快线由上下穿慢线）做空卖出。均线我们采用EMA均线。
只不过策略要设计为多品种，那么每个品种参数可能就不一样（不同品种用不同的均线参数），所以要一种“参数组”的方式设计参数。
参数设计成这种字符串形式，每个参数逗号间隔。在策略开始运行时，解析这些字符串。匹配给每个品种（交易对）的执行逻辑。策略轮询检测各个品种的行情、交易条件的触发、图表打印等。所有品种轮询一遍之后，汇总数据，在状态栏上显示表格信息。
策略设计十分简单，适合入门学习，总共只有200+行代码。
策略代码
// 函数作用：取消当前交易对的所有挂单
function cancelAll(e) {
while (true) {
var orders = _C(e.GetOrders)
if (orders.length == 0) {
break
} else {
for (var i = 0 ; i < orders.length ; i++) {
e.CancelOrder(orders[i].Id, orders[i])
Sleep(500)
}
}
Sleep(500)
}
}
// 函数作用：计算实时收益盈亏
function getProfit(account, initAccount, lastPrices) {
// account为当前账户信息，initAccount为初始账户信息，lastPrices为当前所有品种的最新价格
var sum = 0
_.each(account, function(val, key) {
// 遍历当前所有资产，计算除了USDT以外的资产币差，以及金额差
if (key != "USDT" && typeof(initAccount[key]) == "number" && lastPrices[key + "_USDT"]) {
sum += (account[key] - initAccount[key]) * lastPrices[key + "_USDT"]
}
})
// 返回根据当前价格计算得出的资产盈亏
return account["USDT"] - initAccount["USDT"] + sum
}
// 函数作用：生成图表配置
function createChartConfig(symbol, ema1Period, ema2Period) {
// symbol为交易对，ema1Period为第一根EMA均线周期，ema2Period为第二根EMA均线周期
var chart = {
__isStock: true,
extension: {
layout: 'single',
height: 600,
},
title : { text : symbol},
xAxis: { type: 'datetime'},
series : [
{
type: 'candlestick', // K线数据系列
name: symbol,
id: symbol,
data: []
}, {
type: 'line', // EMA数据系列
name: symbol + ',EMA1:' + ema1Period,
data: [],
}, {
type: 'line', // EMA数据系列
name: symbol + ',EMA2:' + ema2Period,
data: []
}
]
}
return chart
}
function main() {
// 重置所有数据
if (isReset) {
_G(null) // 清空所有持久化记录的数据
LogReset(1) // 清空所有日志
LogProfitReset() // 清空所有收益日志
LogVacuum() // 释放实盘数据库占用的资源
Log("重置所有数据", "#FF0000") // 打印信息
}
// 解析参数
var arrSymbols = symbols.split(",") // 逗号分割交易品种字符串
var arrEma1Periods = ema1Periods.split(",") // 分割第一根EMA均线的参数字符串
var arrEma2Periods = ema2Periods.split(",") // 分割第二根EMA均线的参数字符串
var arrAmounts = orderAmounts.split(",") // 分割每个品种的下单量
var account = {} // 用于记录当前资产信息的变量
var initAccount = {} // 用于记录最初资产信息的变量
var currTradeMsg = {} // 用于记录当前BAR是否交易的变量
var lastPrices = {} // 用于记录监控的品种最新价格的变量
var lastBarTime = {} // 用于记录最近一根BAR的时间的变量，用于画图时BAR的更新判断
var arrChartConfig = [] // 用于记录图表配置信息，用于画图
if (_G("currTradeMsg")) { // 例如重启时，恢复currTradeMsg数据
currTradeMsg = _G("currTradeMsg")
Log("恢复记录", currTradeMsg)
}
// 初始化account
_.each(arrSymbols, function(symbol, index) {
exchange.SetCurrency(symbol)
var arrCurrencyName = symbol.split("_")
var baseCurrency = arrCurrencyName[0]
var quoteCurrency = arrCurrencyName[1]
if (quoteCurrency != "USDT") {
throw "only support quoteCurrency: USDT"
}
if (!account[baseCurrency] || !account[quoteCurrency]) {
cancelAll(exchange)
var acc = _C(exchange.GetAccount)
account[baseCurrency] = acc.Stocks
account[quoteCurrency] = acc.Balance
}
// 初始化图表相关的数据
lastBarTime[symbol] = 0
arrChartConfig.push(createChartConfig(symbol, arrEma1Periods[index], arrEma2Periods[index]))
})
if (_G("initAccount")) {
initAccount = _G("initAccount")
Log("恢复初始账户记录", initAccount)
} else {
// 用当前资产信息，初始化initAccount变量
_.each(account, function(val, key) {
initAccount[key] = val
})
}
Log("account:", account, "initAccount:", initAccount) // 打印资产信息
// 初始化图表对象
var chart = Chart(arrChartConfig)
// 图表重置
chart.reset()
// 策略主循环逻辑
while (true) {
// 遍历所有品种，逐个执行双均线逻辑
_.each(arrSymbols, function(symbol, index) {
exchange.SetCurrency(symbol) // 切换交易对为symbol字符串记录的交易对
var arrCurrencyName = symbol.split("_") // 以“_”符号分割交易对
var baseCurrency = arrCurrencyName[0] // 交易币的字符串
var quoteCurrency = arrCurrencyName[1] // 计价币的字符串
// 根据index索引，获取当前交易对的EMA均线参数
var ema1Period = parseFloat(arrEma1Periods[index])
var ema2Period = parseFloat(arrEma2Periods[index])
var amount = parseFloat(arrAmounts[index])
// 获取当前交易对的K线数据
var r = exchange.GetRecords()
if (!r || r.length < Math.max(ema1Period, ema2Period)) { // K线长度不足时直接返回
Sleep(1000)
return
}
var currBarTime = r[r.length - 1].Time // 记录当前BAR时间戳
lastPrices[symbol] = r[r.length - 1].Close // 记录当前最新价格
var ema1 = TA.EMA(r, ema1Period) // 计算EMA指标
var ema2 = TA.EMA(r, ema2Period) // 计算EMA指标
if (ema1.length < 3 || ema2.length < 3) { // EMA指标数组长度过短，直接返回
Sleep(1000)
return
}
var ema1Last2 = ema1[ema1.length - 2] // 倒数第二BAR上的EMA
var ema1Last3 = ema1[ema1.length - 3] // 倒数第三BAR上的EMA
var ema2Last2 = ema2[ema2.length - 2]
var ema2Last3 = ema2[ema2.length - 3]
// 写入图表数据
var klineIndex = index + 2 * index
// 遍历K线数据
for (var i = 0 ; i < r.length ; i++) {
if (r[i].Time == lastBarTime[symbol]) { // 画图，更新当前BAR以及指标
// 更新
chart.add(klineIndex, [r[i].Time, r[i].Open, r[i].High, r[i].Low, r[i].Close], -1)
chart.add(klineIndex + 1, [r[i].Time, ema1[i]], -1)
chart.add(klineIndex + 2, [r[i].Time, ema2[i]], -1)
} else if (r[i].Time > lastBarTime[symbol]) { // 画图，添加BAR以及指标
// 添加
lastBarTime[symbol] = r[i].Time // 更新时间戳
chart.add(klineIndex, [r[i].Time, r[i].Open, r[i].High, r[i].Low, r[i].Close])
chart.add(klineIndex + 1, [r[i].Time, ema1[i]])
chart.add(klineIndex + 2, [r[i].Time, ema2[i]])
}
}
if (ema1Last3 < ema2Last3 && ema1Last2 > ema2Last2 && currTradeMsg[symbol] != currBarTime) {
// 金叉
var depth = exchange.GetDepth() // 获取当前订单薄深度数据
var price = depth.Asks[Math.min(takeLevel, depth.Asks.length)].Price // 取第10档价格，吃单
if (depth && price * amount <= account[quoteCurrency]) { // 获取深度数据正常，有足够资产下单
exchange.Buy(price, amount, ema1Last3, ema2Last3, ema1Last2, ema2Last2) // 下单买入
cancelAll(exchange) // 取消所有挂单
var acc = _C(exchange.GetAccount) // 获取账户资产信息
if (acc.Stocks != account[baseCurrency]) { // 检测账户资产发生变动
account[baseCurrency] = acc.Stocks // 更新资产
account[quoteCurrency] = acc.Balance // 更新资产
currTradeMsg[symbol] = currBarTime // 记录当前BAR已经交易
_G("currTradeMsg", currTradeMsg) // 持久化记录
var profit = getProfit(account, initAccount, lastPrices) // 计算收益
if (profit) {
LogProfit(profit, account, initAccount) // 打印收益
}
}
}
} else if (ema1Last3 > ema2Last3 && ema1Last2 < ema2Last2 && currTradeMsg[symbol] != currBarTime) {
// 死叉
var depth = exchange.GetDepth()
var price = depth.Bids[Math.min(takeLevel, depth.Bids.length)].Price
if (depth && amount <= account[baseCurrency]) {
exchange.Sell(price, amount, ema1Last3, ema2Last3, ema1Last2, ema2Last2)
cancelAll(exchange)
var acc = _C(exchange.GetAccount)
if (acc.Stocks != account[baseCurrency]) {
account[baseCurrency] = acc.Stocks
account[quoteCurrency] = acc.Balance
currTradeMsg[symbol] = currBarTime
_G("currTradeMsg", currTradeMsg)
var profit = getProfit(account, initAccount, lastPrices)
if (profit) {
LogProfit(profit, account, initAccount)
}
}
}
}
Sleep(1000)
})
// 状态栏表格变量
var tbl = {
type : "table",
title : "账户信息",
cols : [],
rows : []
}
// 将数据写入状态栏表格结构
tbl.cols.push("--")
tbl.rows.push(["初始"])
tbl.rows.push(["当前"])
_.each(account, function(val, key) {
if (typeof(initAccount[key]) == "number") {
tbl.cols.push(key)
tbl.rows[0].push(initAccount[key]) // 初始
tbl.rows[1].push(val) // 当前
}
})
// 显示状态栏表格
LogStatus(_D(), "\n", "profit:", getProfit(account, initAccount, lastPrices), "\n", "`" + JSON.stringify(tbl) + "`")
}
}
策略回测
可以看到ETH、LTC、ETC都根据均线金叉死叉触发，发生了交易。
也可以挂模拟盘测试。
策略源码：https://www.fmz.com/strategy/333783
策略仅仅用于回测测试，学习策略设计，实盘慎用。
Related
- Introduction to Lead-Lag Arbitrage in Cryptocurrency (2)
- 数字货币中的Lead-Lag套利介绍（2）
- Discussion on External Signal Reception of FMZ Platform: A Complete Solution for Receiving Signals with Built-in Http Service in Strategy
- FMZ平台外部信号接收的探讨：策略内置Http服务接收信号的完整方案
- Introduction to Lead-Lag Arbitrage in Cryptocurrency (1)
- 数字货币中的Lead-Lag套利介绍（1）
- Discussion on External Signal Reception of FMZ Platform: Extended API VS Strategy Built-in HTTP Service
- FMZ平台外部信号接收的探讨：扩展API vs 策略内置HTTP服务
- Discussion on Strategy Testing Method Based on Random Ticker Generator
- 基于随机行情生成器的策略测试方法探讨
- New Feature of FMZ Quant: Use _Serve Function to Create HTTP Services Easily
More
- 数字货币现货打新抢币策略（教学）
- Design a Multiple-Chart Plotting Library
- 设计一个多图表画线类库
- 60行代码实现一个思路--合约抄底策略
- 基于FMZ量化的订单同步管理系统设计（2）
- 基于FMZ量化的订单同步管理系统设计（1）
- 升级！数字货币期货类马丁策略
- 数字货币期货多品种ATR策略（教学）
- 2021年数字货币行情回顾与错过的最简单10倍策略
- Fisher指标的JavaScript语言实现以及在FMZ上画图
- 数字货币期货双均线拐点策略（教学）
- 资金费率策略近况和推荐操作
- 挂单期现对冲策略设计研究、范例
- FMZ平台Python爬虫应用初探--爬取币安公告内容
- dYdX策略设计范例--随机交易策略
- 发明者量化交易平台APP使用快速入门
- 币本位合约期现差价回归套利分析
- 发明者通用协议合约接入示例
- 数字货币手动期现对冲策略
- 研究平台进阶——Python进行数据分析和策略回测
Mr.Huang. 2
Mr.Huang. 2
Mr.Huang. 1
轻轻的云 谢谢梦大！！！
wanghehe711@qq.com 感谢 感谢！新手正在研究中~但是实盘测试报错 ：GetOrders: Invalid ContractType 这是托管的问题吗？
发明者量化-小小梦 不客气，感谢支持。
发明者量化-小小梦 思路差不多，这个是个策略例子，具体可以看代码学习。
wanghehe711@qq.com 在这个基础上能改成永续期货合约吗 ？ 难度大吗 如果可以的话 我试着改一改
发明者量化-小小梦 这是现货策略， 不是期货的。