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 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 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 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){