|
@@ -852,11 +852,23 @@ public class CoinServiceImpl implements CoinService {
|
|
|
int MAX_NUMBER = 100;
|
|
int MAX_NUMBER = 100;
|
|
|
Stream.iterate(0, n -> n + 1).limit((watchlistList.size() + MAX_NUMBER - 1) / MAX_NUMBER)
|
|
Stream.iterate(0, n -> n + 1).limit((watchlistList.size() + MAX_NUMBER - 1) / MAX_NUMBER)
|
|
|
.forEach(i -> {
|
|
.forEach(i -> {
|
|
|
|
|
+ try {
|
|
|
|
|
+ Thread.sleep(2000L);
|
|
|
|
|
+ } catch (InterruptedException e) {
|
|
|
|
|
+ throw new RuntimeException(e);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
Map<String, CoinWatchlist> coinWatchlistMap4CoingeckoId = watchlistList.stream().skip((long) i * MAX_NUMBER).limit(MAX_NUMBER).collect(Collectors.toMap(CoinWatchlist::getCoingeckoId, coinWatchlist -> coinWatchlist));
|
|
Map<String, CoinWatchlist> coinWatchlistMap4CoingeckoId = watchlistList.stream().skip((long) i * MAX_NUMBER).limit(MAX_NUMBER).collect(Collectors.toMap(CoinWatchlist::getCoingeckoId, coinWatchlist -> coinWatchlist));
|
|
|
parseWatchlistMap4Coingecko(coinWatchlistMap4CoingeckoId);
|
|
parseWatchlistMap4Coingecko(coinWatchlistMap4CoingeckoId);
|
|
|
});
|
|
});
|
|
|
Stream.iterate(0, n -> n + 1).limit((watchlistList.size() + MAX_NUMBER - 1) / MAX_NUMBER)
|
|
Stream.iterate(0, n -> n + 1).limit((watchlistList.size() + MAX_NUMBER - 1) / MAX_NUMBER)
|
|
|
.forEach(i -> {
|
|
.forEach(i -> {
|
|
|
|
|
+ try {
|
|
|
|
|
+ Thread.sleep(2000L);
|
|
|
|
|
+ } catch (InterruptedException e) {
|
|
|
|
|
+ throw new RuntimeException(e);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
Map<Long, CoinWatchlist> coinWatchlistMap4CmcId = watchlistList.stream().skip((long) i * MAX_NUMBER).limit(MAX_NUMBER).collect(Collectors.toMap(CoinWatchlist::getCmcId, coinWatchlist -> coinWatchlist));
|
|
Map<Long, CoinWatchlist> coinWatchlistMap4CmcId = watchlistList.stream().skip((long) i * MAX_NUMBER).limit(MAX_NUMBER).collect(Collectors.toMap(CoinWatchlist::getCmcId, coinWatchlist -> coinWatchlist));
|
|
|
parseWatchlistMap4CmC(coinWatchlistMap4CmcId);
|
|
parseWatchlistMap4CmC(coinWatchlistMap4CmcId);
|
|
|
});
|
|
});
|
|
@@ -1342,6 +1354,11 @@ public class CoinServiceImpl implements CoinService {
|
|
|
return coinTraderPageInfo;
|
|
return coinTraderPageInfo;
|
|
|
} else if (params.getString("nameEn").equals("watchlist")) {
|
|
} else if (params.getString("nameEn").equals("watchlist")) {
|
|
|
PageHelper.startPage(params.getInteger("pageNo"), params.getInteger("pageSize"), true);
|
|
PageHelper.startPage(params.getInteger("pageNo"), params.getInteger("pageSize"), true);
|
|
|
|
|
+
|
|
|
|
|
+ if (params.containsKey("sortField")) {
|
|
|
|
|
+ params.put("sortField", Arrays.asList(params.getString("sortField").split(",")));
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
List<CoinWatchlist> watchlistList = coinMapper.findWatchlistList(params.toJavaObject(Map.class));
|
|
List<CoinWatchlist> watchlistList = coinMapper.findWatchlistList(params.toJavaObject(Map.class));
|
|
|
|
|
|
|
|
PageInfo<CoinWatchlist> watchlistPageInfo = new PageInfo<>(watchlistList);
|
|
PageInfo<CoinWatchlist> watchlistPageInfo = new PageInfo<>(watchlistList);
|