| | |
| | | } |
| | | |
| | | 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); |
| | |
| | | } |
| | | } |
| | | |
| | | } catch (Throwable e) { |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | |