管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-05-26 1f9acd6a4190052a909ff04102f8b15b57444ecc
1
已修改3个文件
48 ■■■■ 文件已修改
src/main/java/com/lf/server/entity/all/StaticData.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/show/ApplyService.java 40 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/application.yml 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/entity/all/StaticData.java
@@ -54,6 +54,8 @@
    public static final int I180_NEG = -180;
    public static final int I1000 = 1000;
    public static final int I2050 = 2050;
    public static final int I4490 = 4490;
@@ -118,6 +120,8 @@
    public final static String ADMIN = "admin";
    public final static String SYS_META = "sysmeta";
    /**
     * 版本号
     */
src/main/java/com/lf/server/service/show/ApplyService.java
@@ -2,6 +2,7 @@
import com.lf.server.entity.all.StaticData;
import com.lf.server.entity.ctrl.DownloadReqEntity;
import com.lf.server.entity.data.MetaEntity;
import com.lf.server.entity.show.ApplyEntity;
import com.lf.server.entity.show.FlowEntity;
import com.lf.server.entity.sys.UserEntity;
@@ -162,7 +163,7 @@
        ApplyEntity apply = new ApplyEntity();
        apply.setUserid(ue.getId());
        apply.setDepids(StringHelper.join(dr.getDepcodes(), ","));
        apply.setTabs(StringHelper.join(dr.getTabs(), ","));
        apply.setTabs(getTabs(dr));
        apply.setEntities(StringHelper.join(dr.getEntities(), ","));
        apply.setWkt(dr.getWkt());
        apply.setPwd(aesPwd);
@@ -176,6 +177,33 @@
        apply.setFilters(dr.getFilter());
        return apply;
    }
    /**
     * 获取表名
     */
    private String getTabs(DownloadReqEntity dr) {
        if (!StaticData.SYS_META.equals(dr.getEntities())) {
            return StringHelper.join(dr.getTabs(), ",");
        }
        List<MetaEntity> list = metaService.selectMetaFiles(dr.getIds());
        if (null == list || list.isEmpty()) {
            return "元数据表";
        }
        StringBuilder sb = new StringBuilder();
        for (MetaEntity me : list) {
            sb.append(me.getName()).append(",");
            if (sb.length() > StaticData.I1000) {
                break;
            }
        }
        if (sb.length() > 1) {
            sb.deleteCharAt(sb.length() - 1);
        }
        return sb.toString();
    }
    /**
@@ -217,10 +245,10 @@
            dr.setPwd(pwd);
            dr.setDepcode(entity.getDepcode());
            dr.setDirs(entity.getDircodes());
            dr.setIds(getIds(entity));
            dr.setIds(getIds(entity.getGids()));
            dr.setFilter(entity.getFilters());
            String guid = "sysmeta".equals(entity.getEntities()) ? metaService.downloadMeteReq(ue, dr) : dataLibService.downloadDbReq(ue, dr);
            String guid = StaticData.SYS_META.equals(entity.getEntities()) ? metaService.downloadMeteReq(ue, dr) : dataLibService.downloadDbReq(ue, dr);
            if (!StringHelper.isEmpty(guid)) {
                entity.setGuid(guid);
                update(entity);
@@ -233,13 +261,13 @@
    /**
     * 获取ID集合
     */
    private List<Integer> getIds(ApplyEntity entity) {
        if (StringHelper.isEmpty(entity.getGids())) {
    private List<Integer> getIds(String gids) {
        if (StringHelper.isEmpty(gids)) {
            return null;
        }
        List<Integer> list = new ArrayList<>();
        for (String str : entity.getGids().split(StaticData.COMMA)) {
        for (String str : gids.split(StaticData.COMMA)) {
            list.add(Integer.parseInt(str));
        }
src/main/resources/application.yml
@@ -42,8 +42,8 @@
  datasource:
    name: prod
    # JDBC 基本配置 &currentSchema=public
    #url: jdbc:postgresql://103.85.165.99:5433/langfang?useAffectedRows=true
    url: jdbc:postgresql://192.168.20.205:5433/langfang?useAffectedRows=true
    url: jdbc:postgresql://103.85.165.99:5433/langfang?useAffectedRows=true
    #url: jdbc:postgresql://192.168.20.205:5433/langfang?useAffectedRows=true
    #url: jdbc:postgresql://127.0.0.1:5433/langfang?useAffectedRows=true
    username : postgres
    password: Postgres!_14_Lf