bug

api_kucoin.js

@@ -103,13 +103,14 @@ class biboxApi {
       } else {
         try {
           const result = JSON.parse(body);
-          if (result.success && result.code === 'OK') {
+          if (result.success) {
             callback(null, result);
           } else {
             callback(result, null);
           }
         } catch (e) {
-          console.log(e);
+          console.error(e);
+          console.error(body);
           callback({statusCode:response.statusCode}, null);
         }
       }

baseCollector.js

@@ -225,24 +225,24 @@ class BaseCollector {
   runStrategy3(){
     console.log("启动成功");
     this._fetchSymbols(this._handleFetchSymbolResult.bind(this));
-    // setInterval(()=>{
-    //   redisClient.get(this.machine + "_STOP", (err, value) => {
-    //     if (value) {
-    //       this.allowTrade = false;
-    //       console.log("滑点过多，停止交易");
-    //     } else {
-    //       this.allowTrade = true;
-    //     }
-    //   });
-    // },1000 *10);
-    // setInterval(()=>{
-    //   this._runMonitor((data)=>{
-    //     if(data){
-    //       this.balanceMap = {...data};
-    //       redisClient.set(this.machine,JSON.stringify(this.balanceMap),"EX",30);
-    //     }
-    //   });
-    // },this._runMonitorInterval());
+    setInterval(()=>{
+      redisClient.get(this.machine + "_STOP", (err, value) => {
+        if (value) {
+          this.allowTrade = false;
+          console.log("滑点过多，停止交易");
+        } else {
+          this.allowTrade = true;
+        }
+      });
+    },1000 *10);
+    setInterval(()=>{
+      this._runMonitor((data)=>{
+        if(data){
+          this.balanceMap = {...data};
+          redisClient.set(this.machine,JSON.stringify(this.balanceMap),"EX",30);
+        }
+      });
+    },this._runMonitorInterval());
   }
 
   runStrategy2(){

kucoinCollector.js

@@ -147,8 +147,8 @@ class BiboxCollector extends BaseCollector{
     //有可能会由于数值过小，传进来的amount被表示为科学计数法法
     const amountStr = parseFloat(amount).toFixed(10);
     const nums = amountStr.split('.');
-    if(nums.length ===2 && nums[1].length>8){
-      return nums[0]+"."+nums[1].slice(0,8);
+    if(nums.length ===2 && nums[1].length>4){
+      return nums[0]+"."+nums[1].slice(0,4);
     }
     return amount;
   }