Commit 72432eb95a026c3811bd60e7cb7d3db7d3de0ae2
1 parent
1086a68246
Exists in
dev
#fix:优化一键发送小程序升级提醒
Showing 1 changed file with 37 additions and 32 deletions
platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientServiceFacade.java
View file @
72432eb
| ... | ... | @@ -609,43 +609,48 @@ |
| 609 | 609 | return baseResponse; |
| 610 | 610 | } |
| 611 | 611 | |
| 612 | - public void sendMsg(String hospitalId) { | |
| 612 | + public void sendMsg(final String hospitalId) { | |
| 613 | 613 | PatientsQuery patientsQuery = new PatientsQuery(); |
| 614 | 614 | patientsQuery.setYn(1); |
| 615 | + patientsQuery.setType(1); | |
| 615 | 616 | patientsQuery.setHospitalId(hospitalId); |
| 616 | - List<Patients> list = patientsService.queryPatient(patientsQuery); | |
| 617 | + final List<Patients> list = patientsService.queryPatient(patientsQuery); | |
| 617 | 618 | if (CollectionUtils.isNotEmpty(list)) { |
| 618 | - List<MsgRequest> messages = new ArrayList<>(); | |
| 619 | - for (Patients patients : list) { | |
| 620 | - Organization organization = organizationService.getOrganization(Integer.valueOf(patients.getHospitalId())); | |
| 621 | - if (organization != null) { | |
| 622 | - MsgRequest mr = new MsgRequest(); | |
| 623 | - mr.setPhone(patients.getPhone()); | |
| 624 | - mr.setTypeId(ProjectTypeEnums.YNXT.getId()); | |
| 625 | - mr.setStatus(SmsStatusEnums.WFS.getId()); | |
| 626 | - mr.setHospitalId(patients.getHospitalId()); | |
| 627 | - mr.setTempId(patients.getId()); | |
| 628 | - mr.setPatientId(patients.getId()); | |
| 629 | - mr.setSmsStatus(SmsStatusEnums.WFS.getId()); | |
| 630 | - mr.setServiceType(1); //判断发送类型 | |
| 631 | - mr.setFirst("系统已更新，请刷新小程序进行体验");// | |
| 632 | - mr.setObjType(1); | |
| 633 | - mr.setSubTypeId(SmsServiceEnums.FWKT.getId()); | |
| 634 | - mr.setKeyword1(organization.getName());// | |
| 635 | - //planTime 和 timeType为必填 否则推送中心会推送异常 | |
| 636 | - mr.setTimeType(SmsTimeTypeEnums.ONTIME.getId()); | |
| 637 | - mr.setPlanTime(DateUtil.getyyyy_MM_dd_hms(new Date())); | |
| 638 | - mr.setKeyword2("产科（系统已更新，请刷新小程序进行体验）"); | |
| 639 | - mr.setRemark(patients.getUsername()); | |
| 640 | - mr.setCreated(DateUtil.getyyyy_MM_dd_hms(new Date())); | |
| 641 | - mr.setWxTempId("tx-UmDE3YMqYgAeFccXB7HIlTuG_tiP9LMdX2bvBpus"); | |
| 642 | - messages.add(mr); | |
| 619 | + commonThreadPool.execute(new Runnable() { | |
| 620 | + @Override | |
| 621 | + public void run() { | |
| 622 | + List<MsgRequest> messages = new ArrayList<>(); | |
| 623 | + Organization organization = organizationService.getOrganization(Integer.valueOf(hospitalId)); | |
| 624 | + for (Patients patients : list) { | |
| 625 | + if (organization != null) { | |
| 626 | + MsgRequest mr = new MsgRequest(); | |
| 627 | + mr.setPhone(patients.getPhone()); | |
| 628 | + mr.setTypeId(ProjectTypeEnums.YNXT.getId()); | |
| 629 | + mr.setStatus(SmsStatusEnums.WFS.getId()); | |
| 630 | + mr.setHospitalId(patients.getHospitalId()); | |
| 631 | + mr.setTempId(patients.getId()); | |
| 632 | + mr.setPatientId(patients.getId()); | |
| 633 | + mr.setSmsStatus(SmsStatusEnums.WFS.getId()); | |
| 634 | + mr.setServiceType(1); //判断发送类型 | |
| 635 | + mr.setFirst("系统已更新，请刷新小程序进行体验");// | |
| 636 | + mr.setObjType(1); | |
| 637 | + mr.setSubTypeId(SmsServiceEnums.FWKT.getId()); | |
| 638 | + mr.setKeyword1(organization.getName());// | |
| 639 | + //planTime 和 timeType为必填 否则推送中心会推送异常 | |
| 640 | + mr.setTimeType(SmsTimeTypeEnums.ONTIME.getId()); | |
| 641 | + mr.setPlanTime(DateUtil.getyyyy_MM_dd_hms(new Date())); | |
| 642 | + mr.setKeyword2("产科（系统已更新，请刷新小程序进行体验）"); | |
| 643 | + mr.setRemark(patients.getUsername()); | |
| 644 | + mr.setCreated(DateUtil.getyyyy_MM_dd_hms(new Date())); | |
| 645 | + mr.setWxTempId("tx-UmDE3YMqYgAeFccXB7HIlTuG_tiP9LMdX2bvBpus"); | |
| 646 | + messages.add(mr); | |
| 647 | + } | |
| 648 | + } | |
| 649 | + if (CollectionUtils.isNotEmpty(messages)){ | |
| 650 | + smsConfigFacade.saveMsg(messages, hospitalId); | |
| 651 | + } | |
| 643 | 652 | } |
| 644 | - } | |
| 645 | - if (CollectionUtils.isNotEmpty(messages)){ | |
| 646 | - smsConfigFacade.saveMsg(messages, hospitalId); | |
| 647 | - } | |
| 648 | - | |
| 653 | + }); | |
| 649 | 654 | } |
| 650 | 655 | } |
| 651 | 656 |