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); + } } /***