1

zyy

4 days ago 3446c284c744bd6b1fb082a2a33aa263b2d475fe

 trading-order-huobi/src/main/java/com/yami/trading/huobi/jsws/WebsocketRunClient.java

@@ -88,7 +88,7 @@
                if (item == null || !item.getType().equalsIgnoreCase(Item.US_STOCKS)) {
                    return;
                }
                //System.out.println(s);
                System.out.println(s);
                StockWSBean stockRealTimeBean = new StockWSBean();
                stockRealTimeBean.setPid(stringObjectMap.get("Id"));
                stockRealTimeBean.setLast(stringObjectMap.get("Last"));
@@ -102,6 +102,11 @@
                stockRealTimeBean.setOpen(stringObjectMap.get("Open"));
                stockRealTimeBean.setPrevClose(stringObjectMap.get("PrevClose"));
                stockRealTimeBean.setSymbol(stringObjectMap.get("Symbol"));
                stockRealTimeBean.setVolume(stringObjectMap.get("Volume"));
                stockRealTimeBean.setPrevLast(stringObjectMap.get("PrevLast"));
                stockRealTimeBean.setPrevChg(stringObjectMap.get("PrevChg"));
                stockRealTimeBean.setPrevChgPct(stringObjectMap.get("PrevChgPct"));
                stockRealTimeBean.setPrevPrevClose(stringObjectMap.get("PrevPrevClose"));
                Realtime realtime = new Realtime();
                /*realtime.setUuid(stringObjectMap.get("pid"));
                realtime.setSymbol(stringObjectMap.get("symbol"));
@@ -127,7 +132,11 @@
                realtime.setChangeRatio(new BigDecimal(stringObjectMap.get("ChgPct")).doubleValue());
                realtime.setBid(new BigDecimal(stringObjectMap.get("Bid")).doubleValue());
                realtime.setAsk(new BigDecimal(stringObjectMap.get("Ask")).doubleValue());

                realtime.setVolume(new BigDecimal(stringObjectMap.get("Volume")).doubleValue());
                realtime.setPrevLast(new BigDecimal(stringObjectMap.get("PrevLast")).doubleValue());
                realtime.setPrevChg(new BigDecimal(stringObjectMap.get("PrevChg")).doubleValue());
                realtime.setPrevChgPct(new BigDecimal(stringObjectMap.get("PrevChgPct")).doubleValue());
                realtime.setPrevPrevClose(new BigDecimal(stringObjectMap.get("PrevPrevClose")).doubleValue());

                DataCache.putRealtime(realtime.getSymbol(), realtime);

@@ -136,7 +145,7 @@
                sendLoca(json);

            } catch (Exception e) {
                log.error("处理WebSocket消息时发生错误: {}", e);
                //log.error("处理WebSocket消息时发生错误: {}", e);
            }
        } else {
            log.info("WebSocket心跳或认证响应: {}", s);