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 394f30c..29fc6e2 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 @@ -8,6 +8,7 @@ import com.lyms.platform.biz.JdbcUtil; import com.lyms.platform.biz.service.*; import com.lyms.platform.common.enums.SieveStatusEnums; import com.lyms.platform.common.enums.YnEnums; +import com.lyms.platform.common.result.BaseResponse; import com.lyms.platform.common.utils.CompressEncodeingUtil; import com.lyms.platform.common.utils.DateUtil; import com.lyms.platform.common.utils.ExceptionUtils; @@ -139,7 +140,7 @@ public class TestController { */ @RequestMapping(value = "/synBuildToPatientService", method = RequestMethod.GET) @ResponseBody - public String synBuildToPatientService( + public BaseResponse synBuildToPatientService( @RequestParam(value = "isSkip") boolean isSkip, @RequestParam(value = "isZjzx") boolean isZjzx ) { @@ -169,16 +170,9 @@ public class TestController { System.out.println("线程处理数据量:"+i+"--至--"+end); commonThreadPool.submit(new BuildSerToPatientSerWorker(i, end,patientsService,patientServiceService,isSkip,isZjzx,batchSize,patientCount)); } - - // for (Future f : listFuture) { - // try { - // f.get(30, TimeUnit.SECONDS); - // } catch (Exception e) { - // ExceptionUtils.catchException(e, "convertToQuanCPatient get result Future error."); - // } - // } - - return "success"; + BaseResponse baseResponse = new BaseResponse(); + baseResponse.setErrormsg("一共需要处理数据量:"+patientCount); + return baseResponse; }