管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2022-11-21 6997d659f4ad0b57b706d2764ae17d3cf0737fef
1
已修改4个文件
74 ■■■■■ 文件已修改
src/main/java/com/lf/server/helper/GdbHelper.java 14 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/helper/MdbHelper.java 14 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/helper/ShpHelper.java 3 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/data/DataLoaderService.java 43 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/helper/GdbHelper.java
@@ -39,4 +39,18 @@
        return list;
    }
    /**
     * 读取数据
     */
    public static <T> List<T> readData(Class clazz, String filePath) {
        List<T> list = new ArrayList<>();
        try {
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
        }
        return list;
    }
}
src/main/java/com/lf/server/helper/MdbHelper.java
@@ -39,4 +39,18 @@
        return list;
    }
    /**
     * 读取数据
     */
    public static <T> List<T> readData(Class clazz, String filePath) {
        List<T> list = new ArrayList<>();
        try {
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
        }
        return list;
    }
}
src/main/java/com/lf/server/helper/ShpHelper.java
@@ -194,6 +194,9 @@
        }
    }
    /**
     * 读取数据
     */
    public static <T> List<T> readData(Class clazz, String filePath) {
        List<T> list = new ArrayList<>();
        try {
src/main/java/com/lf/server/service/data/DataLoaderService.java
@@ -233,13 +233,9 @@
                        insertXls(root, mfe, tabs);
                        break;
                    case "shp":
                        insertShp(temp + "_zip", mfe, tabs);
                        break;
                    case "gdb":
                        insertGdb(temp + "_zip", mfe, tabs);
                        break;
                    case "mdb":
                        insertMdb(temp + "_zip", mfe, tabs);
                        insertDb(me.getType(), temp + "_zip", mfe, tabs);
                        break;
                    default:
                        break;
@@ -431,9 +427,9 @@
    }
    /**
     * 插入SHP
     * 插入DB
     */
    private void insertShp(String root, MetaFileEntity mfe, List<TabMapperEntity> tabs) {
    private void insertDb(String type, String root, MetaFileEntity mfe, List<TabMapperEntity> tabs) {
        for (TabMapperEntity tab : tabs) {
            if (!tab.getFileName().equals(mfe.getName()) || StringHelper.isEmpty(tab.getEntity())) {
                continue;
@@ -450,8 +446,21 @@
                continue;
            }
            List<?> list = ShpHelper.readData(clazz, root + File.separator + tab.getSubPath());
            if (list.isEmpty()) {
            List<?> list = null;
            switch (type) {
                case "shp":
                    list = ShpHelper.readData(clazz, root + File.separator + tab.getSubPath());
                    break;
                case "gdb":
                    list = GdbHelper.readData(clazz, root + File.separator + tab.getSubPath());
                    break;
                case "mdb":
                    list = MdbHelper.readData(clazz, root + File.separator + tab.getSubPath());
                    break;
                default:
                    break;
            }
            if (null == list || list.isEmpty()) {
                continue;
            }
            setCreateInfo(list, mfe);
@@ -486,21 +495,5 @@
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
        }
    }
    /**
     * 插入GDB
     */
    private Integer insertGdb(String root, MetaFileEntity mfe, List<TabMapperEntity> tabs) {
        return 0;
    }
    /**
     * 插入MDB
     */
    private Integer insertMdb(String root, MetaFileEntity mfe, List<TabMapperEntity> tabs) {
        return 0;
    }
}