init

src/main/java/com/shanghaichengdi/service/impl/BoatPollutionWarningServiceImpl.java

@@ -94,7 +94,7 @@ public class BoatPollutionWarningServiceImpl extends ServiceImpl<BoatPollutionWa
         List<Map<String, List<BoatAISVO>>> boatAISVOMaplist = splitMap(boatAISVOMap, 50);
         boatAISVOMaplist.forEach(subBoatAISVOMap -> CompletableFuture.runAsync(() -> {
             {
-                boatAISVOMap.forEach((k, v) -> {
+                subBoatAISVOMap.forEach((k, v) -> {
                     //查询船舶最近监管记录
                     List<BoatPollutionSupervision> bpsList = boatPollutionSupervisionList.stream().filter(x -> x.getMmsi().equals(k) && x.getSupervisionState().equals(SupervisionStateEnum.SUPERVISING.getStatusCode())).sorted(Comparator.comparing(BoatPollutionSupervision::getCreatedTime).reversed()).collect(Collectors.toList());
                     LocalDateTime gpsTime = LocalDateTimeUtil.parse(v.get(0).getGpsTime());
@@ -361,7 +361,7 @@ public class BoatPollutionWarningServiceImpl extends ServiceImpl<BoatPollutionWa
         List<Map<String, List<BoatAISVO>>> boatAISVOMaplist = splitMap(boatAISVOMap, 50);
         boatAISVOMaplist.forEach(subBoatAISVOMap -> CompletableFuture.runAsync(() -> {
             {
-                boatAISVOMap.forEach((k, v) -> {
+                subBoatAISVOMap.forEach((k, v) -> {
                     //查询船舶最近监管记录
                     List<BoatPollutionSupervision> bpsList = boatPollutionSupervisionList.stream().filter(x -> x.getMmsi().equals(k) && x.getSupervisionState().equals(SupervisionStateEnum.SUPERVISING.getStatusCode())).sorted(Comparator.comparing(BoatPollutionSupervision::getCreatedTime).reversed()).collect(Collectors.toList());
                     LocalDateTime gpsTime = LocalDateTimeUtil.parse(v.get(0).getGpsTime());