From df42e224ff59c45d88ad15913d27d2b66a33e6c4 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Tue, 11 Nov 2025 15:40:20 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
trading-order-huobi/src/main/java/com/yami/trading/huobi/task/RealtimePushJob.java | 14 +++++++++++++-
1 files changed, 13 insertions(+), 1 deletions(-)
diff --git a/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/RealtimePushJob.java b/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/RealtimePushJob.java
index e1553ca..c91bc89 100644
--- a/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/RealtimePushJob.java
+++ b/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/RealtimePushJob.java
@@ -73,6 +73,18 @@
}
for (String symbol : symbolSet) {
+ // 新增：校验symbol是否为null或空字符串
+ if (symbol == null || symbol.trim().isEmpty()) {
+ log.warn("----> RealtimePushJob symbol为空或无效，跳过处理");
+ continue;
+ }
+
+ Item bySymbol = itemService.findCaCheBySymbol(symbol);
+ if (bySymbol == null) {
+ log.warn("---> RealtimePushJob 当前 symbol:{} 没有对应的数据库记录", symbol);
+ continue;
+ }
+
Realtime realtimeData = DataCache.getRealtime(symbol);
if (realtimeData == null) {
log.error("realtimeHandle 获取{} 数据为空", symbol);
@@ -99,7 +111,7 @@
}
}
- } catch (Throwable e) {
+ } catch (Exception e) {
e.printStackTrace();
}
--
Gitblit v1.9.3