Commit 7867dff8 by rongjun

bug

parent 4af36107
...@@ -224,7 +224,6 @@ class BaseCollector { ...@@ -224,7 +224,6 @@ class BaseCollector {
runStrategy3(){ runStrategy3(){
console.log("启动成功"); console.log("启动成功");
this._fetchSymbols(this._handleFetchSymbolResult.bind(this));
setInterval(()=>{ setInterval(()=>{
redisClient.get(this.machine + "_STOP", (err, value) => { redisClient.get(this.machine + "_STOP", (err, value) => {
if (value) { if (value) {
...@@ -243,6 +242,8 @@ class BaseCollector { ...@@ -243,6 +242,8 @@ class BaseCollector {
} }
}); });
},this._runMonitorInterval()); },this._runMonitorInterval());
this._fetchSymbols(this._handleFetchSymbolResult.bind(this));
} }
runStrategy2(){ runStrategy2(){
......
...@@ -211,16 +211,17 @@ class BiboxCollector extends BaseCollector{ ...@@ -211,16 +211,17 @@ class BiboxCollector extends BaseCollector{
_getCoinsInfo(){ _getCoinsInfo(){
console.log('start get coin info...'); console.log('start get coin info...');
coinInfoMap = {}
this.api.coins_info((error,result)=>{ this.api.coins_info((error,result)=>{
if(error){ if(error){
console.error('get coins info error'); console.error('get coins info error');
this._getCoinsInfo(); this._getCoinsInfo();
}else { }else {
if(result.data){ if(result.data){
coinInfoMap = {}
for(let d of result.data){ for(let d of result.data){
coinInfoMap[d.coin] = d coinInfoMap[d.coin] = d
} }
console.log('get coin info ok');
} }
} }
}); });
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment