syn progress

master
yixian 4 years ago
parent 680cf5b070
commit 0bb3a1c687

@ -204,6 +204,7 @@ public class ATOReportServiceImpl implements ATOReportService {
List<Integer> clients = clientMapper.listClientsWithTransactionsSettled(startOfMon.toDate(), endOfMon.toDate()); List<Integer> clients = clientMapper.listClientsWithTransactionsSettled(startOfMon.toDate(), endOfMon.toDate());
if (progress != null) { if (progress != null) {
progress.setMonth(startOfMon, clients); progress.setMonth(startOfMon, clients);
synchronizeProgress();
} }
clients.parallelStream().forEach(clientId -> loadClientMonthTransactions(reportingParty, clientId, startOfMon, endOfMon)); clients.parallelStream().forEach(clientId -> loadClientMonthTransactions(reportingParty, clientId, startOfMon, endOfMon));
} }
@ -231,6 +232,7 @@ public class ATOReportServiceImpl implements ATOReportService {
} }
if (progress != null) { if (progress != null) {
progress.markClientFinished(clientId); progress.markClientFinished(clientId);
synchronizeProgress();
} }
} }

Loading…
Cancel
Save