jiangjiazhi / regional-platform

Download as
Browse Code »

Commit 508b247535200df49fea203a2d9d5213be129533

Authored by yangfei
1 parent 98c8411937
Exists in master and in 6 other branches autism, dev, fengning, fengning2023-06-06, longhua, luanping

服务同步

Showing 2 changed files with 8 additions and 3 deletions

platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java View file @ 508b247
... ... @@ -154,7 +154,7 @@
154 154 int patientCount = patientsService.queryPatientCount(patientsQuery);
155 155 System.out.println("一共需要处理数据量："+patientCount);
156 156  
157   - //预计开启10个线程处理，计算每个线程需要处理的数据量
  157 + //预计开启5个线程处理，计算每个线程需要处理的数据量
158 158 int batchSize = patientCount/5;
159 159 int end = 0;
160 160 List<Future> listFuture = new ArrayList<>();
platform-operate-api/src/main/java/com/lyms/platform/operate/web/worker/BuildSerToPatientSerWorker.java View file @ 508b247
... ... @@ -55,9 +55,14 @@
55 55 public Object call() {
56 56 try {
57 57 for (int i = startIndex; i < endIndex; i += batchSize) {
58   - System.out.println("总数据量："+allCount+"，正在处理第：" + i+"--到--"+(i+batchSize));
59 58 PatientsQuery patientsQuery = new PatientsQuery();
60   - patientsQuery.setLimit(batchSize);
  59 + if(i+batchSize>endIndex){
  60 + patientsQuery.setLimit(endIndex-i);
  61 + }else{
  62 + patientsQuery.setLimit(batchSize);
  63 + }
  64 + System.out.println("总数据量："+allCount+"，正在处理第：" + i+"--到--"+(i+batchSize)+",limit:"+patientsQuery.getLimit());
  65 +
61 66 patientsQuery.setPage((i + batchSize) / batchSize);
62 67 //排查本院隐藏建档
63 68 patientsQuery.setExtEnable(false);