From 17e13c2532f67052b89f73ecb00f7fa067da4e80 Mon Sep 17 00:00:00 2001 From: kami <605128600@qq.com> Date: Wed, 25 Dec 2024 15:47:02 +0800 Subject: [PATCH] =?UTF-8?q?=E6=89=93=E5=88=86oom?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/RiskScoreRuleServiceImpl.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/biutag/supervisiondata/service/impl/RiskScoreRuleServiceImpl.java b/src/main/java/com/biutag/supervisiondata/service/impl/RiskScoreRuleServiceImpl.java index 227693e..e1e5660 100644 --- a/src/main/java/com/biutag/supervisiondata/service/impl/RiskScoreRuleServiceImpl.java +++ b/src/main/java/com/biutag/supervisiondata/service/impl/RiskScoreRuleServiceImpl.java @@ -57,8 +57,8 @@ public class RiskScoreRuleServiceImpl implements RiskScoreRuleService { .select(Model::getId, Model::getRiskScoreRuleId)); Map modelMap = models.stream().collect(Collectors.toMap(Model::getRiskScoreRuleId, Function.identity(), (oldValue, newValue) -> newValue)); - List> personals = IntStream.range(0, (riskPersonals.size() + 99999) / 100000) - .mapToObj(i -> riskPersonals.subList(i * 100000, Math.min((i + 1) * 100000, riskPersonals.size()))) + List> personals = IntStream.range(0, (riskPersonals.size() + 9999) / 10000) + .mapToObj(i -> riskPersonals.subList(i * 10000, Math.min((i + 1) * 10000, riskPersonals.size()))) .toList(); log.info("本次打分将对{}人进行算分,分{}批进行", riskPersonals.size(), personals); calc(personals, weight, rulesV1, ruleMap, modelMap); @@ -83,7 +83,7 @@ public class RiskScoreRuleServiceImpl implements RiskScoreRuleService { clue.setScoreResult(update.getScoreResult()); } log.info("第{}批修改得分数量{}条", i, updates.size()); - riskModelTaskClueRepository.updateBatchById(updates, 100000); + riskModelTaskClueRepository.updateBatchById(updates, 10000); log.info("第{}批开始算分", i); Map>> clueMap = new HashMap<>();