K线机器人-修复生成空盘口数据BUG

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