From 7d9bf660d08d1b39af670e54dedf784e32080dc2 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Fri, 09 Jan 2026 17:54:01 +0800
Subject: [PATCH] ipo
---
trading-order-huobi/src/main/java/com/yami/trading/huobi/task/DepthPushJob.java | 11 +++++++++--
1 files changed, 9 insertions(+), 2 deletions(-)
diff --git a/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/DepthPushJob.java b/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/DepthPushJob.java
index f107080..2a60287 100644
--- a/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/DepthPushJob.java
+++ b/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/DepthPushJob.java
@@ -84,11 +84,18 @@
}
for (String symbol : symbolSet) {
- DepthTimeObject depth = DataCache.getDepth(symbol);
- Item bySymbol = itemService.findBySymbol(symbol);
+ // 新增：校验symbol是否为null或空字符串
+ if (symbol == null || symbol.trim().isEmpty()) {
+ logger.warn("----> DepthPushJob.depthHandle symbol为空或无效，跳过处理");
+ continue;
+ }
+
+ Item bySymbol = itemService.findCaCheBySymbol(symbol);
if (bySymbol == null) {
logger.warn("---> DepthPushJob.depthHandle 当前 symbol:{} 没有对应的数据库记录", symbol);
+ continue;
}
+ DepthTimeObject depth = DataCache.getDepth(symbol);
if (depth == null) {
dataService.depth(symbol);
}
--
Gitblit v1.9.3