diff --git a/health-watch/health-watch-biz/src/main/java/com/renkang/watch/service/impl/WatchServiceImpl.java b/health-watch/health-watch-biz/src/main/java/com/renkang/watch/service/impl/WatchServiceImpl.java index 1b1d7c0..040febd 100644 --- a/health-watch/health-watch-biz/src/main/java/com/renkang/watch/service/impl/WatchServiceImpl.java +++ b/health-watch/health-watch-biz/src/main/java/com/renkang/watch/service/impl/WatchServiceImpl.java @@ -402,7 +402,7 @@ public class WatchServiceImpl implements IWatchService { periodList.add(new JSONObject().fluentPut("wdType", wdType)); } } - return periodList.parallelStream().map(jsonValue -> { + return periodList.stream().filter(Objects::nonNull).map(jsonValue -> { JSONObject item = (JSONObject) jsonValue; WatchH5IndexItemVo itemVo = item.toJavaObject(WatchH5IndexItemVo.class); if (Objects.isNull(itemVo.getWarnMax())) {