支持多个交易所, 多线程, 想学习多线程或者图表的可以学习下这个策略
function _D(t) { if (typeof(t) == 'undefined') { t = new Date(); } var year = t.getFullYear(); var month = t.getMonth() + 1; var day = t.getDate(); var hour = t.getHours(); var minute = t.getMinutes(); var second = t.getSeconds(); if (month < 10) { month = '0' + month; } if (day < 10) { day = '0' + day; } if (hour < 10) { hour = '0' + hour; } if (minute < 10) { minute = '0' + minute; } if (second < 10) { second = '0' + second; } return year + '-' + month + '-' + day + ' ' + hour + ':' + minute + ':' + second; } function ExchangeManager(e, idx) { var arr = []; this.Last = 0; this.e = e; this.idx = idx; this.Go = e.Go; this.GetName = e.GetName; this.GetLabel = e.GetLabel; this.health = 100; this.tickerChanged = false; this.init = function() { if (e.GetName() == "Futures_BitVC") { e.SetContractType("week"); } var ticker = e.GetTicker(); if (!ticker) { this.Last = 0; } else { this.Last = _N(ticker.Last, 3); } this.ticker = ticker; this.tickerChanged = true; }; this.updateHealth = function(ticker) { if (ticker) { this.tickerChanged = _N(ticker.Last, 3) != this.Last; this.Last = _N(ticker.Last, 3); this.ticker = ticker; } arr.push(ticker); if (arr.length > TickCount) { arr.shift(); } }; this.getHealth = function() { var ratio = 0; var n = Math.min(TickCount, arr.length); for (var i = n-1; i >=0; i--) { if (arr[i]) { ratio++; } } return parseFloat(((ratio * 100) / n).toFixed(3)); }; } function multiCall(tasks, callback, isRetry) { var ret = []; var n = 0; if (typeof(isRetry) == 'undefined') { isRetry = true; } var ts = new Date(); while (true) { var now = new Date(); if ((now.getTime() - ts.getTime()) > 1000) { ts = now; var waitNames = []; for (var i = 0; i < tasks.length; i++) { if (typeof(ret[i]) == 'undefined' || typeof(ret[i].wait) != "undefined") { waitNames.push(tasks[i][0].GetName() + "("+tasks[i].slice(1).join(",")+")"); } } if (waitNames.length > 0) { // add api status as extra LogStatus("等待: " + waitNames.join(", ") + " 当前时间:" + _D() + " 重试" + (isRetry ? "开启" : "关闭")); } } for (var i = 0; i < tasks.length; i++) { if (typeof(ret[i]) != 'undefined' && typeof(ret[i].wait) != "undefined") { var r = ret[i].wait(0); if (r) { ret[i] = r; n++; if (typeof(callback) != 'undefined') { callback(tasks[i], r); } } else if (typeof(r) != 'undefined') { if (isRetry) { // null retry delete ret[i]; } else { n++; // ignore ret[i] = true; if (typeof(callback) != 'undefined') { callback(tasks[i], r); } } } } if (typeof(ret[i]) == 'undefined') { ret[i] = tasks[i][0].Go.apply(this, tasks[i].slice(1)); } } if (n == tasks.length) { break; } Sleep(50); } return ret; } function EnsureCall(method) { var r; while (!(r = method.apply(this, Array.prototype.slice.call(arguments).slice(1)))) { Sleep(300); } return r; } function main() { var keys = []; var table = { type: 'table', title: '行情信息', cols: ['交易所', '买一', '卖一', '最后成交价', '最高', '最低', '交易量'], rows: [] }; var es = []; for (var i = 0; i < exchanges.length; i++) { var m = new ExchangeManager(exchanges[i], i); m.init(); es.push(m); keys.push(exchanges[i].GetLabel()); } var chart = Chart({ __isStock: false, chart: { type: 'column' }, title: { text: '交易所API可用率' }, subtitle: { text: '采样最近 ' + TickCount + ' 次, 每 ' + Interval +' 秒更新一次' }, xAxis: { categories: keys }, yAxis: [{ min: 0, max: 100, title: {text: '可用率'} },{ min: 1000, title: {text: '最后成交价'}, style: {color: '#4572A7'}, opposite: true } ], plotOptions: { column: { pointPadding: 0.2, borderWidth: 0 } }, series: [ { name: '可用率', data: [], tooltip: {valueSuffix: ' %'}, dataLabels: {color: '#000000', rotation: -35, enabled: true, x:2, y:50}}, { name: '成交价', color: '#bbbbbb', yAxis: 1, data: [], tooltip: {valueSuffix: ' 元'}, dataLabels: {color: '#000000', rotation: -35, enabled: true, x:2, y:120}} ] }); chart.reset(); // Initialize chart for (var i = 0; i < es.length; i++) { chart.add([0, 100]); chart.add([1, es[i].Last]); } Log("初始化成功."); Sleep(5000); while (true) { var tasks = []; for (var i = 0; i < es.length; i++) { tasks.push([es[i], "GetTicker"]); } multiCall(tasks, function(r, result) { r[0].updateHealth(result); }, false); for (var i = 0; i < es.length; i++) { var health = es[i].getHealth(); if (health != es[i].health) { chart.add([0, health, es[i].idx]); es[i].health = health; } if (es[i].tickerChanged) { chart.add([1, es[i].Last, es[i].idx]); } var ticker = es[i].ticker; if (ticker) { table.rows[i] = [es[i].GetLabel(), ticker.Buy, ticker.Sell, ticker.Last + '#ff0000', ticker.High, ticker.Low, ticker.Volume]; } } LogStatus('最后更新于: ' + _D() +'\n`' + JSON.stringify(table) + '`'); var cmd = GetCommand(); if (cmd && cmd.indexOf('清空日志') === 0) { LogReset(); Log("日志已重置"); } Sleep(Interval*1000); } }template: strategy.tpl:40:21: executing "strategy.tpl" at <.api.GetStrategyListByName>: wrong number of args for GetStrategyListByName: want 7 got 6