From 13a7a117bf089a2952b40cdbedb5b9fa195c4e77 Mon Sep 17 00:00:00 2001 From: liquanyu Date: Wed, 25 Apr 2018 15:26:31 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AD=95=E5=A6=87=E5=AD=A6=E6=A0=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/lyms/platform/msg/worker/CourseMsgGenerateWorker.java | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/platform-msg-generate/src/main/java/com/lyms/platform/msg/worker/CourseMsgGenerateWorker.java b/platform-msg-generate/src/main/java/com/lyms/platform/msg/worker/CourseMsgGenerateWorker.java index 330b131..82db1d2 100644 --- a/platform-msg-generate/src/main/java/com/lyms/platform/msg/worker/CourseMsgGenerateWorker.java +++ b/platform-msg-generate/src/main/java/com/lyms/platform/msg/worker/CourseMsgGenerateWorker.java @@ -123,7 +123,7 @@ public class CourseMsgGenerateWorker implements Runnable { PatientsQuery patientsQuery = new PatientsQuery(); patientsQuery.setYn(YnEnums.YES.getId()); patientsQuery.setHospitalId(course.getHospitalId()); - patientsQuery.setLimit(2); + patientsQuery.setLimit(2000); int count = 1; while (true) { @@ -170,13 +170,12 @@ public class CourseMsgGenerateWorker implements Runnable { break; } count++; - Thread.sleep(2000); } list.setMessages(messages); HelperUtils.sendMsg(list); course.setIsSend(1); courseService.updateCourse(course); - } catch (InterruptedException e) { + } catch (Exception e) { logger.info("generateYun error." + course); } } @@ -190,7 +189,7 @@ public class CourseMsgGenerateWorker implements Runnable { PatientsQuery patientsQuery = new PatientsQuery(); patientsQuery.setYn(YnEnums.YES.getId()); patientsQuery.setHospitalId(course.getHospitalId()); - patientsQuery.setLimit(2); + patientsQuery.setLimit(1000); int count = 1; while (true) { @@ -232,13 +231,12 @@ public class CourseMsgGenerateWorker implements Runnable { break; } count++; - Thread.sleep(2000); } list.setMessages(messages); HelperUtils.sendMsg(list); course.setIsSend(1); courseService.updateCourse(course); - } catch (InterruptedException e) { + } catch (Exception e) { logger.info("generateChan error."+course); } } -- 1.8.3.1