|
|
|
@ -152,24 +152,6 @@ public class RiskPersonalServiceImpl implements RiskPersonalService { |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public Connection getConnection() throws SQLException { |
|
|
|
|
|
|
|
return dataSource.getConnection(); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
|
|
|
public void updateBatchScore(List<RiskPersonal> personals) { |
|
|
|
|
|
|
|
List<List<RiskPersonal>> list = IntStream.range(0, (personals.size() + 9999) / 10000) |
|
|
|
|
|
|
|
.mapToObj(i -> personals.subList(i * 10000, Math.min((i + 1) * 10000, personals.size()))) |
|
|
|
|
|
|
|
.toList(); |
|
|
|
|
|
|
|
log.info("开始批量修改: {}", list.size()); |
|
|
|
|
|
|
|
int count = list.size(); |
|
|
|
|
|
|
|
for (List<RiskPersonal> riskPersonals : list) { |
|
|
|
|
|
|
|
batchUpdateData(riskPersonals); |
|
|
|
|
|
|
|
count--; |
|
|
|
|
|
|
|
log.info("进度:{}", count); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void fixed() { |
|
|
|
public void fixed() { |
|
|
|
List<RiskPersonal> personals = repository.list(); |
|
|
|
List<RiskPersonal> personals = repository.list(); |
|
|
|
|