35ececb0d9959e010f1ac160f20afd4dba27de57..9d9a1e55b5020d774db213cb8d60479be2b1fbdd
2026-03-16 zyy
1
9d9a1e diff | tree
2026-03-16 zyy
1
7ff42a diff | tree
3 files modified
15 ■■■■ changed files
trading-order-admin/src/main/java/com/yami/trading/api/controller/RealtimeController.java 8 ●●●● patch | view | raw | blame | history
trading-order-huobi/src/main/java/com/yami/trading/huobi/data/NezhaHandleRealTime.java 3 ●●●●● patch | view | raw | blame | history
trading-order-huobi/src/main/java/com/yami/trading/huobi/tradingview/api/TradingViewAPI.java 4 ●●●● patch | view | raw | blame | history
trading-order-admin/src/main/java/com/yami/trading/api/controller/RealtimeController.java
@@ -287,7 +287,13 @@
            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;
trading-order-huobi/src/main/java/com/yami/trading/huobi/data/NezhaHandleRealTime.java
@@ -166,6 +166,9 @@
            symbol =  itemService.getSymbolByRemarks(symbol);
            Integer decimal = itemService.getDecimal(symbol);
            Item item = this.itemService.findBySymbol(symbol);
            if (item == null) {
                return;
            }
            //更新行情中的symbol [要不然后续取不到缓存]
            realtime.setSymbol(item.getSymbol());
trading-order-huobi/src/main/java/com/yami/trading/huobi/tradingview/api/TradingViewAPI.java
@@ -232,12 +232,12 @@
        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());