From 0daa620a2bd6cbfb3f5ce810f1330404340938eb Mon Sep 17 00:00:00 2001
From: luzhaofeng <574317128@qq.com>
Date: Fri, 22 Nov 2019 16:31:07 +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=E4=BA=A7=E7=94=9F=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   | 31 ++++++++++++-------
 1 file changed, 20 insertions(+), 11 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 09ff3a1..48b2e09 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
@@ -282,12 +282,16 @@ public class KMarketScheduling {
                 newPrices.put(unitPrice, marketDTO);
             }
         }
-
-        //设置深度数据到缓存中
-        setDepthInRedis(newPrices, coinName, unitName, tradingType);
-
-        //发送推送前端请求
-        send(coinName, unitName);
+        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);
+        }
     }
 
     /***
@@ -349,11 +353,16 @@ public class KMarketScheduling {
             }
         }
 
-        //设置深度数据到缓存中
-        setDepthInRedis(newPrices, coinName, unitName, tradingType);
-
-        //发送推送前端请求
-        send(coinName, unitName);
+        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);
+        }
     }
 
     /***