bak 更新后

kimi

2020-05-27 2893347bf72477c4d108e8589a0f61e3e97a990c

 src/main/java/com/highdatas/mdm/service/impl/SysViewServiceImpl.java

@@ -67,7 +67,13 @@
    AntianaphylaxisClient antianaphylaxisClient;
    @Autowired
    RedisClient redisClient;

    /**
     *
     * @description:  通过id获取视图分发的分页的回信
     * @param viewId 视图id
     * @return: 分页对象
     *
     */
    @Override
    public Page getInitPageInfo(String viewId) {

@@ -112,6 +118,13 @@
        redisClient.putRedisValObj(realRedisKey, page);
        return page;
    }
    /**
     *
     * @description:  创建视图
     * @param viewId 视图id
     * @return: 创建是否成功
     *
     */
    @Override
    public boolean createView(String viewId) {
        try {
@@ -203,7 +216,13 @@
        }

    }

    /**
     *
     * @description:  视图质量检验
     * @param sysView 视图
     * @return: 是否通过检验
     *
     */
    private boolean checkTempData(SysView sysView) {
        SysAssembleCheckType checkType = sysView.getCheckType();
        if (checkType == null) {
@@ -235,7 +254,13 @@
        }
        return true;
    }

    /**
     *
     * @description:  插入关联表数据
     * @param sysView 视图
     * @return:
     *
     */
    private void InsertJoin(SysView sysView) {
        String userId = sysView.getUserId();
        TUser user = DbUtils.getUserById(userId);
@@ -272,7 +297,13 @@
        }
        tableInfoMapper.updateJoin(tableName, joinSql, updateFieldBuilder.toString(), Constant.WHERE_DEFAULT);
    }

    /**
     *
     * @description:  1对1 数据转换
     * @param sysView 视图
     * @return:
     *
     */
    private void changeValCommon(SysView sysView) {
        String mappingField = sysView.getMappingField();
        String tableName = sysView.getViewTableName();
@@ -296,7 +327,14 @@
            tableInfoMapper.updateJoin(tableName, changeJoinStr, updateSegment.toRawString(), filterSegment.toString());
        }
    }

    /**
     *
     * @description:  从新生成视图表
     * @param tableName 表名
     * @param totalFieldList 字段列表
     * @return: 生成是否成功
     *
     */
    private boolean dropCreateViewTable(List<String> totalFieldList, String tableName) {
        boolean created = unBigDataDataSourceInfo.dropData(tableName);
        if (!created) {
@@ -311,6 +349,13 @@
        return true;
    }

    /**
     *
     * @description:  获取视图的物理表名
     * @param view 视图对象
     * @return: 物理表名
     *
     */
    @Override
    public String getViewTableName(SysView view) {
        String viewTableName = view.getViewTableName();
@@ -321,7 +366,13 @@
        }
        return viewTableName;
    }

    /**
     *
     * @description:  获取视图 mapping的物理表名
     * @param view 视图对象
     * @return: mapping的物理表名
     *
     */
    @Override
    public String getMappingTableName(SysView view) {
        String id = view.getId();
@@ -330,6 +381,15 @@
        view.setMappingTable(mappingTableName).updateById();
        return mappingTableName;
    }
    /**
     *
     * @description:  获取关联主题的有权限的字段
     * @param user 用户
     * @param join 关联主题对象
     * @return: 关联主题的有权限的字段
     *
     */

    @Override
    public List<String> getSubFieldList(SysViewJoin join, TUser user) {
        String fieldsStr = join.getFields();
@@ -346,7 +406,13 @@

        return baseFieldList;
    }

    /**
     *
     * @description:  获取基准主题的有权限的字段
     * @param sysView 主题
     * @return: 基准主题的有权限的字段
     *
     */
    private List<String> getBaseFieldList(SysView sysView) {
        String fieldsStr = sysView.getFields();
        List<String> baseFieldList = new ArrayList<>();
@@ -362,6 +428,13 @@

        return baseFieldList;
    }
    /**
     *
     * @description:  获取1对1转换的字段
     * @param sysView 视图
     * @return: 1对1转换的字段列表
     *
     */
    @Override
    public List<ViewMapFieldItem> getMapField(SysView sysView) {
        List<ViewMapFieldItem> result = new ArrayList<>();
@@ -412,14 +485,26 @@
        }
        return result;
    }

    /**
     *
     * @description:  获取关联主题对象
     * @param sysView 视图
     * @return: 获取关联主题对象
     *
     */
    private List<SysViewJoin> getJoinList(SysView sysView) {
        String id = sysView.getId();
        Wrapper<SysViewJoin> eq = new EntityWrapper<SysViewJoin>().eq(Constant.PARENT_ID, id);
        List<SysViewJoin> joinList = joinService.selectList(eq);
        return joinList;
    }

    /**
     *
     * @description:  获取全部字段列表
     * @param sysView 视图
     * @return: 全部字段列表
     *
     */
    public List<String> getTotalFieldList(SysView sysView) {
        String userId = sysView.getUserId();
        TUser user = DbUtils.getUserById(userId);
@@ -443,7 +528,13 @@
        sysView.setViewJoinList(sysViewJoins);
        return totalFieldList;
    }

    /**
     *
     * @description:  获取基准主题对象
     * @param sysView 视图
     * @return: 获取基准主题对象
     *
     */
    @Override
    public Maintain getBaseMaintain(SysView sysView) {

@@ -459,7 +550,13 @@
    }
    return baseMaintain;
    }

    /**
     *
     * @description:  获取关联主题对象
     * @param viewJoin 视图关联主题
     * @return: 获取关联主题对象
     *
     */
    @Override
    public Maintain getJoinMaintain(SysViewJoin viewJoin) {

@@ -475,12 +572,26 @@
        }
        return baseMaintain;
    }

    /**
     *
     * @description:  获取视图实际使用的字段
     * @param field 主题字段
     * @param baseTableName 表名
     * @return: 视图实际使用的字段
     *
     */
    @Override
    public String changeFieldName(String baseTableName, String field) {
        return DbUtils.StrJoinLink(Constant.EMPTY_Str, baseTableName, Constant.UnderLine, field);
    }

    /**
     *
     * @description:  审批结束后根据条件重新生成视图并分发
     * @param maintainId 版本id
     * @param status 审批状态
     * @return:
     *
     */
    @Override
    public void dealFlow(String maintainId, ActivitiStatus status) {
        try {