یہ ایک سے زیادہ تبادلے کی حمایت کرتا ہے، ایک سے زیادہ موضوعات، اور اگر آپ کو ایک سے زیادہ موضوعات یا چارٹ سیکھنے کے لئے چاہتے ہیں، تو آپ کو اس حکمت عملی کو سیکھنے کے لئے ہے.
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);
}
}