| | |
| | | } |
| | | |
| | | 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); |
| | | } |