From 00f42b535ae2001903ef18168f16fbe477e59a23 Mon Sep 17 00:00:00 2001
From: zyy3 <zyy3@zy.com>
Date: Thu, 06 Nov 2025 16:40:30 +0800
Subject: [PATCH] 1
---
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