1

13693261870

2023-02-18 3e1416bffcb3761d06261e327edcbfe10a5443fb

 src/main/java/com/lf/server/service/show/DataLibService.java

@@ -40,10 +40,10 @@
    private final static Log log = LogFactory.getLog(DataLibService.class);

    /**
     * 查询DB中溢出的单位ID
     * 查询DB中溢出的单位编码
     */
    public List<Integer> selectDbOverflowDep(UserEntity ue, List<String> entities, String wkt) {
        List<Integer> rs = new ArrayList<>();
    public List<String> selectDbOverflowDep(UserEntity ue, List<String> entities, String wkt) {
        List<String> rs = new ArrayList<>();
        for (String enity : entities) {
            try {
                GeomBaseMapper<?> baseMapper = ClassHelper.getGeoBaseMapper(enity);
@@ -53,8 +53,8 @@

                QueryWrapper wrapper = new QueryWrapper();
                wrapper.select("depid");
                wrapper.gt("depid", 0);
                wrapper.apply(String.format("depid != ALL(fn_rec_array(%d, 'dep'))", ue.getDepid()));
                // wrapper.gt("depid", 0); wrapper.apply(String.format("depid != ALL(fn_rec_array(%d, 'dep'))", ue.getDepid()))
                wrapper.apply("depid is not null and depid not like '" + ue.getDepcode() + "%'");
                wrapper.groupBy("depid");

                Integer srid = baseQueryService.getSrid(baseMapper);
@@ -62,9 +62,9 @@
                    wrapper.apply(String.format("ST_Intersects(ST_PolygonFromText('%s', %d), geom)", wkt, srid));
                }

                List<Integer> ids = baseMapper.selectObjs(wrapper);
                List<String> ids = baseMapper.selectObjs(wrapper);

                addDepIds(rs, ids);
                addDepCodes(rs, ids);
            } catch (Exception ex) {
                log.error(ex.getMessage(), ex);
            }
@@ -74,14 +74,14 @@
    }

    /**
     * 添加单位ID
     * 添加单位编码
     */
    private void addDepIds(List<Integer> rs, List<Integer> ids) {
    private void addDepCodes(List<String> rs, List<String> ids) {
        if (null == ids || ids.isEmpty()) {
            return;
        }

        for (Integer id : ids) {
        for (String id : ids) {
            if (!rs.contains(id)) {
                rs.add(id);
            }
@@ -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);
        }
    }
}