Procházet zdrojové kódy

删除算法提示关联自动项目

root před 2 roky
rodič
revize
7e0bb655f3

+ 46 - 44
simulation-resource-server/src/main/java/com/css/simulation/resource/model/service/ConfigService.java

@@ -41,7 +41,8 @@ public class ConfigService {
     //* -------------------------------- Comment --------------------------------
 
     /**
-     *  获取车辆配置列表
+     * 获取车辆配置列表
+     *
      * @param pageParam
      * @return
      */
@@ -50,20 +51,20 @@ public class ConfigService {
         pageParam.setCreateUserId(AuthUtil.getCurrentUserId());
 
         // 私有查询需获取当前人 userId
-        if(DictConstants.IS_NOT_SHARED.equals(pageParam.getShare())){
+        if (DictConstants.IS_NOT_SHARED.equals(pageParam.getShare())) {
             pageParam.setCreateUserId(AuthUtil.getCurrentUserId());
         }
         // 公有查询不需要当前人 userId
-        if(DictConstants.IS_SHARED.equals(pageParam.getShare())){
+        if (DictConstants.IS_SHARED.equals(pageParam.getShare())) {
             pageParam.setCreateUserId(null);
         }
         List<ConfigVO> list = configMapper.getConfigPageList(pageParam);    // 查询《配置-传感器关系表》
         list.forEach(configVO -> {
             List<ConfigSensorVO> sensorList = configMapper.getConfigSensors(configVO);  // 根据配置 id 获取传感器列表
             Map<String, List<ConfigSensorVO>> configSensors = sensorList.stream().collect(Collectors.groupingBy(ConfigSensorVO::getSensorType));
-            Map<String,String> sensorCount = new HashMap<>();
-            configSensors.forEach((sensorType,configSensorVOs)->{
-                sensorCount.put(sensorType,String.valueOf(configSensorVOs.size()));
+            Map<String, String> sensorCount = new HashMap<>();
+            configSensors.forEach((sensorType, configSensorVOs) -> {
+                sensorCount.put(sensorType, String.valueOf(configSensorVOs.size()));
             });
             configVO.setSensorCount(sensorCount);
         });
@@ -83,7 +84,7 @@ public class ConfigService {
         ConfigPO configPO = new ConfigPO();
         String currentUserId = AuthUtil.getCurrentUserId();
         Timestamp currentTime = TimeUtil.getNowForMysql();
-        ObjectUtil.voToPo(configVO,configPO);
+        ObjectUtil.voToPo(configVO, configPO);
         configPO.setCreateUserId(currentUserId);
         configPO.setCreateTime(currentTime);
         configPO.setModifyUserId(currentUserId);
@@ -94,19 +95,19 @@ public class ConfigService {
         configPO.setDescription(configVO.getConfigDescription());
         //名称校验
         List<ConfigVO> list = configMapper.checkConfigName(configPO);
-        if(ObjectUtil.isNotNull(list)){
+        if (ObjectUtil.isNotNull(list)) {
             configPO.setId(null);
             return configPO;
         }
         //主表主键
         String configId = configPO.getId();
-        if(ObjectUtil.isNull(configId)){//新增
+        if (ObjectUtil.isNull(configId)) {//新增
             configId = StringUtil.getRandomUUID();
             configPO.setId(configId);
             configPO.setConfigCode(StringUtil.getRandomCode());
             configMapper.insertConfig(configPO);
             LogUtil.insert();
-        }else{//修改
+        } else {//修改
             configMapper.updateConfig(configPO);
             LogUtil.update();
         }
@@ -116,12 +117,12 @@ public class ConfigService {
         //List<ConfigSensorVO> configSensorVOs = configVO.getConfigSensors();
         Map<String, List<ConfigSensorVO>> configSensors = configVO.getConfigSensors();
         List<ConfigSensorPO> configSensorPOs = new ArrayList<>();
-        if(ObjectUtil.isNotNull(configSensors)){
-            configSensors.forEach((sensorType,configSensorVOs)->{
-                if(ObjectUtil.isNotNull(configSensorVOs)){
+        if (ObjectUtil.isNotNull(configSensors)) {
+            configSensors.forEach((sensorType, configSensorVOs) -> {
+                if (ObjectUtil.isNotNull(configSensorVOs)) {
                     configSensorVOs.forEach(vo -> {
                         ConfigSensorPO po = new ConfigSensorPO();
-                        ObjectUtil.voToPo(vo,po);
+                        ObjectUtil.voToPo(vo, po);
                         po.setId(StringUtil.getRandomUUID());
                         //子表外键
                         po.setConfigId(configPO.getId());
@@ -135,7 +136,7 @@ public class ConfigService {
                 }
             });
         }
-        if(ObjectUtil.isNotNull(configSensorPOs)){
+        if (ObjectUtil.isNotNull(configSensorPOs)) {
             configMapper.insertConfigSensors(configSensorPOs);
         }
         return configPO;
@@ -146,7 +147,7 @@ public class ConfigService {
         ConfigPO configPO = new ConfigPO();
         String currentUserId = AuthUtil.getCurrentUserId();
         Timestamp currentTime = TimeUtil.getNowForMysql();
-        ObjectUtil.voToPo(configVO,configPO);
+        ObjectUtil.voToPo(configVO, configPO);
         configPO.setCreateUserId(currentUserId);
         configPO.setCreateTime(currentTime);
         configPO.setModifyUserId(currentUserId);
@@ -157,10 +158,10 @@ public class ConfigService {
         configPO.setDescription(configVO.getConfigDescription());
         //名称校验
         List<ConfigVO> list = configMapper.checkConfigName(configPO);
-        if(ObjectUtil.isNotNull(list)){
+        if (ObjectUtil.isNotNull(list)) {
             configMapper.updateConfig(configPO);
             LogUtil.update();
-        }else {
+        } else {
             //主表主键
             String configId = configPO.getId();
             configId = StringUtil.getRandomUUID();
@@ -176,12 +177,12 @@ public class ConfigService {
         //List<ConfigSensorVO> configSensorVOs = configVO.getConfigSensors();
         Map<String, List<ConfigSensorVO>> configSensors = configVO.getConfigSensors();
         List<ConfigSensorPO> configSensorPOs = new ArrayList<>();
-        if(ObjectUtil.isNotNull(configSensors)){
-            configSensors.forEach((sensorType,configSensorVOs)->{
-                if(ObjectUtil.isNotNull(configSensorVOs)){
+        if (ObjectUtil.isNotNull(configSensors)) {
+            configSensors.forEach((sensorType, configSensorVOs) -> {
+                if (ObjectUtil.isNotNull(configSensorVOs)) {
                     configSensorVOs.forEach(vo -> {
                         ConfigSensorPO po = new ConfigSensorPO();
-                        ObjectUtil.voToPo(vo,po);
+                        ObjectUtil.voToPo(vo, po);
                         po.setId(StringUtil.getRandomUUID());
                         //子表外键
                         po.setConfigId(configPO.getId());
@@ -195,7 +196,7 @@ public class ConfigService {
                 }
             });
         }
-        if(ObjectUtil.isNotNull(configSensorPOs)){
+        if (ObjectUtil.isNotNull(configSensorPOs)) {
             configMapper.insertConfigSensors(configSensorPOs);
         }
         return configPO;
@@ -203,7 +204,7 @@ public class ConfigService {
 
     public int delConfigById(ConfigVO vo) {
         ConfigPO po = new ConfigPO();
-        ObjectUtil.voToPo(vo,po);
+        ObjectUtil.voToPo(vo, po);
         po.setIsDeleted(DictConstants.YES);
         po.setModifyUserId(AuthUtil.getCurrentUserId());
         po.setModifyTime(TimeUtil.getNowForMysql());
@@ -215,7 +216,7 @@ public class ConfigService {
     public ConfigPO shareConfigByInfo(ConfigVO configVO) {
         //构建主表对象
         ConfigPO configPO = new ConfigPO();
-        ObjectUtil.voToPo(configVO,configPO);
+        ObjectUtil.voToPo(configVO, configPO);
         configPO.setShare(DictConstants.YES);//转公有
         configPO.setCreateUserId(null);
 
@@ -223,14 +224,14 @@ public class ConfigService {
         Timestamp currentTime = TimeUtil.getNowForMysql();
         //名称校验
         List<ConfigVO> list = configMapper.checkConfigName(configPO);
-        if(ObjectUtil.isNotNull(list)){
+        if (ObjectUtil.isNotNull(list)) {
             configPO.setModifyUserId(currentUserId);
             configPO.setModifyTime(currentTime);
             configPO.setIsDeleted(DictConstants.NO);
             configMapper.updateConfig(configPO);
             LogUtil.update();
 
-        }else {
+        } else {
             configPO.setCreateUserId(currentUserId);
             configPO.setCreateTime(currentTime);
             configPO.setModifyUserId(currentUserId);
@@ -245,7 +246,7 @@ public class ConfigService {
             configMapper.insertConfig(configPO);
         }
         //复制车辆表旧数据
-        if(configPO.getVehicleId() != null){
+        if (configPO.getVehicleId() != null) {
             VehicleParam vehicleParam = new VehicleParam();
             vehicleParam.setId(configPO.getVehicleId());
             VehicleVO vehicleInfo = vehicleMapper.getVehicleInfo(vehicleParam);
@@ -257,15 +258,15 @@ public class ConfigService {
 
         //构建字表新数据
         Map<String, List<ConfigSensorVO>> configSensors = configVO.getConfigSensors();
-        System.out.println("  //构建字表新数据---------"+configSensors);
+        System.out.println("  //构建字表新数据---------" + configSensors);
         List<ConfigSensorPO> configSensorPOs = new ArrayList<>();
-        if(CollectionUtil.isNotEmpty(configSensors)){
-            configSensors.forEach((sensorType,configSensorVOs)->{
+        if (CollectionUtil.isNotEmpty(configSensors)) {
+            configSensors.forEach((sensorType, configSensorVOs) -> {
 
-                if(ObjectUtil.isNotNull(configSensorVOs)){
+                if (ObjectUtil.isNotNull(configSensorVOs)) {
                     configSensorVOs.forEach(vo -> {
                         ConfigSensorPO po = new ConfigSensorPO();
-                        ObjectUtil.voToPo(vo,po);
+                        ObjectUtil.voToPo(vo, po);
                         po.setId(StringUtil.getRandomUUID());
                         //子表外键
                         po.setConfigId(configPO.getId());
@@ -282,48 +283,49 @@ public class ConfigService {
                                 cameraParam.setId(vo.getSensorId());
                                 CameraVO cameraVO = cameraService.getCameraInfo(cameraParam);
                                 CameraPO cameraPO = new CameraPO();
-                                ObjectUtil.voToPo(cameraVO,cameraPO);
+                                ObjectUtil.voToPo(cameraVO, cameraPO);
                                 CameraPO cameraPO1 = cameraService.shareCamera(cameraPO);
                                 break;
                             }
-                            case "lidar":{
+                            case "lidar": {
                                 LidarParam lidarParam = new LidarParam();
                                 lidarParam.setId(vo.getSensorId());
                                 LidarVO lidarVO = lidarService.getLidarInfo(lidarParam);
                                 LidarPO lidarPO = new LidarPO();
-                                ObjectUtil.voToPo(lidarVO,lidarPO);
+                                ObjectUtil.voToPo(lidarVO, lidarPO);
                                 LidarPO lidarPO1 = lidarService.shareLidar(lidarPO);
                                 break;
                             }
-                            case "ogt":{
+                            case "ogt": {
                                 OgtParam ogtParam = new OgtParam();
                                 ogtParam.setId(vo.getSensorId());
                                 OgtVO ogtVO = ogtService.getOgtInfo(ogtParam);
                                 OgtPO ogtPO = new OgtPO();
-                                ObjectUtil.voToPo(ogtVO,ogtPO);
+                                ObjectUtil.voToPo(ogtVO, ogtPO);
                                 OgtPO ogtPO1 = ogtService.shareOgt(ogtPO);
                                 break;
                             }
-                            case "gps":{
+                            case "gps": {
                                 GpsParam gpsParam = new GpsParam();
                                 gpsParam.setId(vo.getSensorId());
                                 GpsVO gpsVO = gpsService.getGpsInfo(gpsParam);
                                 GpsPO gpsPO = new GpsPO();
-                                ObjectUtil.voToPo(gpsVO,gpsPO);
+                                ObjectUtil.voToPo(gpsVO, gpsPO);
                                 GpsPO gpsPO1 = gpsService.shareGps(gpsPO);
                                 break;
                             }
-                            case "radar":{
+                            case "radar": {
                                 break;
                             }
-                            default:break;
+                            default:
+                                break;
                         }
 
                     });
                 }
             });
         }
-        if(ObjectUtil.isNotNull(configSensorPOs)){
+        if (ObjectUtil.isNotNull(configSensorPOs)) {
             configMapper.insertConfigSensors(configSensorPOs);
         }
         return configPO;
@@ -336,7 +338,7 @@ public class ConfigService {
         return configPO;
     }
 
-    public int getConfigTotal(){
+    public int getConfigTotal() {
         return configMapper.getConfigTotal(AuthUtil.getCurrentUserId());
     }
 }