| | |
| | | List<Item> itemsTotal; |
| | | List<Item> items = new ArrayList<>(); |
| | | //按字符串排序 |
| | | List<Item> itemList = itemService.cacheGetAll().stream().sorted(Comparator.comparing(Item::getSorted).reversed()).collect(Collectors.toList()); |
| | | List<Item> itemList = itemService.cacheGetAll().stream() |
| | | .sorted(Comparator.comparing( |
| | | item -> Integer.parseInt(item.getSorted()), |
| | | Comparator.reverseOrder() |
| | | )) |
| | | .collect(Collectors.toList()); |
| | | |
| | | //按数字排序 |
| | | // List<Item> itemList = itemService.cacheGetAll().stream().sorted(Comparator.comparing(Item::getSorted, (x,y)->{ |
| | | // int xInt = 0; |
| | |
| | | symbol = itemService.getSymbolByRemarks(symbol); |
| | | Integer decimal = itemService.getDecimal(symbol); |
| | | Item item = this.itemService.findBySymbol(symbol); |
| | | if (item == null) { |
| | | return; |
| | | } |
| | | //更新行情中的symbol [要不然后续取不到缓存] |
| | | realtime.setSymbol(item.getSymbol()); |
| | | |
| | |
| | | if (data.has("ch")) |
| | | tickerData.setChange(data.get("ch").asDouble()); |
| | | else |
| | | tickerData.setChange(cache.getIfPresent(proName).getChange()); |
| | | tickerData.setChange(cache.getIfPresent(proName).getChange() == null ? 0 : cache.getIfPresent(proName).getChange()); |
| | | |
| | | if (data.has("chp")) |
| | | tickerData.setChangePercent(data.get("chp").asDouble()); |
| | | else |
| | | tickerData.setChangePercent(cache.getIfPresent(proName).getChangePercent()); |
| | | tickerData.setChangePercent(cache.getIfPresent(proName).getChangePercent() == null ? 0 : cache.getIfPresent(proName).getChangePercent()); |
| | | |
| | | if (data.has("volume")) |
| | | tickerData.setVolume(data.get("volume").asLong()); |