From 69b5fdc593fa73424448df0c911c5177f7497e7c Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Mon, 01 Sep 2025 18:44:11 +0800
Subject: [PATCH] 停牌判断 新增申购记录
---
trading-order-admin/src/main/java/com/yami/trading/admin/task/RealtimeWebsocketServer.java | 5 +++++
1 files changed, 5 insertions(+), 0 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 1d3f217..95667f5 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
@@ -4,6 +4,7 @@
import com.yami.trading.bean.data.domain.Realtime;
import com.yami.trading.bean.data.domain.Trade;
import com.yami.trading.bean.item.domain.Item;
+import com.yami.trading.common.exception.YamiShopBindException;
import com.yami.trading.common.util.Arith;
import com.yami.trading.huobi.data.AdjustmentValueCache;
import com.yami.trading.huobi.data.DataCache;
@@ -91,6 +92,10 @@
Item item = itemService.findBySymbol(symbol);
symbol = item.getSymbol();
item = this.itemService.findBySymbol(symbol);
+ //停牌时不更新
+ if (itemService.isSuspended(item)) {
+ return;
+ }
Double currentValue = AdjustmentValueCache.getCurrentValue().get(symbol).doubleValue();
double close = event.getTicker().getClose().doubleValue();
double vol = event.getTicker().getVol().doubleValue();
--
Gitblit v1.9.3