perf:调整导入流程的条数

This commit is contained in:
曾文豪
2023-04-10 16:48:02 +08:00
parent a32c333a6c
commit c33ad6075e

View File

@@ -85,9 +85,9 @@ public class CoreLogService extends TsServiceBase<CoreLogOperationMapper, CoreLo
CollUtil.split(list, 100).forEach((it) -> { CollUtil.split(list, 100).forEach((it) -> {
int accept = consumer.accept(it); int accept = consumer.accept(it);
coreLogProcess.setSuccessNum(coreLogProcess.getSuccessNum() + accept); coreLogProcess.setSuccessNum(coreLogProcess.getSuccessNum() + accept);
coreLogProcess.setFailNum(coreLogProcess.getFailNum() + 100 - accept); coreLogProcess.setFailNum(coreLogProcess.getFailNum() + it.size() - accept);
if (coreLogProcess.getFailNum() + coreLogProcess.getSuccessNum() == list.size()) { if (coreLogProcess.getFailNum() + coreLogProcess.getSuccessNum() >= list.size()) {
coreLogProcess.setFailFile(consumer.getFailFile()); coreLogProcess.setFailFile(consumer.getFailFile());
coreLogProcess.setStatus(1); coreLogProcess.setStatus(1);
} }