管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-02-09 effc7aa4c1006fc2874f47f34db3be13384014ea
1
已修改2个文件
49 ■■■■ 文件已修改
src/main/java/com/lf/server/controller/show/DataLibController.java 7 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/show/DataLibService.java 42 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/controller/show/DataLibController.java
@@ -321,13 +321,8 @@
                return fail("密码不符合要求");
            }
            BasicMapper baseMapper = ClassHelper.getBasicMapper(name);
            if (baseMapper == null) {
                return fail("查询对象不存在", null);
            }
            UserEntity ue = tokenService.getCurrentUser(req);
            String guid = dataLibService.zipDbData(ue, baseMapper, filter, pwd);
            String guid = dataLibService.zipDbData(ue, name, filter, pwd);
            return success(guid);
        } catch (Exception ex) {
src/main/java/com/lf/server/service/show/DataLibService.java
@@ -207,12 +207,15 @@
    /**
     * 打包DB数据
     */
    public String zipDbData(UserEntity ue, BasicMapper baseMapper, String filter, String pwd) {
        boolean flag = baseMapper instanceof GeomBaseMapper;
    public String zipDbData(UserEntity ue, String name, String filter, String pwd) throws Exception {
        BasicMapper baseMapper = ClassHelper.getBasicMapper(name);
        if (baseMapper == null) {
            return null;
        }
        QueryWrapper wrapper = new QueryWrapper();
        baseQueryService.addFilterWrapper(wrapper, filter);
        if (flag) {
        if (baseMapper instanceof GeomBaseMapper) {
            wrapper.select("ST_AsText(geom) as geom, *");
        }
@@ -221,6 +224,37 @@
            return null;
        }
        return null;
        Map<String, List<?>> map = new HashMap<>(1);
        map.put(name, list);
        return zipData(ue, map, pwd);
    }
    /**
     * 打包数据
     */
    private String zipData(UserEntity ue, Map<String, List<?>> map, String pwd) throws Exception {
        String tempName = StringHelper.YMDHMS2_FORMAT.format(new Date());
        String tempPath = pathHelper.getTempPath(tempName);
        String filePath = tempPath + File.separator + tempName + ".gdb";
        File file = new File(filePath);
        if (file.exists() && file.isDirectory()) {
            FileHelper.deleteDir(filePath);
        }
        GdbHelper.createGdb(filePath, map);
        String zipName = tempName + ".gdb.zip";
        String zipFile = pathHelper.getDownloadFullPath() + File.separator + zipName;
        ZipFile zip = Zip4jHelper.createZipFile(zipFile, pwd);
        ZipParameters params = Zip4jHelper.getZipParams();
        addZipFiles(zip, params, file.listFiles());
        String dbPwd = Md5Helper.reverse(Md5Helper.generate(pwd));
        DownloadEntity downloadEntity = getDownloadEntity(ue, zipFile, dbPwd);
        int rows = downloadMapper.insert(downloadEntity);
        return rows > 0 ? downloadEntity.getGuid() : null;
    }
}