bak 更新后

kimi

2020-05-27 2893347bf72477c4d108e8589a0f61e3e97a990c

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

@@ -45,7 +45,14 @@
    IMasterAuthorDetailService masterAuthorDetailService;
    @Autowired
    RedisClient redisClient;

    /**
     *
     * @description:  获取下一版本信息
     * @param tableName 表名
     * @param userId 用户id
     * @return: 字段版本对象
     *
     */
    @Override
    public MaintainField getNextMaintain(String tableName, String userId) {
        MaintainField maintain = this.getMaxVersion(tableName);
@@ -101,7 +108,13 @@
        }
        return nowMaintain;
    }

    /**
     *
     * @description:  通过字段版本获取对应的数据版本list
     * @param tableName 表名
     * @return 数据版本列表
     *
     */
    @Override
    public List<Maintain> getMaintainByMaintainField(String maintainFieldId, String tableName) {
        HashMap<String, List<Maintain>> resultMap = getMaintainFieldMapByTable(tableName);
@@ -123,40 +136,15 @@
        return resultMap.get(maintainFieldId);
    }

    @Override
    public boolean checkNowVersion(String maintainFieldId) {
        MaintainField maintain = selectById(maintainFieldId);
        MaintainField maxVersion = getNowVersion(maintain.getTableName());
        Integer compared = DbUtils.compareVersion(maxVersion, maintain);
        if (compared != null && compared == 0) {
            return true;
        } else {
            return false;
        }
    }

    @Override
    public boolean checkFirstVersion(String id) {
        MaintainField maintain = selectById(id);
        MaintainField order_no = selectOne(new EntityWrapper<MaintainField>().eq("table_name", maintain.getTableName()).orderBy("order_no"));
        if (maintain.getId().equalsIgnoreCase(order_no.getId())) {
            return true;
        }
        return false;
    }

    @Override
    public boolean checkdMaxVersion(String maintainFieldId) {
        MaintainField maintain = selectById(maintainFieldId);
        MaintainField maxVersion = getMaxVersion(maintain.getTableName());
        Integer compared = DbUtils.compareVersion(maxVersion, maintain);
        if (compared == 0) {
            return true;
        } else {
            return false;
        }
    }

    /**
     *
     * @description:  获取最大的字段版本
     * @param tableName 表名
     * @return 字段版本对象
     *
     */
    @Override
    public MaintainField getMaxVersion(String tableName) {
        Wrapper<MaintainField> versionWrapper = new EntityWrapper<MaintainField>().eq("table_name", tableName).orderBy("order_no desc");
@@ -164,7 +152,13 @@
        MaintainField maxVersion = this.selectOne(versionWrapper);
        return maxVersion;
    }

    /**
     *
     * @description:  获取未生效的最大版本
     * @param tableName 表名
     * @return 字段版本对象
     *
     */
    @Override
    public MaintainField getUnFlowMaxVersion(String tableName) {
        Wrapper<MaintainField> versionWrapper = new EntityWrapper<MaintainField>().isNull("flow_id").eq("table_name", tableName).orderBy("order_no desc");
@@ -172,7 +166,13 @@
        MaintainField maxVersion = selectOne(versionWrapper);
        return maxVersion;
    }

    /**
     *
     * @description:  获取当前正在用的字段版本对象
     * @param tableName 表名
     * @return 字段版本对象
     *
     */
    @Override
    public MaintainField getNowVersion(String tableName) {
        Wrapper<MaintainField> versionWrapper = new EntityWrapper<MaintainField>().eq("table_name", tableName).isNotNull("flow_id").orderBy("order_no desc");
@@ -191,12 +191,13 @@
        return null;
    }

    @Override
    public MaintainField getMaintainFromVersion(String tableName, String verison) {
        Wrapper<MaintainField> versionWrapper = new EntityWrapper<MaintainField>().eq("version", verison).eq("table_name", tableName);
        MaintainField maxVersion = selectOne(versionWrapper);
        return maxVersion;
    }
    /**
     *
     * @description:  流程完成后的处理
     * @param maintainId 字段版本
     * @param status 流程状态
     *
     */

    @Override
    public void dealFlow(String maintainId, ActivitiStatus status) {
@@ -306,7 +307,13 @@




    /**
     *
     * @description:  获取未生效的版本数量
     * @param tableName 表名
     * @return 未生效版本数量
     *
     */
    @Override
    public int getUnFlowCount(String tableName, String userId) {
        List<MaintainField> maintainFields = selectList(new EntityWrapper<MaintainField>().eq("table_name", tableName));
@@ -326,7 +333,13 @@
        }
        return cnt;
    }

    /**
     *
     * @description:  通过表名获取字段版本，数据版本的map list
     * @param tableName 表名
     * @return 字段版本，数据版本的map list
     *
     */
    @Override
    public JSONArray getMaintainListByTable(String tableName) {
        HashMap<String, List<Maintain>> resultMap = getMaintainFieldMapByTable(tableName);
@@ -373,7 +386,14 @@
        }
        return array;
    }

    /**
     *
     * @description:  通过表名和字段版本获取数据版本list
     * @param tableName 表名
     * @param id 字段版本id
     * @return 数据版本list
     *
     */
    @Override
    public List<Maintain> getMaintainListByMaintainField(String id, String tableName) {
        MaintainField maintainField = selectById(id);
@@ -388,7 +408,13 @@

        return  getMaintainByMaintainField(maintainField.getId(), maintainField.getTableName());
    }

    /**
     *
     * @description:  通过表名获取字段版本，数据版本的map list
     * @param tableName 表名
     * @return 字段版本，数据版本的map list
     *
     */
    private HashMap<String, List<Maintain>> getMaintainFieldMapByTable(String tableName) {
        List<Maintain> maintainList = maintainService.selectList(new EntityWrapper<Maintain>().eq("table_name", tableName).isNotNull("flow_id").orderBy("order_no desc"));
        HashMap<String, List<Maintain>> resultMap = new HashMap<>();