From 640ccb9229224642515527daf87f308a7aa9bdf4 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Wed, 10 Jun 2026 11:47:26 +0800
Subject: [PATCH] 1
---
trading-order-admin/src/main/java/com/yami/trading/admin/task/RealtimeWebsocketServer.java | 211 ++++++++++++++++++++++++++--------------------------
1 files changed, 107 insertions(+), 104 deletions(-)
diff --git a/trading-order-admin/src/main/java/com/yami/trading/admin/task/RealtimeWebsocketServer.java b/trading-order-admin/src/main/java/com/yami/trading/admin/task/RealtimeWebsocketServer.java
index 8e798ce..f7b8e00 100644
--- a/trading-order-admin/src/main/java/com/yami/trading/admin/task/RealtimeWebsocketServer.java
+++ b/trading-order-admin/src/main/java/com/yami/trading/admin/task/RealtimeWebsocketServer.java
@@ -30,32 +30,32 @@
import java.util.stream.Collectors;
/**
- *
+ *
* 深度、近期交易记录 websocket启动服务
*/
@Component
public class RealtimeWebsocketServer {
- @Autowired
- ItemService itemService;
- @Autowired
- HobiDataService hobiDataService;
+ @Autowired
+ ItemService itemService;
+ @Autowired
+ HobiDataService hobiDataService;
- public static Map<String, Long> map = new HashMap();
+ public static Map<String, Long> map = new HashMap();
- public void start() {
- List<Item> itemList = itemService.cacheGetAll().stream().filter(i -> i.getType().equalsIgnoreCase(Item.cryptos)).collect(Collectors.toList());
+ public void start() {
+ List<Item> itemList = itemService.cacheGetAll().stream().filter(i -> i.getType().equalsIgnoreCase(Item.cryptos)).collect(Collectors.toList());
- MarketClient tickerClient = MarketClient.create(new HuobiOptions());
- for (Item item : itemList) {
- String symbol = item.getSymbol();
- SubMarketTickerRequest tickerReq = new SubMarketTickerRequest();
- tickerReq.setSymbol(symbol);
- tickerClient.subMarketTicker(tickerReq, (marketTradeEvent) -> {
- // System.out.println(JSONObject.toJSONString(marketTradeEvent));
- ticker(marketTradeEvent, symbol);
- });
- }
+ MarketClient tickerClient = MarketClient.create(new HuobiOptions());
+ for (Item item : itemList) {
+ String symbol = item.getSymbol();
+ SubMarketTickerRequest tickerReq = new SubMarketTickerRequest();
+ tickerReq.setSymbol(symbol);
+ tickerClient.subMarketTicker(tickerReq, (marketTradeEvent) -> {
+ // System.out.println(JSONObject.toJSONString(marketTradeEvent));
+ ticker(marketTradeEvent, symbol);
+ });
+ }
// MarketClient marketClient = MarketClient.create(new HuobiOptions());
// for (Item item : itemList) {
@@ -79,114 +79,117 @@
// trade(marketTradeEvent, symbol);
// });
// }
- }
+ }
- private void ticker(MarketTickerEvent event, String symbol) {
- try {
+ private void ticker(MarketTickerEvent event, String symbol) {
+ try {
- if (map.containsKey(symbol) && map.get(symbol) > event.getTs()) {
- return;
- }
- map.put(symbol, event.getTs() + 500);
- Realtime realtime = new Realtime();
- Item item = itemService.findBySymbol(symbol);
- symbol = item.getSymbol();
- item = this.itemService.findBySymbol(symbol);
- //停牌时不更新
- if (itemService.isSuspended(symbol)) {
- return;
- }
- Double currentValue = AdjustmentValueCache.getCurrentValue().get(symbol).doubleValue();
- double close = event.getTicker().getClose().doubleValue();
- double vol = event.getTicker().getVol().doubleValue();
- double amount = event.getTicker().getAmount().doubleValue();
+ if (map.containsKey(symbol) && map.get(symbol) > event.getTs()) {
+ return;
+ }
+ map.put(symbol, event.getTs() + 500);
+ Realtime realtime = new Realtime();
+ Item item = itemService.findBySymbol(symbol);
+ symbol = item.getSymbol();
+ item = this.itemService.findBySymbol(symbol);
+ //停牌时不更新
+ if (itemService.isSuspended(symbol)) {
+ return;
+ }
+ BigDecimal adjustment = AdjustmentValueCache.getCurrentValue().get(symbol);
+ double currentValue = adjustment != null ? adjustment.doubleValue() : 0D;
+ double close = event.getTicker().getClose().doubleValue();
+ double vol = event.getTicker().getVol().doubleValue();
+ double amount = event.getTicker().getAmount().doubleValue();
- realtime.setSymbol(symbol);
- realtime.setTs(event.getTs());
- realtime.setName(item.getName());
- realtime.setOpen(event.getTicker().getOpen());
- realtime.setClose(new BigDecimal(close));
- realtime.setHigh(event.getTicker().getHigh());
- realtime.setLow(event.getTicker().getLow());
- realtime.setVolume(new BigDecimal(vol));
- realtime.setAmount(new BigDecimal(amount));
+ realtime.setSymbol(symbol);
+ realtime.setTs(event.getTs());
+ realtime.setName(item.getName());
+ realtime.setOpen(event.getTicker().getOpen());
+ realtime.setClose(new BigDecimal(close));
+ realtime.setHigh(event.getTicker().getHigh());
+ realtime.setLow(event.getTicker().getLow());
+ realtime.setVolume(new BigDecimal(vol));
+ realtime.setAmount(new BigDecimal(amount));
- if (currentValue != null && currentValue != 0) {
- realtime.setClose(new BigDecimal(Arith.add(close, currentValue.doubleValue())));
- realtime.setVolume(new BigDecimal(Arith.add(vol, Arith.mul(Arith.div(currentValue, close), vol))));
- realtime.setAmount(new BigDecimal(Arith.add(amount, Arith.mul(Arith.div(currentValue, close), amount))));
- }
+ if (currentValue != 0) {
+ realtime.setClose(new BigDecimal(Arith.add(close, currentValue)));
+ //realtime.setVolume(new BigDecimal(Arith.add(vol, Arith.mul(Arith.div(currentValue, close), vol))));
+ //realtime.setAmount(new BigDecimal(Arith.add(amount, Arith.mul(Arith.div(currentValue, close), amount))));
- Double high = DataCache.getRealtimeHigh().get(symbol);
- Double low = DataCache.getRealtimeLow().get(symbol);
+ Double high = DataCache.getRealtimeHigh().get(symbol);
+ Double low = DataCache.getRealtimeLow().get(symbol);
- if (high == null || realtime.getClose().doubleValue() > high) {
- DataCache.getRealtimeHigh().put(symbol, close);
- }
- if ((low == null || realtime.getClose().doubleValue() < low) && realtime.getClose().doubleValue() > 0) {
- DataCache.getRealtimeLow().put(symbol, close);
- }
+ if (high != null) {
+ realtime.setHigh(BigDecimal.valueOf(high));
+ }
+ if (low != null) {
+ realtime.setLow(BigDecimal.valueOf(low));
+ }
+ }
- Realtime current = DataCache.getRealtime(symbol);
- if (current == null || current.getTs() != event.getTs()) {
- // 交易量倍数不为空或0时修改倍数
- if (item.getMultiple().doubleValue() > 0) {
- realtime.setVolume(realtime.getVolume().multiply(item.getMultiple()));
- realtime.setAmount(realtime.getAmount().multiply(item.getMultiple()));
- }
- if (high != null && high >= realtime.getClose().doubleValue()) {
+
+ Realtime current = DataCache.getRealtime(symbol);
+ if (current == null || current.getTs() != event.getTs()) {
+ // 交易量倍数不为空或0时修改倍数
+ if (item.getMultiple().doubleValue() > 0) {
+ realtime.setVolume(realtime.getVolume().multiply(item.getMultiple()));
+ realtime.setAmount(realtime.getAmount().multiply(item.getMultiple()));
+ }
+
+ /*if (high != null && high >= realtime.getClose().doubleValue()) {
realtime.setHigh(new BigDecimal(high));
}
if (low != null && low <= realtime.getClose().doubleValue()) {
realtime.setLow(new BigDecimal(low));
- }
+ }*/
/*ouble h24Before = DataCache.getRealtime24HBeforeOpen().get(symbol);
if (h24Before != null) {
realtime.setOpen(new BigDecimal(h24Before));
}*/
- /*if (realtime.getSymbol().equals("axsusdt")) {
- System.out.println("axsusdt2" + realtime);
+ /*if (realtime.getSymbol().equals("galausdt")) {
+ System.out.println("galausdt222" + realtime);
}*/
- DataCache.putRealtime(symbol, realtime);
- // System.out.println(JSONObject.toJSONString(realtime));
- }
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
+ DataCache.putRealtime(symbol, realtime);
+ // System.out.println(JSONObject.toJSONString(realtime));
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
- private void depth(MarketDepthEvent event, String symbol) {
- Item item = itemService.findBySymbol(symbol);
- Depth depth = hobiDataService.depthDecorator(event, item);
- if (depth != null) {
- DepthTimeObject timeObject = new DepthTimeObject();
- timeObject.setLastTime(new Date());
- timeObject.setDepth(depth);
- DataCache.getDepth().put(item.getSymbol(), timeObject);
- // System.out.println("深度数据 入缓存" + JSONObject.toJSONString(timeObject));
- }
- }
+ private void depth(MarketDepthEvent event, String symbol) {
+ Item item = itemService.findBySymbol(symbol);
+ Depth depth = hobiDataService.depthDecorator(event, item);
+ if (depth != null) {
+ DepthTimeObject timeObject = new DepthTimeObject();
+ timeObject.setLastTime(new Date());
+ timeObject.setDepth(depth);
+ DataCache.getDepth().put(item.getSymbol(), timeObject);
+ // System.out.println("深度数据 入缓存" + JSONObject.toJSONString(timeObject));
+ }
+ }
- private void trade(MarketTradeEvent event, String symbol) {
- Item item = itemService.findBySymbol(symbol);
- Trade trade = hobiDataService.tradeDecorator(event, item);
- if (trade != null) {
- TradeTimeObject timeObject = new TradeTimeObject();
- timeObject.setLastTime(new Date());
- timeObject.put(item.getSymbol(), trade.getData());
- DataCache.getTrade().put(item.getSymbol(), timeObject);
- }
- }
+ private void trade(MarketTradeEvent event, String symbol) {
+ Item item = itemService.findBySymbol(symbol);
+ Trade trade = hobiDataService.tradeDecorator(event, item);
+ if (trade != null) {
+ TradeTimeObject timeObject = new TradeTimeObject();
+ timeObject.setLastTime(new Date());
+ timeObject.put(item.getSymbol(), trade.getData());
+ DataCache.getTrade().put(item.getSymbol(), timeObject);
+ }
+ }
- public void setItemService(ItemService itemService) {
- this.itemService = itemService;
- }
+ public void setItemService(ItemService itemService) {
+ this.itemService = itemService;
+ }
- public void setHobiDataService(HobiDataService hobiDataService) {
- this.hobiDataService = hobiDataService;
- }
+ public void setHobiDataService(HobiDataService hobiDataService) {
+ this.hobiDataService = hobiDataService;
+ }
}
--
Gitblit v1.9.3