From be1c42894b2e83c504e89f269b75a83e569c30b0 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=A2=81=E7=90=A6=E6=B6=9B?= <18222067976@163.com>
Date: Fri, 5 Nov 2021 00:02:16 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/jero/quartz/job/RemindersAllJob.java  | 41 +++++++++++--------
 1 file changed, 23 insertions(+), 18 deletions(-)

diff --git a/jero-boot-incoming-payment/src/main/java/com/jero/quartz/job/RemindersAllJob.java b/jero-boot-incoming-payment/src/main/java/com/jero/quartz/job/RemindersAllJob.java
index 5887b1e6..56cb7e82 100644
--- a/jero-boot-incoming-payment/src/main/java/com/jero/quartz/job/RemindersAllJob.java
+++ b/jero-boot-incoming-payment/src/main/java/com/jero/quartz/job/RemindersAllJob.java
@@ -38,25 +38,30 @@ public class RemindersAllJob implements Job {
             List<PayCommonProject> list = projectReceivableNotEqualsPaidService.queryProjectReceivableNotEqualsPaid();
             if(!CollectionUtils.isEmpty(list)){
                 list.forEach(p->{
-                    // 发送消息
-                    SendMessageDTO sendMessageDTO = new SendMessageDTO();
-                    if(!StringUtils.isBlank(p.getEmail())){
-                        sendMessageDTO.setEmail(PasswordUtil.decrypt(p.getEmail()));
+                    log.info(p.getChargeProject() + "=============发送消息");
+                    try {
+                        // 发送消息
+                        SendMessageDTO sendMessageDTO = new SendMessageDTO();
+                        if(!StringUtils.isBlank(p.getEmail())){
+                            sendMessageDTO.setEmail(PasswordUtil.decrypt(p.getEmail()));
+                        }
+                        if(!StringUtils.isBlank(p.getPhone())){
+                            sendMessageDTO.setPhone(PasswordUtil.decrypt(p.getPhone()));
+                            sendMessageDTO.setToUser(PasswordUtil.decrypt(p.getPhone()));
+                        }
+                        HashMap<String,String> map = new HashMap<>();
+                        map.put("projectName",p.getChargeProject());
+                        sendMessageDTO.setFromUser(ProjectCommon.ADMIN);
+                        sendMessageDTO.setTemplateCode(CompanyMessageEnums.MSG11.getCode());
+                        sendMessageDTO.setTemplateParam(map);
+                        JSONObject json = new JSONObject();
+                        json.put("id",p.getId());
+                        sendMessageDTO.setBusId(json.toJSONString());
+                        log.info(p.getChargeProject() + "=============发送消息" + sendMessageDTO);
+                        sendMessageService.SendMessageJobService(sendMessageDTO);
+                    }catch (Exception e){
+                        log.error("消息发送失败：",e);
                     }
-                    if(!StringUtils.isBlank(p.getPhone())){
-                        sendMessageDTO.setPhone(PasswordUtil.decrypt(p.getPhone()));
-                        sendMessageDTO.setToUser(PasswordUtil.decrypt(p.getPhone()));
-                    }
-                    HashMap<String,String> map = new HashMap<>();
-                    map.put("projectName",p.getChargeProject());
-                    sendMessageDTO.setFromUser(ProjectCommon.ADMIN);
-                    sendMessageDTO.setTemplateCode(CompanyMessageEnums.MSG11.getCode());
-                    sendMessageDTO.setTemplateParam(map);
-                    JSONObject json = new JSONObject();
-                    json.put("id",p.getId());
-                    sendMessageDTO.setBusId(json.toJSONString());
-                    log.info(p.getChargeProject() + "=============发送消息" + sendMessageDTO);
-                    sendMessageService.SendMessageJobService(sendMessageDTO);
                 });
             }
         }catch (Exception e){