LK/income_payments_management
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

定时任务修改

Browse Source
This commit is contained in:
梁琦涛
2021-11-05 00:02:16 +08:00
parent a13f8ac472
commit be1c42894b
1 changed files with 23 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files
jero-boot-incoming-payment/src/main/java/com/jero/quartz/job/RemindersAllJob.java
+23 -18
View File
@@ -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){