|
|
@@ -849,11 +849,17 @@ public class CoinServiceImpl implements CoinService {
|
|
|
params.put("sort", "desc");
|
|
|
List<CoinWatchlist> watchlistList = coinMapper.findWatchlistList(params);
|
|
|
|
|
|
- Map<String, CoinWatchlist> coinWatchlistMap4CoingeckoId = watchlistList.stream().collect(Collectors.toMap(CoinWatchlist::getCoingeckoId, coinWatchlist -> coinWatchlist));
|
|
|
- parseWatchlistMap4Coingecko(coinWatchlistMap4CoingeckoId);
|
|
|
-
|
|
|
- Map<Long, CoinWatchlist> coinWatchlistMap4CmcId = coinWatchlistMap4CoingeckoId.values().stream().collect(Collectors.toMap(CoinWatchlist::getCmcId, coinWatchlist -> coinWatchlist));
|
|
|
- parseWatchlistMap4CmC(coinWatchlistMap4CmcId);
|
|
|
+ int MAX_NUMBER = 100;
|
|
|
+ Stream.iterate(0, n -> n + 1).limit((watchlistList.size() + MAX_NUMBER - 1) / MAX_NUMBER)
|
|
|
+ .forEach(i -> {
|
|
|
+ Map<String, CoinWatchlist> coinWatchlistMap4CoingeckoId = watchlistList.stream().skip((long) i * MAX_NUMBER).limit(MAX_NUMBER).collect(Collectors.toMap(CoinWatchlist::getCoingeckoId, coinWatchlist -> coinWatchlist));
|
|
|
+ parseWatchlistMap4Coingecko(coinWatchlistMap4CoingeckoId);
|
|
|
+ });
|
|
|
+ Stream.iterate(0, n -> n + 1).limit((watchlistList.size() + MAX_NUMBER - 1) / MAX_NUMBER)
|
|
|
+ .forEach(i -> {
|
|
|
+ Map<Long, CoinWatchlist> coinWatchlistMap4CmcId = watchlistList.stream().skip((long) i * MAX_NUMBER).limit(MAX_NUMBER).collect(Collectors.toMap(CoinWatchlist::getCmcId, coinWatchlist -> coinWatchlist));
|
|
|
+ parseWatchlistMap4CmC(coinWatchlistMap4CmcId);
|
|
|
+ });
|
|
|
}, 0, 1, TimeUnit.HOURS);
|
|
|
|
|
|
// Upbit交易所监控报警
|