添加如果有version就用version来判断数据新旧

api_kucoin.js

@@ -101,7 +101,7 @@ class biboxApi {
         console.log("fetch ws token error");
         this.subscribeSymbols(symbols, depth, callback);
       }else{
-        // for(let i=0;i<3;i++){
+        // for(let i=0;i<2;i++){
           const ip = IPs[0];
           // setTimeout(()=>{
             this._openWs(result, symbols, depth,ip, callback);
@@ -147,7 +147,7 @@ class biboxApi {
         }
         totalOrderbook[symbol].bids = bids;
         totalOrderbook[symbol].asks = asks;
-        const ret = {data: {SELL: asks, BUY: bids}, timestamp: timeStamp, symbol: symbol}
+        const ret = {data: {SELL: asks, BUY: bids}, timestamp: timeStamp, symbol: symbol,seq:response.seq};
         callback(null, ret);
       }
         // else {

baseCollector.js

@@ -25,13 +25,18 @@ class BaseCollector {
    * @param timeStamp 从服务器获取的数据的时间戳
    * @private
    */
-  _publishDataForStrategy3(asks, bids, symbol, timeStamp) {
+  _publishDataForStrategy3(asks, bids, symbol, timeStamp,version) {
     if(!asks.length || !bids.length){
       return;
     }
     const realSymbol = this._convertSymbolName(symbol);
     const lastEventTime = this.getSymbolEventTime(realSymbol);
-    if(lastEventTime >= timeStamp){
+    const lastVersion = this._getLastDataVersion(realSymbol);
+    if(lastVersion >0 && version){
+      if(lastVersion >= version){
+        return;
+      }
+    } else if(lastEventTime >= timeStamp){
       return;
     }
 
@@ -44,6 +49,7 @@ class BaseCollector {
       symbol: realSymbol,
       asks: asks,
       bids: bids,
+      version:version,
     }
     if(parseFloat(data.bestBid) > parseFloat(data.bestAsk)){
       // console.error("同一交易对，卖价低于买价，可能数据有误:"+realSymbol);
@@ -149,6 +155,14 @@ class BaseCollector {
     }
     return 0;
   }
+  _getLastDataVersion(symbol){
+    const keySymbol = this._convertSymbolName(symbol);
+    let lastData = lastDataMap[keySymbol];
+    if(lastData){
+      return lastData['version'] || -1;
+    }
+    return -1;
+  }
 
   isBaseCurrency(currency) {
     return this.baseCurrencies.includes(currency);

kucoinCollector.js

@@ -92,7 +92,7 @@ class BiboxCollector extends BaseCollector{
         const data = result.data;
         const timeStamp = result.timestamp;
         const symbol = result.symbol;
-        callback(data.SELL.slice(0, depth), data.BUY.slice(0, depth), symbol, timeStamp);
+        callback(data.SELL.slice(0, depth), data.BUY.slice(0, depth), symbol, timeStamp,result.seq);
       }
     })
   }

package.json

@@ -6,7 +6,7 @@
   "scripts": {
     "strategy2": "node $NODE_DEBUG_OPTION strategy2.js",
     "test": "export MACHINE=K; export http_proxy='http://localhost:8118';export https_proxy='http://localhost:8118';export agent='socks:127.0.0.1:1086';node $NODE_DEBUG_OPTION test_kucoin.js",
-    "strategy3": "export http_proxy='http://localhost:8118';export https_proxy='http://localhost:8118';export agent='socks:127.0.0.1:1086';node $NODE_DEBUG_OPTION kucoinStrategy3.js"
+    "strategy3": "export MACHINE=K;export http_proxy='http://localhost:8118';export https_proxy='http://localhost:8118';export agent='socks:127.0.0.1:1086';node $NODE_DEBUG_OPTION kucoinStrategy3.js"
   },
   "author": "",
   "license": "ISC",