From 72432eb95a026c3811bd60e7cb7d3db7d3de0ae2 Mon Sep 17 00:00:00 2001 From: zhangchao Date: Fri, 26 Jul 2024 08:48:57 +0800 Subject: [PATCH] =?UTF-8?q?#fix:=E4=BC=98=E5=8C=96=E4=B8=80=E9=94=AE?= =?UTF-8?q?=E5=8F=91=E9=80=81=E5=B0=8F=E7=A8=8B=E5=BA=8F=E5=8D=87=E7=BA=A7?= =?UTF-8?q?=E6=8F=90=E9=86=92?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../operate/web/facade/PatientServiceFacade.java | 69 ++++++++++++---------- 1 file changed, 37 insertions(+), 32 deletions(-) diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientServiceFacade.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientServiceFacade.java index ef0294c..30c3135 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientServiceFacade.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientServiceFacade.java @@ -609,43 +609,48 @@ public class PatientServiceFacade { return baseResponse; } - public void sendMsg(String hospitalId) { + public void sendMsg(final String hospitalId) { PatientsQuery patientsQuery = new PatientsQuery(); patientsQuery.setYn(1); + patientsQuery.setType(1); patientsQuery.setHospitalId(hospitalId); - List list = patientsService.queryPatient(patientsQuery); + final List list = patientsService.queryPatient(patientsQuery); if (CollectionUtils.isNotEmpty(list)) { - List messages = new ArrayList<>(); - for (Patients patients : list) { - Organization organization = organizationService.getOrganization(Integer.valueOf(patients.getHospitalId())); - if (organization != null) { - MsgRequest mr = new MsgRequest(); - mr.setPhone(patients.getPhone()); - mr.setTypeId(ProjectTypeEnums.YNXT.getId()); - mr.setStatus(SmsStatusEnums.WFS.getId()); - mr.setHospitalId(patients.getHospitalId()); - mr.setTempId(patients.getId()); - mr.setPatientId(patients.getId()); - mr.setSmsStatus(SmsStatusEnums.WFS.getId()); - mr.setServiceType(1); //判断发送类型 - mr.setFirst("系统已更新，请刷新小程序进行体验");// - mr.setObjType(1); - mr.setSubTypeId(SmsServiceEnums.FWKT.getId()); - mr.setKeyword1(organization.getName());// - //planTime 和 timeType为必填 否则推送中心会推送异常 - mr.setTimeType(SmsTimeTypeEnums.ONTIME.getId()); - mr.setPlanTime(DateUtil.getyyyy_MM_dd_hms(new Date())); - mr.setKeyword2("产科（系统已更新，请刷新小程序进行体验）"); - mr.setRemark(patients.getUsername()); - mr.setCreated(DateUtil.getyyyy_MM_dd_hms(new Date())); - mr.setWxTempId("tx-UmDE3YMqYgAeFccXB7HIlTuG_tiP9LMdX2bvBpus"); - messages.add(mr); + commonThreadPool.execute(new Runnable() { + @Override + public void run() { + List messages = new ArrayList<>(); + Organization organization = organizationService.getOrganization(Integer.valueOf(hospitalId)); + for (Patients patients : list) { + if (organization != null) { + MsgRequest mr = new MsgRequest(); + mr.setPhone(patients.getPhone()); + mr.setTypeId(ProjectTypeEnums.YNXT.getId()); + mr.setStatus(SmsStatusEnums.WFS.getId()); + mr.setHospitalId(patients.getHospitalId()); + mr.setTempId(patients.getId()); + mr.setPatientId(patients.getId()); + mr.setSmsStatus(SmsStatusEnums.WFS.getId()); + mr.setServiceType(1); //判断发送类型 + mr.setFirst("系统已更新，请刷新小程序进行体验");// + mr.setObjType(1); + mr.setSubTypeId(SmsServiceEnums.FWKT.getId()); + mr.setKeyword1(organization.getName());// + //planTime 和 timeType为必填 否则推送中心会推送异常 + mr.setTimeType(SmsTimeTypeEnums.ONTIME.getId()); + mr.setPlanTime(DateUtil.getyyyy_MM_dd_hms(new Date())); + mr.setKeyword2("产科（系统已更新，请刷新小程序进行体验）"); + mr.setRemark(patients.getUsername()); + mr.setCreated(DateUtil.getyyyy_MM_dd_hms(new Date())); + mr.setWxTempId("tx-UmDE3YMqYgAeFccXB7HIlTuG_tiP9LMdX2bvBpus"); + messages.add(mr); + } + } + if (CollectionUtils.isNotEmpty(messages)){ + smsConfigFacade.saveMsg(messages, hospitalId); + } } - } - if (CollectionUtils.isNotEmpty(messages)){ - smsConfigFacade.saveMsg(messages, hospitalId); - } - + }); } } -- 1.8.3.1