package com.highdatas.mdm.service.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
|
import com.highdatas.mdm.entity.TQualityRule;
|
import com.highdatas.mdm.mapper.TQualityRuleMapper;
|
import com.highdatas.mdm.pojo.CodeMsg;
|
import com.highdatas.mdm.pojo.Result;
|
import com.highdatas.mdm.service.ITQualityRuleService;
|
import com.highdatas.mdm.service.MasterDataService;
|
import com.highdatas.mdm.util.Constant;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.Arrays;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.regex.Pattern;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 规则表 服务实现类
|
* </p>
|
*
|
* @author kimi
|
* @since 2019-12-18
|
*/
|
@Service
|
public class TQualityRuleServiceImpl extends ServiceImpl<TQualityRuleMapper, TQualityRule> implements ITQualityRuleService {
|
|
@Autowired
|
MasterDataService masterDataService;
|
|
@Override
|
public Result rule(String tableName, String field, String ruleId) {
|
if (StringUtils.isEmpty(field)) {
|
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
|
}
|
TQualityRule tQualityRule = selectOne(new EntityWrapper<TQualityRule>().eq("rule_id", ruleId));
|
if (tQualityRule == null) {
|
return Result.error(CodeMsg.SELECT_ERROR_NOTFOUND);
|
}
|
|
String[] split = field.split(Constant.COMMA_TRIM);
|
List<String> collect = Arrays.stream(split).collect(Collectors.toList());
|
Result result = masterDataService.selectList(tableName, collect);
|
JSONObject object = (JSONObject)result.getData();
|
List<Map<String, Object>> datas = (List<Map<String, Object>>) object.get("grid");
|
String codeContent = tQualityRule.getCodeContent();
|
int total = datas.size();
|
int matched = 0;
|
for (Map<String, Object> data : datas) {
|
if (data == null) {
|
continue;
|
}
|
String tableVal = String.valueOf(data.get(field));
|
boolean matches = Pattern.matches(codeContent, tableVal);
|
if (matches) {
|
matched++;
|
}
|
}
|
HashMap<String, Object> resultMap = new HashMap<>();
|
resultMap.put("total", total);
|
resultMap.put("matched", matched);
|
return Result.success(resultMap);
|
}
|
}
|
