演示站

zj

2025-11-05 9c6296d07a668b15b9794709172e28ce3d9603e2

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

@@ -43,7 +43,7 @@

    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
@@ -74,7 +74,11 @@
            stockRealTimeBean.setPc(stringObjectMap.get("Chg").toString());
            stockRealTimeBean.setPcp(stringObjectMap.get("ChgPct").toString()+"%");
            stockRealTimeBean.setTime(stringObjectMap.get("Time").toString());
            RedisKeyUtil.setCacheRealTimeStock(EStockType.IN,stockRealTimeBean);
            stockRealTimeBean.setOpen(stringObjectMap.get("Open"));
            stockRealTimeBean.setPrevClose(stringObjectMap.get("PrevClose"));
            stockRealTimeBean.setSymbol(stringObjectMap.get("Symbol"));

            RedisKeyUtil.setCacheRealTimeStock(EStockType.US,stockRealTimeBean);
            ObjectMapper objectMapper = new ObjectMapper();
            try {
                if(!stockRealTimeBean.getPcp().contains("-")){
@@ -83,7 +87,7 @@
                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);
            }
@@ -128,4 +132,4 @@
            log.error("Http 请求错误", e);
        }
    }
}
}