From 9c9fe6075c0599d2f4b38a564ea4fa94266e94d3 Mon Sep 17 00:00:00 2001
From: luzhaofeng <574317128@qq.com>
Date: Fri, 22 Nov 2019 17:39:13 +0800
Subject: [PATCH] =?UTF-8?q?K=E7=BA=BF=E6=9C=BA=E5=99=A8=E4=BA=BA-=E4=BF=AE?=
 =?UTF-8?q?=E5=A4=8D=E7=94=9F=E6=88=90=E7=A9=BA=E7=9B=98=E5=8F=A3=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AEBUG?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../databot/schedule/KMarketScheduling.java   | 28 ++++++-------------
 1 file changed, 8 insertions(+), 20 deletions(-)

diff --git a/blockchain-server/blockchain-server-databot/src/main/java/com/blockchain/server/databot/schedule/KMarketScheduling.java b/blockchain-server/blockchain-server-databot/src/main/java/com/blockchain/server/databot/schedule/KMarketScheduling.java
index 48b2e09..0159563 100644
--- a/blockchain-server/blockchain-server-databot/src/main/java/com/blockchain/server/databot/schedule/KMarketScheduling.java
+++ b/blockchain-server/blockchain-server-databot/src/main/java/com/blockchain/server/databot/schedule/KMarketScheduling.java
@@ -214,6 +214,8 @@ public class KMarketScheduling {
         setDepthByPriceInRedis(config, CommonConstant.BUY, coinName, unitName);
         //设置卖盘数据
         setDepthByPriceInRedis(config, CommonConstant.SELL, coinName, unitName);
+        //发送推送前端请求
+        send(coinName, unitName);
     }
 
     /***
@@ -233,6 +235,8 @@ public class KMarketScheduling {
         setDepthByPercentInRedis(config, CommonConstant.BUY, coinName, unitName, nowPrice);
         //设置卖盘数据
         setDepthByPercentInRedis(config, CommonConstant.SELL, coinName, unitName, nowPrice);
+        //发送推送前端请求
+        send(coinName, unitName);
     }
 
     /***
@@ -282,16 +286,8 @@ public class KMarketScheduling {
                 newPrices.put(unitPrice, marketDTO);
             }
         }
-        if (newPrices.size() == 0) {
-            System.out.println("==========================出现0==============================");
-            System.out.println("配置：" + config.toString());
-            System.out.println("单价：" + newPrices);
-        } else {
-            //设置深度数据到缓存中
-            setDepthInRedis(newPrices, coinName, unitName, tradingType);
-            //发送推送前端请求
-            send(coinName, unitName);
-        }
+        //设置深度数据到缓存中
+        setDepthInRedis(newPrices, coinName, unitName, tradingType);
     }
 
     /***
@@ -353,16 +349,8 @@ public class KMarketScheduling {
             }
         }
 
-        if (newPrices.size() == 0) {
-            System.out.println("==========================出现0==============================");
-            System.out.println("配置：" + config.toString());
-            System.out.println("单价：" + nowPrice);
-        } else {
-            //设置深度数据到缓存中
-            setDepthInRedis(newPrices, coinName, unitName, tradingType);
-            //发送推送前端请求
-            send(coinName, unitName);
-        }
+        //设置深度数据到缓存中
+        setDepthInRedis(newPrices, coinName, unitName, tradingType);
     }
 
     /***