|
@@ -361,8 +361,6 @@ public class BoatPollutionWarningServiceImpl extends ServiceImpl<BoatPollutionWa
|
|
|
List<Map<String, List<BoatAISVO>>> boatAISVOMaplist = splitMap(boatAISVOMap, 50);
|
|
|
boatAISVOMaplist.forEach(subBoatAISVOMap -> CompletableFuture.runAsync(() -> {
|
|
|
{
|
|
|
-
|
|
|
-
|
|
|
boatAISVOMap.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());
|