大宗交易修改

zyy

2025-07-15 dfd95b8354429de9b14087cb96cba0ba0cd7265a

 src/main/java/com/nq/ws/WebsocketRunClient.java

@@ -52,7 +52,10 @@
        heartbeatTimer.schedule(new TimerTask() {
            @Override
            public void run() {
                send(("key:"+ eStockType.getStockKey()+":"+eStockType.getContryId()).getBytes());
                if (isOpen()) {
                    send(("key:"+ eStockType.getStockKey()+":"+eStockType.getContryId()).getBytes());
                }

            }
        }, 0, 3000); // 每3秒发送一次心跳消息
    }
@@ -78,7 +81,6 @@
        RedisKeyUtil.setCacheRealTimeStock(EStockType.US,stockRealTimeBean);
        ObjectMapper objectMapper = new ObjectMapper();
        try {
            System.out.println("sdd");
            if(!stockRealTimeBean.getPcp().contains("-")){
                stockRealTimeBean.setPcp("+"+stringObjectMap.get("ChgPct").toString()+"%");
            }