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/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