Browse Source

打分oom

master
kami 1 year ago
parent
commit
24459201fc
  1. 3
      src/main/java/com/biutag/supervisiondata/service/impl/RiskScoreRuleServiceImpl.java

3
src/main/java/com/biutag/supervisiondata/service/impl/RiskScoreRuleServiceImpl.java

@ -48,6 +48,7 @@ public class RiskScoreRuleServiceImpl implements RiskScoreRuleService {
} }
log.info("开始查询风险人员"); log.info("开始查询风险人员");
List<RiskPersonal> riskPersonals = personalRepository.list(queryWrapper); List<RiskPersonal> riskPersonals = personalRepository.list(queryWrapper);
log.info("共{}人", riskPersonals.size());
List<RiskScoreRule> rules = riskScoreRuleRepository.list(new LambdaQueryWrapper<>()); List<RiskScoreRule> rules = riskScoreRuleRepository.list(new LambdaQueryWrapper<>());
List<RiskScoreRule> rulesV1 = rules.stream().filter(item -> item.getLevel() == 1).toList(); List<RiskScoreRule> rulesV1 = rules.stream().filter(item -> item.getLevel() == 1).toList();
@ -60,7 +61,7 @@ public class RiskScoreRuleServiceImpl implements RiskScoreRuleService {
List<List<RiskPersonal>> personals = IntStream.range(0, (riskPersonals.size() + 9999) / 10000) List<List<RiskPersonal>> personals = IntStream.range(0, (riskPersonals.size() + 9999) / 10000)
.mapToObj(i -> riskPersonals.subList(i * 10000, Math.min((i + 1) * 10000, riskPersonals.size()))) .mapToObj(i -> riskPersonals.subList(i * 10000, Math.min((i + 1) * 10000, riskPersonals.size())))
.toList(); .toList();
log.info("本次打分将对{}人进行算分,分{}批进行", riskPersonals.size(), personals); log.info("本次打分将对{}人进行算分,分{}批进行", riskPersonals.size(), personals.size());
calc(personals, weight, rulesV1, ruleMap, modelMap); calc(personals, weight, rulesV1, ruleMap, modelMap);
} }

Loading…
Cancel
Save