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