消息修改

This commit is contained in:
梁琦涛
2021-10-09 18:43:58 +08:00
parent a42027d974
commit 83f839d5d6
2 changed files with 23 additions and 14 deletions
@@ -5,6 +5,8 @@ import java.util.*;
import java.util.stream.Collectors;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.jero.common.api.vo.Result;
@@ -322,6 +324,9 @@ public class PayWorkingGroupSubItemController extends JeroController<PayWorkingG
sendMessageDTO.setTemplateCode(CompanyMessageEnums.MSG11.getCode());
sendMessageDTO.setTemplateParam(map);
sendMessageDTO.setBusType("C_OPEN_TYPE11");
JSONObject json = new JSONObject();
json.put("id",p.getId());
sendMessageDTO.setBusId(json.toJSONString());
sendMessageService.SendMessageService(sendMessageDTO);
});
return Result.OK("添加成功!");
@@ -1,5 +1,6 @@
package com.jero.quartz.job;
import com.alibaba.fastjson.JSONObject;
import com.jero.common.common.ProjectCommon;
import com.jero.common.dto.SendMessageDTO;
import com.jero.common.enums.CompanyMessageEnums;
@@ -38,20 +39,23 @@ public class RemindersAllJob implements Job {
list.forEach(p->{
log.info(p.getChargeProject() + "=============发送消息");
// 发送消息
// 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);
// sendMessageService.SendMessageService(sendMessageDTO);
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());
sendMessageService.SendMessageService(sendMessageDTO);
});
}
}