管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-02-18 3e1416bffcb3761d06261e327edcbfe10a5443fb
src/main/java/com/lf/server/service/show/DataLibService.java
@@ -40,7 +40,7 @@
    private final static Log log = LogFactory.getLog(DataLibService.class);
    /**
     * 查询DB中溢出的单位ID
     * 查询DB中溢出的单位编码
     */
    public List<String> selectDbOverflowDep(UserEntity ue, List<String> entities, String wkt) {
        List<String> rs = new ArrayList<>();
@@ -64,7 +64,7 @@
                List<String> ids = baseMapper.selectObjs(wrapper);
                addDepIds(rs, ids);
                addDepCodes(rs, ids);
            } catch (Exception ex) {
                log.error(ex.getMessage(), ex);
            }
@@ -74,9 +74,9 @@
    }
    /**
     * 添加单位ID
     * 添加单位编码
     */
    private void addDepIds(List<String> rs, List<String> ids) {
    private void addDepCodes(List<String> rs, List<String> ids) {
        if (null == ids || ids.isEmpty()) {
            return;
        }
@@ -189,7 +189,7 @@
    private DownloadEntity getDownloadEntity(UserEntity ue, String file, String pwd) throws Exception {
        DownloadEntity de = new DownloadEntity();
        de.setName(FileHelper.getFileName(file));
        // 1-Shp文件,2-专题图,3-元数据,4-业务数据
        // 1-Shp文件,2-专题图,3-源数据,4-业务数据,5-管道分析,6-统计报告
        de.setType(4);
        de.setSizes(FileHelper.sizeToMb(new File(file).length()));
        de.setDepid(ue.getDepid());
@@ -257,4 +257,72 @@
        return rows > 0 ? downloadEntity.getGuid() : null;
    }
    /**
     * 处理编码
     */
    public static String copeCodes(String codes, String field) {
        if (StringHelper.isEmpty(codes) || StringHelper.isSqlInjection(codes)) {
            return null;
        }
        List<String> list = codesAsList(codes);
        removeDuplicate(list);
        setRightLike(list, field);
        return StringHelper.join(list, " or ");
    }
    /**
     * 单位编码转集合
     */
    private static List<String> codesAsList(String codes) {
        List<String> list = Arrays.asList(codes.split(","));
        Set set = new HashSet(list);
        List<String> newList = new ArrayList<>(set);
        Collections.sort(newList);
        return newList;
    }
    /**
     * 去除重复
     */
    private static void removeDuplicate(List<String> list) {
        int i = 0;
        while (i < list.size()) {
            int j = findStr(list, i);
            if (j > -1) {
                list.remove(j);
                continue;
            }
            i++;
        }
    }
    /**
     * 查找字符串
     */
    private static int findStr(List<String> list, int i) {
        String source = list.get(i);
        for (int j = i + 1, c = list.size(); j < c; j++) {
            if (list.get(j).startsWith(source)) {
                return j;
            }
        }
        return -1;
    }
    /**
     * 设置 右like
     */
    private static void setRightLike(List<String> list, String field) {
        for (int i = 0, c = list.size(); i < c; i++) {
            String str = String.format("%s like '%s%%'", field, list.get(i));
            list.set(i, str);
        }
    }
}