周收益、代理后台入金 充值

peter

2025-10-30 854aa5b79d3906b335524f09581f3a567a7bad49

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

@@ -43,12 +43,21 @@
//
//    private static HttpPost httpPost;
//    static {
//        httpPost = new HttpPost("http://127.0.0.1:8001/api/sendNotification"); // 初始化 HttpPost
//        httpPost = new HttpPost("http://127.0.0.1:8008/api/sendNotification"); // 初始化 HttpPost
//    }
//
//    @Override
//    public void onOpen(ServerHandshake serverHandshake) {
//        send(("key:"+ eStockType.getStockKey()+":"+eStockType.getContryId()).getBytes());
//        Timer heartbeatTimer;
//        // 启动心跳定时器
//        heartbeatTimer = new Timer();
//        heartbeatTimer.schedule(new TimerTask() {
//            @Override
//            public void run() {
//                send(("key:"+ eStockType.getStockKey()+":"+eStockType.getContryId()).getBytes());
//            }
//        }, 0, 3000); // 每3秒发送一次心跳消息
//    }
//
//    @Override
@@ -65,7 +74,7 @@
//            stockRealTimeBean.setPc(stringObjectMap.get("Chg").toString());
//            stockRealTimeBean.setPcp(stringObjectMap.get("ChgPct").toString()+"%");
//            stockRealTimeBean.setTime(stringObjectMap.get("Time").toString());
//            RedisKeyUtil.setCacheRealTimeStock(EStockType.IN,stockRealTimeBean);
//            RedisKeyUtil.setCacheRealTimeStock(EStockType.US,stockRealTimeBean);
//            ObjectMapper objectMapper = new ObjectMapper();
//            try {
//                if(!stockRealTimeBean.getPcp().contains("-")){
@@ -74,11 +83,13 @@
//                String json = objectMapper.writeValueAsString(stockRealTimeBean);
//                sendLoca(json);
//                StockRealTimeBean stockDetailBean =  new Gson().fromJson(s, StockRealTimeBean.class);
//                RedisKeyUtil.setCacheRealTimeStock(EStockType.IN,stockDetailBean);
//                RedisKeyUtil.setCacheRealTimeStock(EStockType.US,stockDetailBean);
//            } catch (JsonProcessingException e) {
//                throw new RuntimeException(e);
//            }
//
//        }else{
//            log.error("websocket  消息错误："+s);
//        }
//    }
//