管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-03-28 d3d32bede6f5dfe8fa1939c7fb85f0af57ea3358
src/main/java/com/lf/server/service/show/DataLibService.java
@@ -148,8 +148,11 @@
     * 请求DB数据下载
     */
    public String downloadDbReq(UserEntity ue, DownloadReqEntity dr) {
        Map<String, List<?>> map = queryData(dr);
        if (map.size() == 0) {
        Map<String, String> annexMap = new HashMap<>(3);
        Map<String, List<?>> dataMap = new HashMap<>(3);
        queryData(dr, dataMap, annexMap);
        if (dataMap.size() == 0) {
            return null;
        }
@@ -159,8 +162,7 @@
    /**
     * 查询数据
     */
    private Map<String, List<?>> queryData(DownloadReqEntity dr) {
        Map<String, List<?>> map = new HashMap<>(3);
    private void queryData(DownloadReqEntity dr, Map<String, List<?>> dataMap, Map<String, String> annexMap) {
        for (String enity : dr.getEntities()) {
            try {
                BasicMapper baseMapper = ClassHelper.getBasicMapper(enity);
@@ -169,20 +171,23 @@
                }
                QueryWrapper wrapper = createQueryWrapper(baseMapper, dr);
                List<?> list = baseMapper.selectList(wrapper);
                List list = baseMapper.selectList(wrapper);
                if (null == list || list.size() == 0) {
                    continue;
                }
                if (!map.containsKey(enity)) {
                    map.put(enity, list);
                if (!dataMap.containsKey(enity)) {
                    dataMap.put(enity, list);
                } else {
                    dataMap.get(enity).addAll(list);
                }
                // SQL片段
                String sqlSegment = wrapper.getSqlSegment();
            } catch (Exception ex) {
                log.error(ex.getMessage(), ex);
            }
        }
        return map;
    }
    /**
@@ -196,7 +201,8 @@
            wrapper.apply(dirs);
        }
        if (!StringHelper.isEmpty(dr.getDepcode())) {
            wrapper.likeRight("depid", dr.getDepcode());
            //wrapper.likeRight("depid", dr.getDepcode());
            wrapper.apply(String.format("depid like '%s'", StringHelper.getRightLike(dr.getDepcode())));
        }
        if (baseMapper instanceof GeomBaseMapper && !StringHelper.isEmpty(dr.getWkt())) {
            wrapper.select("ST_AsText(geom) as geom, *");
@@ -415,7 +421,7 @@
        removeDuplicate(list);
        setRightLike(list, field);
        return StringHelper.join(list, " or ");
        return "(" + StringHelper.join(list, " or ") + ")";
    }
    /**