1.1.历史无证设备设备来源进行分3类,公共方法提取

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/java/com/yeejoin/amos/boot/module/jg/api/enums/EquipSourceEnum.java

 package com.yeejoin.amos.boot.module.jg.api.enums;
 
+import com.baomidou.mybatisplus.core.toolkit.StringUtils;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 
@@ -45,4 +46,17 @@ public enum EquipSourceEnum {
     public String getName() {
         return name;
     }
+
+    public static String getDataSourceName(String dataSource) {
+        if(StringUtils.isEmpty(dataSource)){
+            return EquipSourceEnum.jg_his.getName();
+        }
+        if(EquipSourceEnum.jg.getCode().equals(dataSource) || (dataSource.startsWith(EquipSourceEnum.jg.getCode()) && !dataSource.startsWith(EquipSourceEnum.jg_his.getCode()))){
+            return EquipSourceEnum.jg.getName();
+        } else if(dataSource.startsWith(EquipSourceEnum.jg_his_black.getCode())){
+            return EquipSourceEnum.jg_his_black.getName();
+        } else {
+            return EquipSourceEnum.jg_his.getName();
+        }
+    }
 }

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/IdxBizJgRegisterInfoServiceImpl.java

@@ -1015,7 +1015,7 @@ public class IdxBizJgRegisterInfoServiceImpl extends BaseService<IdxBizJgRegiste
                 objMap.putAll(filterMap);
             }
         }
-        objMap.put(DATA_SOURCE_NAME, this.getDataSourceName(useInfo.getDataSource()));
+        objMap.put(DATA_SOURCE_NAME, EquipSourceEnum.getDataSourceName(useInfo.getDataSource()));
         // 设计制造
         IdxBizJgDesignInfo designInfo = iIdxBizJgDesignInfoService.getOneData(record);
         if (!ValidationUtil.isEmpty(designInfo)) {
@@ -1941,7 +1941,7 @@ public class IdxBizJgRegisterInfoServiceImpl extends BaseService<IdxBizJgRegiste
                 if (!ValidationUtil.isEmpty(dto2.get(DATA_SOURCE))) {
                     String s = dto2.get(DATA_SOURCE).toString();
                     dto2.put(DATA_SOURCE, s);
-                    dto2.put(DATA_SOURCE_NAME, this.getDataSourceName(s));
+                    dto2.put(DATA_SOURCE_NAME, EquipSourceEnum.getDataSourceName(s));
                 }
                 dto2.put("record", dto2.get(SEQUENCE_NBR));
                 list.add(dto2);
@@ -1996,18 +1996,6 @@ public class IdxBizJgRegisterInfoServiceImpl extends BaseService<IdxBizJgRegiste
         return result;
     }
 
-    private String getDataSourceName(String dataSource) {
-        if(StringUtils.isEmpty(dataSource)){
-            return "";
-        }
-        if(EquipSourceEnum.jg.getCode().equals(dataSource) || (dataSource.startsWith(EquipSourceEnum.jg.getCode()) || !dataSource.startsWith(EquipSourceEnum.jg_his.getCode()))){
-            return EquipSourceEnum.jg.getName();
-        } else if(dataSource.startsWith(EquipSourceEnum.jg_his_black.getCode())){
-            return EquipSourceEnum.jg_his_black.getName();
-        } else {
-            return EquipSourceEnum.jg_his.getName();
-        }
-    }
 
     /**
      * 设备注册信息分页查询
@@ -2294,11 +2282,7 @@ public class IdxBizJgRegisterInfoServiceImpl extends BaseService<IdxBizJgRegiste
                 if (!ValidationUtil.isEmpty(dto2.get(DATA_SOURCE))) {
                     String s = dto2.get(DATA_SOURCE).toString();
                     dto2.put(DATA_SOURCE, s);
-                    dto2.put(DATA_SOURCE_NAME, Arrays.stream(EquipSourceEnum.values())
-                            .filter(e -> s.startsWith(e.getCode()))
-                            .map(EquipSourceEnum::getName)
-                            .findFirst()
-                            .orElse(EquipSourceEnum.jg.getName()));
+                    dto2.put(DATA_SOURCE_NAME, EquipSourceEnum.getDataSourceName(s));
                 }
                 dto2.put("record", dto2.get(SEQUENCE_NBR));
                 list.add(dto2);
@@ -3872,11 +3856,7 @@ public class IdxBizJgRegisterInfoServiceImpl extends BaseService<IdxBizJgRegiste
                 if (!ValidationUtil.isEmpty(source.get(DATA_SOURCE))) {
                     String s = source.get(DATA_SOURCE).toString();
                     source.put(DATA_SOURCE, s);
-                    source.put(DATA_SOURCE_NAME, Arrays.stream(EquipSourceEnum.values())
-                            .filter(e -> s.startsWith(e.getCode()))
-                            .map(EquipSourceEnum::getName)
-                            .findFirst()
-                            .orElse(EquipSourceEnum.jg.getName()));
+                    source.put(DATA_SOURCE_NAME, EquipSourceEnum.getDataSourceName(s));
                 }
                 result.add(source);
             }

amos-boot-system-tzs/amos-boot-module-statistics/amos-boot-module-statistics-biz/src/main/java/com/yeejoin/amos/boot/module/statistcs/biz/service/impl/JGDPStatisticsServiceImpl.java

@@ -2238,11 +2238,7 @@ public class JGDPStatisticsServiceImpl {
                 if (!ValidationUtil.isEmpty(dto2.get(DATA_SOURCE))) {
                     String s = dto2.get(DATA_SOURCE).toString();
                     dto2.put(DATA_SOURCE, s);
-                    dto2.put(DATA_SOURCE_NAME, Arrays.stream(EquipSourceEnum.values())
-                            .filter(e -> s.startsWith(e.getCode()))
-                            .map(EquipSourceEnum::getName)
-                            .findFirst()
-                            .orElse(EquipSourceEnum.jg.getName()));
+                    dto2.put(DATA_SOURCE_NAME, EquipSourceEnum.getDataSourceName(s));
                 }
                 dto2.put("record", dto2.get(SEQUENCE_NBR));
                 list.add(dto2);