水库数据质量管理

guoshilong

2023-07-05 f18ae9ca317f81095dc1f7e4e32a7513620f9f5d

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
package cn.gistack.sm.resDataCheck.service.impl;
 
import cn.gistack.sm.resDataCheck.entity.Rules;
import cn.gistack.sm.resDataCheck.entity.RulesCondition;
import cn.gistack.sm.resDataCheck.mapper.RulesMapper;
import cn.gistack.sm.resDataCheck.service.IRulesConditionService;
import cn.gistack.sm.resDataCheck.service.IRulesService;
import cn.gistack.sm.resDataCheck.vo.RulesVO;
import com.baomidou.mybatisplus.core.metadata.IPage;
import lombok.AllArgsConstructor;
import org.springblade.core.mp.base.BaseServiceImpl;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.tool.utils.ObjectUtil;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import java.util.List;
 
/**
 * 数据校验规则
 */
@Service
@AllArgsConstructor
public class RulesServiceImpl extends BaseServiceImpl<RulesMapper, Rules> implements IRulesService {
    private final IRulesConditionService rulesConditionService;
 
 
    @Override
    public IPage<Rules> selectRulesPage(IPage<Rules> page, Rules rules) {
        return page.setRecords(baseMapper.selectRulesPage(page,rules));
    }
 
    @Override
    @Transactional
    public Boolean customizeAdd(RulesVO rulesVO) {
        //保存rules
        boolean saveRules = save(rulesVO);
 
        //condition保存规则id
        rulesVO.getRulesConditionList().forEach(condition->{
            condition.setRuleId(rulesVO.getId().toString());
        });
 
        //批量保存condition
        boolean saveCondition = rulesConditionService.saveBatch(rulesVO.getRulesConditionList());
        return saveRules&&saveCondition;
    }
 
    @Override
    @Transactional
    public Boolean customizeEdit(RulesVO rulesVO) {
        //更新rules
        boolean updateRules = updateById(rulesVO);
 
        RulesCondition rulesCondition = new RulesCondition();
        rulesCondition.setRuleId(rulesVO.getId().toString());
        List<RulesCondition> list = rulesConditionService.list(Condition.getQueryWrapper(rulesCondition));
        list.forEach(e->{
            rulesConditionService.physicDelete(e.getId());
        });
 
        rulesVO.getRulesConditionList().forEach(condition->{
            condition.setRuleId(rulesVO.getId().toString());
            rulesConditionService.save(condition);
        });
        return updateRules;
    }
 
    @Override
    public RulesVO getDetail(String id) {
        RulesVO rulesVO = baseMapper.getDetail(id);
        RulesCondition rulesCondition = new RulesCondition();
        rulesCondition.setRuleId(id);
 
        List<RulesCondition> list = rulesConditionService.list(Condition.getQueryWrapper(rulesCondition).orderByDesc("RELATION"));
        rulesVO.setRulesConditionList(list);
 
        return rulesVO;
    }
 
    @Override
    @Transactional
    public Boolean customizeRemove(String id) {
        boolean removeRule = removeById(id);
        RulesCondition rulesCondition = new RulesCondition();
        rulesCondition.setRuleId(id);
        List<RulesCondition> list = rulesConditionService.list(Condition.getQueryWrapper(rulesCondition));
        boolean removeCondition = removeByIds(list);
        return removeRule&&removeCondition;
    }
}