|
|
|
@ -282,13 +282,17 @@ 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); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
/*** |
|
|
|
|
* 封装涨跌幅生成的深度图设值进缓存中 |
|
|
|
@ -349,12 +353,17 @@ 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); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
/*** |
|
|
|
|
* 设置深度数据到缓存中 |
|
|
|
|