管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-03-28 819512a986332036d9b46ea68f8ae19d02f34353
1
已修改1个文件
17 ■■■■ 文件已修改
src/main/java/com/lf/server/service/show/DataLibService.java 17 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/show/DataLibService.java
@@ -148,8 +148,8 @@
     * 请求DB数据下载
     */
    public String downloadDbReq(UserEntity ue, DownloadReqEntity dr) {
        Map<String, String> annexMap = new HashMap<>(3);
        Map<String, List<?>> dataMap = new HashMap<>(3);
        Map<String, List<?>> dataMap = new HashMap<>(2);
        Map<String, List<AttachEntity>> annexMap = new HashMap<>(2);
        queryData(dr, dataMap, annexMap);
        if (dataMap.size() == 0) {
@@ -162,7 +162,7 @@
    /**
     * 查询数据
     */
    private void queryData(DownloadReqEntity dr, Map<String, List<?>> dataMap, Map<String, String> annexMap) {
    private void queryData(DownloadReqEntity dr, Map<String, List<?>> dataMap, Map<String, List<AttachEntity>> annexMap) {
        for (String enity : dr.getEntities()) {
            try {
                BasicMapper baseMapper = ClassHelper.getBasicMapper(enity);
@@ -176,19 +176,26 @@
                    continue;
                }
                String tab = BaseQueryService.getTabName(baseMapper);
                if (!dataMap.containsKey(enity)) {
                    dataMap.put(enity, list);
                } else {
                    dataMap.get(enity).addAll(list);
                }
                if (wrapper.isEmptyOfWhere()) {
                    wrapper.apply("1 = 1");
                }
                String tab = BaseQueryService.getTabName(baseMapper);
                List<AttachEntity> annex = baseMapper.selectAnnex(tab, wrapper);
                if (null == annex || annex.isEmpty()) {
                    continue;
                }
                //
                if (!annexMap.containsKey(enity)) {
                    annexMap.put(enity, annex);
                } else {
                    annexMap.get(enity).addAll(annex);
                }
            } catch (Exception ex) {
                log.error(ex.getMessage(), ex);
            }