diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java index 04fec2d..67043b9 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java @@ -4330,7 +4330,7 @@ public class TestController extends BaseController { { System.out.println(org.getId()+org.getName()); int page = 1; - int limit = 2000; + int limit = 500; while (true) { AntExRecordQuery antExRecordQuery = new AntExRecordQuery(); @@ -4341,41 +4341,23 @@ public class TestController extends BaseController { List antExRecordModelList = recordService.queryAntExRecords(antExRecordQuery); page++; if (CollectionUtils.isNotEmpty(antExRecordModelList)) { - int batchSize = 500; - int end = 0; - for (int i = 0; i < antExRecordModelList.size(); i += batchSize) { - end = (end + batchSize); - if (end > antExRecordModelList.size()) { - end = antExRecordModelList.size(); - } - System.out.println("start:" + i + ",end:" + end); - final List tempList = antExRecordModelList.subList(i, end); - - commonThreadPool.execute(new Runnable() { - @Override - public void run() { - if (CollectionUtils.isNotEmpty(tempList)) { - for (AntExRecordModel antExRecordModel : tempList) { - if (StringUtils.isNotEmpty(antExRecordModel.getParentId())) { - Patients pats = patientsService.findOnePatientById(antExRecordModel.getParentId()); - if (pats != null) - { - if (pats.getType() != null && pats.getType() == 3) - { - AntExRecordModel dbmodel = new AntExRecordModel(); - dbmodel.setDueStatus(1); - dbmodel.setId(antExRecordModel.getId()); - recordService.updateOne(dbmodel, antExRecordModel.getId()); - System.out.println(antExRecordModel.getId()); - } - } - } - } + for (AntExRecordModel antExRecordModel : antExRecordModelList) { + if (StringUtils.isNotEmpty(antExRecordModel.getParentId())) { + Patients pats = patientsService.findOnePatientById(antExRecordModel.getParentId()); + if (pats != null) + { + if (pats.getType() != null && pats.getType() == 3) + { + AntExRecordModel dbmodel = new AntExRecordModel(); + dbmodel.setDueStatus(1); + dbmodel.setId(antExRecordModel.getId()); + recordService.updateOne(dbmodel, antExRecordModel.getId()); + System.out.println(antExRecordModel.getId()); } - } - }); + } } + } else {