优化

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

@@ -3,7 +3,6 @@ package com.shanghaichengdi.service.impl;
 import com.shanghaichengdi.common.enums.SupervisionTypeEnum;
 import com.shanghaichengdi.common.exception.BizException;
 import com.shanghaichengdi.common.properties.GpsStartTimeProperties;
-import com.shanghaichengdi.common.properties.WarningProperties;
 import com.shanghaichengdi.common.util.LocalDateTimeUtil;
 import com.shanghaichengdi.dao.entity.BoatPollutionSupervision;
 import com.shanghaichengdi.dao.entity.DictDistrictPort;
@@ -34,9 +33,6 @@ public class BoatPollutionWarningHandleServiceImpl implements IBoatPollutionWarn
     @Resource
     private GpsStartTimeProperties gpsStartTimeProperties;
 
-    @Resource
-    private WarningProperties warningProperties;
-
     @Resource
     private IGpsinfoHistoryService gpsinfoHistoryService;
 
@@ -83,9 +79,7 @@ public class BoatPollutionWarningHandleServiceImpl implements IBoatPollutionWarn
         Map<String, List<BoatAISVO>> boatAISVOMap = boatAISList.stream().collect(Collectors.groupingBy(BoatAISVO::getDeviceId));
         List<Map<String, List<BoatAISVO>>> boatAISVOMaplist = splitMap(boatAISVOMap, 50);
         boatAISVOMaplist.forEach(subBoatAISVOMap -> CompletableFuture.runAsync(() -> {
-            {
-                boatPollutionWarningService.handleShortBarge(subBoatAISVOMap, boatPollutionSupervisionList, dictDistrictPortList);
-            }
+            boatPollutionWarningService.handleShortBarge(subBoatAISVOMap, boatPollutionSupervisionList, dictDistrictPortList);
         }));
 
         LocalDateTime handleEndTime = LocalDateTime.now();
@@ -124,9 +118,7 @@ public class BoatPollutionWarningHandleServiceImpl implements IBoatPollutionWarn
         Map<String, List<BoatAISVO>> boatAISVOMap = boatAISList.stream().collect(Collectors.groupingBy(BoatAISVO::getDeviceId));
         List<Map<String, List<BoatAISVO>>> boatAISVOMaplist = splitMap(boatAISVOMap, 50);
         boatAISVOMaplist.forEach(subBoatAISVOMap -> CompletableFuture.runAsync(() -> {
-            {
-                boatPollutionWarningService.handleOrdinaryShip(subBoatAISVOMap, boatPollutionSupervisionList, dictDistrictPortList);
-            }
+            boatPollutionWarningService.handleOrdinaryShip(subBoatAISVOMap, boatPollutionSupervisionList, dictDistrictPortList);
         }));
         LocalDateTime handleEndTime = LocalDateTime.now();
         log.info("==========BoatPollutionWarningServiceImpl.handleOrdinaryShip crossTime:[" + Duration.between(handleStartTime, handleEndTime).toMillis() + " milliseconds]==========");