package jnpf.message.util; import cn.hutool.core.util.ObjectUtil; import com.alibaba.fastjson.JSONObject; import jnpf.base.SmsModel; import jnpf.base.SynThirdInfoApi; import jnpf.base.SysConfigApi; import jnpf.base.UserInfo; import jnpf.base.entity.SynThirdInfoEntity; import jnpf.base.entity.SysConfigEntity; import jnpf.base.model.synthirdinfo.DingTalkModel; import jnpf.config.ConfigValueUtil; import jnpf.constant.MsgCode; import jnpf.message.entity.*; import jnpf.message.mapper.*; import jnpf.message.model.EmailModel; import jnpf.model.SocialsSysConfig; import jnpf.permission.UserApi; import jnpf.permission.entity.UserEntity; import jnpf.util.DateUtil; import jnpf.util.JsonUtil; import jnpf.util.RandomUtil; import jnpf.util.StringUtil; import jnpf.util.message.SmsUtil; import jnpf.util.third.DingTalkUtil; import jnpf.util.third.QyWebChatUtil; import lombok.extern.slf4j.Slf4j; import org.apache.commons.text.StringSubstitutor; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.nio.charset.StandardCharsets; import java.util.*; import java.util.regex.Pattern; /** * 消息实体类 * * @版本： V3.2.0 * @版权： 引迈信息技术有限公司（https://www.jnpfsoft.com） * @作者： JNPF开发平台组 * @日期： 2021/4/22 9:06 */ @Component @Slf4j public class SentMessageUtil { @Autowired private ConfigValueUtil configValueUtil; @Autowired private SysConfigApi sysconfigService; @Autowired private UserApi userApi; @Autowired private SynThirdInfoApi synThirdInfoApi; @Autowired private AccountConfigMapper accountConfigMapper; @Autowired private MessageTemplateConfigMapper messageTemplateConfigMapper; @Autowired private MessageMonitorMapper messageMonitorMapper; @Autowired private SmsFieldMapper smsFieldMapper; @Autowired private ShortLInkMapper shortLInkMapper; /** * 发送企业微信消息 * * @param toUserIdsList * @param userInfo * @param sendType * @param entity * @param parameterMap * @return */ public JSONObject SendQyWebChat(List toUserIdsList, UserInfo userInfo, String sendType, SendConfigTemplateEntity entity, Map parameterMap, Map contentMsg) { MessageTemplateConfigEntity msgTemEntity = messageTemplateConfigMapper.getInfo(entity.getTemplateId()); JSONObject retJson = new JSONObject(); boolean code = true; StringBuilder error = new StringBuilder(); // 获取接收人员的企业微信号、创建消息用户实体 for (String userId : toUserIdsList) { error = new StringBuilder(); MessageMonitorEntity monitorEntity = new MessageMonitorEntity(); monitorEntity.setId(RandomUtil.uuId()); monitorEntity.setSendTime(DateUtil.getNowDate()); monitorEntity.setCreatorTime(DateUtil.getNowDate()); monitorEntity.setCreatorUserId(userInfo.getUserId()); if (StringUtil.isEmpty(userId)) { code = false; error = error.append("；").append("接收人为空！"); messageMonitorMapper.create(monitorEntity); continue; } monitorEntity.setReceiveUser(userId); UserEntity userEntity = userApi.getInfoById(userId); if (ObjectUtil.isEmpty(userEntity)) { code = false; error = error.append("；").append("用户不存在！"); messageMonitorMapper.create(monitorEntity); continue; } if (msgTemEntity != null) { //获取消息模板参数 Map msgMap = getParamMap(entity.getId(), parameterMap); // 替换参数 String content = msgTemEntity.getContent(); String msg = contentMsg.get(userId) != null ? contentMsg.get(userId) : "{}"; byte[] bytes = msg.getBytes(StandardCharsets.UTF_8); String encode = Base64.getEncoder().encodeToString(bytes); //流程审批页面链接地址 String pcLink = "/workFlowDetail?config=" + encode; String appLink = "/pages/workFlow/flowBefore/index?config=" + encode; //转换为短链 String shortLink = shortLInkMapper.shortLink(pcLink + userId + msgTemEntity.getMessageType()); shortLink = getShortLink(pcLink, userId, shortLink, msgTemEntity.getMessageType()); String msgTC = msgTemEntity.getTitle() + msgTemEntity.getContent(); if (StringUtil.isNotBlank(msgTC)) { if (msgTC.contains("{@FlowLink}")) { //链接数据保存 this.saveShortLink(pcLink, appLink, shortLink, userInfo, userId, msg); } } String link = configValueUtil.getApiDomain() + "/api/message/ShortLink/" + shortLink; if (StringUtil.isNotBlank(userInfo.getTenantId())) { link = link + "/" + userInfo.getTenantId(); } if (StringUtil.isNotEmpty(content)) { if (content.contains("{@FlowLink}")) { content = content.replace("{@FlowLink}", link + " "); } StringSubstitutor strSubstitutor = new StringSubstitutor(msgMap, "{", "}"); content = strSubstitutor.replace(content); } // 替换参数 String title = msgTemEntity.getTitle(); if (StringUtil.isNotEmpty(title)) { if (title.contains("{@FlowLink}")) { title = title.replace("{@FlowLink}", link + " "); } StringSubstitutor strSubstitutor = new StringSubstitutor(msgMap, "{", "}"); title = strSubstitutor.replace(title); } title = systemParam(parameterMap, contentMsg, title, userInfo); content = systemParam(parameterMap, contentMsg, content, userInfo); monitorEntity.setTitle(title); monitorEntity.setContent(content); // 获取系统配置 SocialsSysConfig config = sysconfigService.getSocialsConfig(); String corpId = config.getQyhCorpId(); String agentId = config.getQyhAgentId(); // 获取的应用的Secret值(某个修复导致俩个秘钥反了，只能反正修复了) String corpSecret = config.getQyhCorpSecret(); String wxUserId = ""; StringBuilder toWxUserId = new StringBuilder(); String toUserIdAll = ""; StringBuilder nullUserInfo = new StringBuilder(); List messageReceiveList = new ArrayList<>(); // 相关参数验证 if (StringUtil.isEmpty(corpId)) { log.error("企业ID为空"); code = false; error = error.append("；").append(userEntity.getRealName() + "：企业ID为空！"); messageMonitorMapper.create(monitorEntity); continue; } if (StringUtil.isEmpty(corpSecret)) { code = false; error = error.append("；").append(userEntity.getRealName() + "：Secret为空！"); messageMonitorMapper.create(monitorEntity); continue; } if (StringUtil.isEmpty(agentId)) { code = false; error = error.append("；").append(userEntity.getRealName() + "：AgentId为空！"); messageMonitorMapper.create(monitorEntity); continue; } if (StringUtil.isEmpty(content)) { code = false; error = error.append("；").append(userEntity.getRealName() + "：内容为空！"); messageMonitorMapper.create(monitorEntity); continue; } // 创建消息实体 MessageEntity messageEntity = JnpfMessageUtil.setMessageEntity(userInfo.getUserId(), content, null, Integer.parseInt(sendType)); //创建消息监控 monitorEntity = createMessageMonitor(monitorEntity, msgTemEntity, null, content, userInfo, null, title); // 获取接收人员的企业微信号、创建消息用户实体 // for (String userId : toUserIdsList) { wxUserId = ""; // 从同步表获取对应的企业微信ID SynThirdInfoEntity synThirdInfoEntity = synThirdInfoApi.getInfoBySysObjId("1", "2", userId, userInfo.getTenantId()); if(synThirdInfoEntity == null){ synThirdInfoEntity = synThirdInfoApi.getInfoBySysObjId("11", "2", userId, userInfo.getTenantId()); } if (synThirdInfoEntity != null) { wxUserId = synThirdInfoEntity.getThirdObjId(); } if (StringUtil.isEmpty(wxUserId)) { nullUserInfo = nullUserInfo.append(",").append(userId); } else { toWxUserId = toWxUserId.append("|").append(wxUserId); } messageReceiveList.add(JnpfMessageUtil.setMessageReceiveEntity(userId, title, Integer.valueOf(sendType))); // } // 处理企业微信号信息串并验证 toUserIdAll = toWxUserId.toString(); if (StringUtil.isNotEmpty(toUserIdAll)) { toUserIdAll = toUserIdAll.substring(1); } if (StringUtil.isEmpty(toUserIdAll)) { code = false; error = error.append("；").append(userEntity.getRealName() + "：接收人对应的企业微信号全部为空！"); messageMonitorMapper.create(monitorEntity); continue; } // 发送企业信息信息 retJson = QyWebChatUtil.sendWxMessage(corpId, corpSecret, agentId, toUserIdAll, content); if (!retJson.getBoolean("code")) { code = false; error = error.append("；").append(userEntity.getRealName() + "：" + retJson.get("error")); messageMonitorMapper.create(monitorEntity); continue; } // 批量发送企业信息信息 // retJson = QyWebChatUtil.sendWxMessage(corpId, corpSecret, agentId, toUserIdAll, content); // messageMonitorMapper.create(monitorEntity); // if (!retJson.getBoolean("code")) { // return retJson; // } // 企业微信号为空的信息写入备注 if (StringUtil.isNotEmpty(nullUserInfo.toString())) { messageEntity.setExcerpt(nullUserInfo.substring(1) + "对应的企业微信号为空"); } messageMonitorMapper.create(monitorEntity); continue; } else { code = false; error = error.append("；").append(userEntity.getRealName() + "：消息模板数据不存在！"); messageMonitorMapper.create(monitorEntity); continue; } } if (code) { retJson.put("code", true); retJson.put("error", MsgCode.SU012.get()); } else { String msg = error.toString(); if (StringUtil.isNotBlank(msg)) { msg = msg.substring(1); } retJson.put("code", false); retJson.put("error", msg); } return retJson; } /** * List toUserIdsList, UserInfo userInfo, String sendType, MessageTemplateEntity entity, Map parameterMap * * @param toUserIdsList * @param userInfo * @param sendType * @param entity * @param parameterMap * @return */ public JSONObject SendDingTalk(List toUserIdsList, UserInfo userInfo, String sendType, SendConfigTemplateEntity entity, Map parameterMap, Map contentMsg) { MessageTemplateConfigEntity msgTemEntity = messageTemplateConfigMapper.getInfo(entity.getTemplateId()); boolean code = true; StringBuilder error = new StringBuilder(); JSONObject retJson = new JSONObject(); for (String userId : toUserIdsList) { error = new StringBuilder(); //消息监控 MessageMonitorEntity monitorEntity = new MessageMonitorEntity(); monitorEntity.setId(RandomUtil.uuId()); monitorEntity.setSendTime(DateUtil.getNowDate()); monitorEntity.setCreatorTime(DateUtil.getNowDate()); monitorEntity.setCreatorUserId(userInfo.getUserId()); monitorEntity.setReceiveUser(userId); if (StringUtil.isEmpty(userId)) { code = false; error = error.append("；").append("接收人为空!"); messageMonitorMapper.create(monitorEntity); continue; } UserEntity userEntity = userApi.getInfoByIdInMessage(userId); if (ObjectUtil.isEmpty(userEntity)) { code = false; error = error.append("；").append("用户不存在！"); messageMonitorMapper.create(monitorEntity); continue; } if (msgTemEntity != null) { String content = msgTemEntity.getContent(); //获取消息模板参数 Map msgMap = getParamMap(entity.getId(), parameterMap); //转换链接 String msg = contentMsg.get(userId) != null ? contentMsg.get(userId) : "{}"; byte[] bytes = msg.getBytes(StandardCharsets.UTF_8); String encode = Base64.getEncoder().encodeToString(bytes); //流程审批页面链接地址 String pcLink = "/workFlowDetail?config=" + encode; String appLink = "/pages/workFlow/flowBefore/index?config=" + encode; //转换为短链 String shortLink = shortLInkMapper.shortLink(pcLink + userId + msgTemEntity.getMessageType()); shortLink = getShortLink(pcLink, userId, shortLink, msgTemEntity.getMessageType()); String msgTC = msgTemEntity.getTitle() + msgTemEntity.getContent(); if (StringUtil.isNotBlank(msgTC)) { if (msgTC.contains("{@FlowLink}")) { //链接数据保存 this.saveShortLink(pcLink, appLink, shortLink, userInfo, userId, msg); } } String link = configValueUtil.getApiDomain() + "/api/message/ShortLink/" + shortLink; if (StringUtil.isNotBlank(userInfo.getTenantId())) { link = link + "/" + userInfo.getTenantId(); } if (StringUtil.isNotEmpty(content)) { if (content.contains("{@FlowLink}")) { content = content.replace("{@FlowLink}", link + " "); } StringSubstitutor strSubstitutor = new StringSubstitutor(msgMap, "{", "}"); content = strSubstitutor.replace(content); } // 替换参数 String title = msgTemEntity.getTitle(); if (StringUtil.isNotEmpty(title)) { if (title.contains("{@FlowLink}")) { title = title.replace("{@FlowLink}", link + " "); } StringSubstitutor strSubstitutor = new StringSubstitutor(msgMap, "{", "}"); title = strSubstitutor.replace(title); } title = systemParam(parameterMap, contentMsg, title, userInfo); content = systemParam(parameterMap, contentMsg, content, userInfo); monitorEntity.setTitle(title); monitorEntity.setContent(content); Map objModel = getSystemConfig(); DingTalkModel dingTalkModel = JsonUtil.getJsonToBean(objModel, DingTalkModel.class); String appKey = dingTalkModel.getDingSynAppKey(); String appSecret = dingTalkModel.getDingSynAppSecret(); String agentId = dingTalkModel.getDingAgentId(); String dingUserId = ""; StringBuilder toDingUserId = new StringBuilder(); String toUserIdAll = ""; StringBuilder nullUserInfo = new StringBuilder(); List messageReceiveList = new ArrayList<>(); // 相关参数验证 if (StringUtil.isEmpty(appKey)) { code = false; error = error.append("；").append(userEntity.getRealName() + "：AppKey为空!"); messageMonitorMapper.create(monitorEntity); continue; } if (StringUtil.isEmpty(appSecret)) { code = false; error = error.append("；").append(userEntity.getRealName() + "：AppSecret为空!"); messageMonitorMapper.create(monitorEntity); continue; } if (StringUtil.isEmpty(agentId)) { code = false; error = error.append("；").append(userEntity.getRealName() + "：AgentId为空!"); messageMonitorMapper.create(monitorEntity); continue; } if (StringUtil.isEmpty(content)) { code = false; error = error.append("；").append(userEntity.getRealName() + "：AgentId为空!"); messageMonitorMapper.create(monitorEntity); continue; } // 创建消息实体 MessageEntity messageEntity = JnpfMessageUtil.setMessageEntity(userInfo.getUserId(), content, null, Integer.parseInt(sendType)); //创建消息监控 monitorEntity = createMessageMonitor(monitorEntity, msgTemEntity, null, content, userInfo, null, title); // 获取接收人员的钉钉号、创建消息用户实体 // for (String userId : toUserIdsList) { dingUserId = ""; dingUserId = ""; // 从同步表获取对应用户的钉钉ID SynThirdInfoEntity synThirdInfoEntity = synThirdInfoApi.getInfoBySysObjId("2", "2", userId, userInfo.getTenantId()); if(synThirdInfoEntity == null){ synThirdInfoEntity = synThirdInfoApi.getInfoBySysObjId("22", "2", userId, userInfo.getTenantId()); } if (synThirdInfoEntity != null) { dingUserId = synThirdInfoEntity.getThirdObjId(); } if (StringUtil.isEmpty(dingUserId)) { nullUserInfo = nullUserInfo.append(",").append(userId); } else { toDingUserId = toDingUserId.append(",").append(dingUserId); } messageReceiveList.add(JnpfMessageUtil.setMessageReceiveEntity(userId, title, Integer.valueOf(sendType))); // 处理接收人员的钉钉号信息串并验证 toUserIdAll = toDingUserId.toString(); if (StringUtil.isNotEmpty(toUserIdAll)) { toUserIdAll = toUserIdAll.substring(1); } if (StringUtil.isEmpty(toUserIdAll)) { code = false; error = error.append("；").append(userEntity.getRealName() + "：接收人对应的钉钉号为空！"); messageMonitorMapper.create(monitorEntity); continue; } // 发送钉钉信息 retJson = DingTalkUtil.sendDingMessage(appKey, appSecret, agentId, toUserIdAll, content); if (!retJson.getBoolean("code")) { code = false; error = error.append("；").append(userEntity.getRealName() + "：" + retJson.get("error")); messageMonitorMapper.create(monitorEntity); continue; } // 钉钉号为空的信息写入备注 if (StringUtil.isNotEmpty(nullUserInfo.toString())) { messageEntity.setExcerpt(nullUserInfo.toString().substring(1) + "对应的钉钉号为空"); } messageMonitorMapper.create(monitorEntity); continue; } else { code = false; error = error.append("；").append(userEntity.getRealName() + "：消息模板数据不存在"); messageMonitorMapper.create(monitorEntity); continue; } } if (code) { retJson.put("code", true); retJson.put("error", MsgCode.SU012.get()); } else { String msg = error.toString(); if (StringUtil.isNotBlank(msg)) { msg = msg.substring(1); } retJson.put("code", false); retJson.put("error", msg); } return retJson; } /** * 发送邮件 * * @param toUserIdsList * @param userInfo * @param sendType * @param entity * @param parameterMap * @return */ public List SendMail(List toUserIdsList, UserInfo userInfo, String sendType, SendConfigTemplateEntity entity, Map parameterMap, Map contentMsg) { List errList = new ArrayList<>(); MessageTemplateConfigEntity msgTemEntity = messageTemplateConfigMapper.getInfo(entity.getTemplateId()); AccountConfigEntity accountEntity = accountConfigMapper.getInfo(entity.getAccountConfigId()); for (String userId : toUserIdsList) { //消息监控 MessageMonitorEntity monitorEntity = new MessageMonitorEntity(); monitorEntity.setId(RandomUtil.uuId()); monitorEntity.setReceiveUser(JsonUtil.getObjectToString(toUserIdsList)); monitorEntity.setSendTime(DateUtil.getNowDate()); monitorEntity.setCreatorTime(DateUtil.getNowDate()); monitorEntity.setCreatorUserId(userInfo.getUserId()); if (StringUtil.isEmpty(userId)) { log.error("接收人为空"); messageMonitorMapper.create(monitorEntity); errList.add("接收人为空"); continue; } monitorEntity.setReceiveUser(userId); UserEntity userEntity = userApi.getInfoByIdInMessage(userId); if (msgTemEntity != null) { String msg = contentMsg.get(userId) != null ? contentMsg.get(userId) : "{}"; byte[] bytes = msg.getBytes(StandardCharsets.UTF_8); String encode = Base64.getEncoder().encodeToString(bytes); //流程审批页面链接地址 String pcLink = "/workFlowDetail?config=" + encode; String appLink = "/pages/workFlow/flowBefore/index?config=" + encode; //转换为短链 String shortLink = shortLInkMapper.shortLink(pcLink + userId + msgTemEntity.getMessageType()); shortLink = getShortLink(pcLink, userId, shortLink, msgTemEntity.getMessageType()); String msgTC = msgTemEntity.getTitle() + msgTemEntity.getContent(); if (StringUtil.isNotBlank(msgTC)) { if (msgTC.contains("{@FlowLink}")) { //链接数据保存 this.saveShortLink(pcLink, appLink, shortLink, userInfo, userId, msg); } } String link = configValueUtil.getApiDomain() + "/api/message/ShortLink/" + shortLink; if (StringUtil.isNotBlank(userInfo.getTenantId())) { link = link + "/" + userInfo.getTenantId(); } Map msgMap = getParamMap(entity.getId(), parameterMap); // 设置邮件标题 String title = msgTemEntity.getTitle(); if (title.contains("{@FlowLink}")) { title = title.replace("{@FlowLink}", link + " "); } if (StringUtil.isNotEmpty(title)) { StringSubstitutor strSubstitutor = new StringSubstitutor(msgMap, "{", "}"); title = strSubstitutor.replace(title); } // 设置邮件内容 String content = msgTemEntity.getContent(); if (content.contains("{@FlowLink}")) { content = content.replace("{@FlowLink}", link + " "); } //获取消息模板参数 if (StringUtil.isNotEmpty(content)) { StringSubstitutor strSubstitutor = new StringSubstitutor(msgMap, "{", "}"); content = strSubstitutor.replace(content); } title = systemParam(parameterMap, contentMsg, title, userInfo); content = systemParam(parameterMap, contentMsg, content, userInfo); monitorEntity.setTitle(title); monitorEntity.setContent(content); if (accountEntity != null) { // 获取系统配置 Map objModel = new HashMap<>(); objModel.put("emailSmtpHost", accountEntity.getSmtpServer()); objModel.put("emailSmtpPort", accountEntity.getSmtpPort().toString()); objModel.put("emailSenderName", accountEntity.getAddressorName()); objModel.put("emailAccount", accountEntity.getSmtpUser()); objModel.put("emailPassword", accountEntity.getSmtpPassword()); objModel.put("emailSsl", accountEntity.getSslLink().equals(1) ? "true" : "false"); EmailModel emailModel = JsonUtil.getJsonToBean(objModel, EmailModel.class); StringBuilder nullUserInfo = new StringBuilder(); List messageReceiveList = new ArrayList<>(); StringBuilder toUserMail = new StringBuilder(); String userEmailAll = ""; String userEmail = ""; String userName = ""; // 相关参数验证 if (StringUtil.isEmpty(emailModel.getEmailSmtpHost())) { log.error("SMTP服务为空"); messageMonitorMapper.create(monitorEntity); errList.add("SMTP服务为空"); continue; } else if (StringUtil.isEmpty(emailModel.getEmailSmtpPort())) { log.error("SMTP端口为空"); messageMonitorMapper.create(monitorEntity); errList.add("SMTP端口为空"); continue; } else if (StringUtil.isEmpty(emailModel.getEmailAccount())) { log.error("发件人邮箱为空"); messageMonitorMapper.create(monitorEntity); errList.add("发件人邮箱为空"); continue; } else if (StringUtil.isEmpty(emailModel.getEmailPassword())) { log.error("发件人密码为空"); messageMonitorMapper.create(monitorEntity); errList.add("发件人密码为空"); continue; } else { // 设置邮件标题 emailModel.setEmailTitle(title); // 设置邮件内容 emailModel.setEmailContent(content); // 创建消息实体 MessageEntity messageEntity = JnpfMessageUtil.setMessageEntity(userInfo.getUserId(), title, emailModel.getEmailContent(), Integer.parseInt(sendType)); //创建消息监控 monitorEntity = createMessageMonitor(monitorEntity, msgTemEntity, accountEntity, content, userInfo, null, title); // 获取收件人的邮箱地址、创建消息用户实体 // for (String userId : toUserIdsList) { if (userEntity != null) { userEmail = StringUtil.isEmpty(userEntity.getEmail()) ? "" : userEntity.getEmail(); userName = userEntity.getRealName(); } if (userEmail != null && !"".equals(userEmail)) { if (EmailUtil.isEmail(userEmail)) { toUserMail = toUserMail.append(",").append(userName).append("<").append(userEmail).append(">"); } } else { nullUserInfo = nullUserInfo.append(",").append(userId); } messageReceiveList.add(JnpfMessageUtil.setMessageReceiveEntity(userId, title, Integer.parseInt(sendType))); // } // 处理接收人员的邮箱信息串并验证 userEmailAll = toUserMail.toString(); if (StringUtil.isNotEmpty(userEmailAll)) { userEmailAll = userEmailAll.substring(1); } if (StringUtil.isEmpty(userEmailAll)) { log.error("接收人对应的邮箱格式错误"); messageMonitorMapper.create(monitorEntity); errList.add("接收人对应的邮箱格式错误"); continue; } else { // 设置接收人员 emailModel.setEmailToUsers(userEmailAll); // 发送邮件 JSONObject retJson = EmailUtil.sendMail(emailModel); messageMonitorMapper.create(monitorEntity); if (!retJson.getBoolean("code")) { log.error("发送失败"); errList.add("发送失败"); continue; } else { // 邮箱地址为空的信息写入备注 if (StringUtil.isNotEmpty(nullUserInfo.toString())) { messageEntity.setExcerpt(nullUserInfo.substring(1) + "对应的邮箱为空"); } continue; // 写入系统的消息表、消息用户表 } } } } continue; } continue; } return errList; } /** * 发送短信 * * @param toUserIdsList * @param entity * @param parameterMap * @return */ public List sendSms(List toUserIdsList, UserInfo userInfo, SendConfigTemplateEntity entity, Map parameterMap, Map contentMsg) { List errList = new ArrayList<>(); //获取短信配置 AccountConfigEntity accountEntity = accountConfigMapper.getInfo(entity.getAccountConfigId()); // 获取消息模板详情 MessageTemplateConfigEntity msgTemEntity = messageTemplateConfigMapper.getInfo(entity.getTemplateId()); for (String toUserId : toUserIdsList) { //消息监控 MessageMonitorEntity monitorEntity = new MessageMonitorEntity(); monitorEntity.setId(RandomUtil.uuId()); monitorEntity.setSendTime(DateUtil.getNowDate()); monitorEntity.setCreatorTime(DateUtil.getNowDate()); monitorEntity.setCreatorUserId(userInfo.getUserId()); monitorEntity.setReceiveUser(toUserId); String msg = contentMsg.get(toUserId) != null ? contentMsg.get(toUserId) : "{}"; byte[] bytes = msg.getBytes(StandardCharsets.UTF_8); String encode = Base64.getEncoder().encodeToString(bytes); //流程审批页面链接地址 //流程审批页面链接地址 String pcLink = "/workFlowDetail?config=" + encode; String appLink = "/pages/workFlow/flowBefore/index?config=" + encode; //转换为短链 String shortLink = shortLInkMapper.shortLink(pcLink + toUserId + msgTemEntity.getMessageType()); shortLink = getShortLink(pcLink, toUserId, shortLink, msgTemEntity.getMessageType()); //发送给用户的链接 String link = configValueUtil.getApiDomain() + "/api/message/ShortLink/" + shortLink; if (StringUtil.isNotBlank(userInfo.getTenantId())) { link = link + "/" + userInfo.getTenantId(); } //转换为短链 if (accountEntity != null) { monitorEntity.setAccountId(accountEntity.getId()); //账号配置——短信 Map objModel = new HashMap<>(16); objModel.put("aliAccessKey", accountEntity.getAppId()); objModel.put("aliSecret", accountEntity.getAppSecret()); objModel.put("tencentSecretId", accountEntity.getAppId()); objModel.put("tencentSecretKey", accountEntity.getAppSecret()); objModel.put("tencentAppId", accountEntity.getSdkAppId()); objModel.put("tencentAppKey", accountEntity.getAppKey()); SmsModel smsConfig = JsonUtil.getJsonToBean(objModel, SmsModel.class); int company = accountEntity.getChannel(); // 组装接受用户 StringBuffer toUserIdList = new StringBuffer(); // for (String toUserId : toUserIdsList) { UserEntity userEntity = userApi.getInfoById(toUserId); if (isPhone(userEntity.getMobilePhone())) { toUserIdList.append(userEntity.getMobilePhone() + ","); } // } //获取消息模板参数 Map msgMap = getParamMap(entity.getId(), parameterMap); // if(parameterMap.containsKey("@flowLink")){ // parameterMap.put("@flowLink",link); // } //短信参数 Map smsMap = new HashMap<>(); if (entity != null) { smsMap = smsFieldMapper.getParamMap(entity.getTemplateId(), msgMap); if (ObjectUtil.isNotEmpty(smsMap)) { if (smsMap.containsValue("@FlowLink")) { //链接数据保存 this.saveShortLink(pcLink, appLink, shortLink, userInfo, toUserId, msg); for (String key : smsMap.keySet()) { if (smsMap.get(key).equals("@FlowLink")) { smsMap.put(key, link + " "); } } } } } // if(smsMap.containsKey("title")) { // smsMap.keySet().removeIf(k -> k.equals("title")); // } if (msgTemEntity != null) { monitorEntity.setMessageTemplateId(msgTemEntity.getId()); String endPoint = ""; if (Objects.equals(1, accountEntity.getChannel())) { endPoint = accountEntity.getEndPoint(); } else if (Objects.equals(2, accountEntity.getChannel())) { endPoint = accountEntity.getZoneName(); } String content = SmsUtil.querySmsTemplateContent(company, smsConfig, endPoint, accountEntity.getZoneParam(), msgTemEntity.getTemplateCode()); if (StringUtil.isNotBlank(content) && !"null".equals(content)) { if (ObjectUtil.isNotEmpty(smsMap) && !"null".equals(smsMap)) { if (Objects.equals(1, accountEntity.getChannel())) { if (content.contains("${")) { for (String key : smsMap.keySet()) { content = content.replace("${" + key + "}", smsMap.get(key).toString()); } } } else if (Objects.equals(2, accountEntity.getChannel())) { if (content.contains("{")) { for (String key : smsMap.keySet()) { content = content.replace("{" + key + "}", smsMap.get(key).toString()); } } } } } //创建消息监控 monitorEntity = createMessageMonitor(monitorEntity, msgTemEntity, accountEntity, content, userInfo, null, null); if (StringUtil.isEmpty(toUserIdList)) { log.error("全部接收人对应的手机号码格式错误"); messageMonitorMapper.create(monitorEntity); errList.add("全部接收人对应的手机号码格式错误"); continue; } SmsUtil.sentSms(company, smsConfig, endPoint, accountEntity.getZoneParam(), toUserIdList.toString(), accountEntity.getSmsSignature(), msgTemEntity.getTemplateCode(), smsMap); messageMonitorMapper.create(monitorEntity); continue; } else { log.error("消息模板数据不存在"); messageMonitorMapper.create(monitorEntity); errList.add("消息模板数据不存在"); continue; } } else { log.error("账号配置数据不存在"); messageMonitorMapper.create(monitorEntity); errList.add("账号配置数据不存在"); continue; } } return errList; } /** * 获取系统配置 */ private Map getSystemConfig() { // 获取系统配置 List configList = sysconfigService.getList("SysConfig"); Map objModel = new HashMap<>(16); for (SysConfigEntity entity : configList) { objModel.put(entity.getFkey(), entity.getValue()); } return objModel; } public static Map getParamMap(String templateId, Map paramMap) { Map map = new HashMap<>(); for (String key : paramMap.keySet()) { if (key.contains(templateId)) { map.put(key.substring(templateId.length()), paramMap.get(key)); } } return map; } public static MessageMonitorEntity createMessageMonitor(MessageMonitorEntity monitorEntity, MessageTemplateConfigEntity msgTemEntity, AccountConfigEntity accountEntity, String content, UserInfo userInfo, List toUserIdsList, String title) { if (msgTemEntity != null) { monitorEntity.setMessageTemplateId(msgTemEntity.getId()); monitorEntity.setMessageSource(msgTemEntity.getMessageSource()); if (StringUtil.isNotBlank(title)) { monitorEntity.setTitle(title); } else { monitorEntity.setTitle(msgTemEntity.getTitle()); } monitorEntity.setMessageType(msgTemEntity.getMessageType()); if ("6".equals(msgTemEntity.getMessageType()) && accountEntity != null) { monitorEntity.setReceiveUser(accountEntity.getWebhookAddress()); } else { if (toUserIdsList != null && toUserIdsList.size() > 0) { monitorEntity.setReceiveUser(JsonUtil.getObjectToString(toUserIdsList)); } } } else { if (StringUtil.isNotBlank(title)) { monitorEntity.setTitle(title); } monitorEntity.setMessageType("1"); } if (accountEntity != null) { monitorEntity.setAccountId(accountEntity.getId()); monitorEntity.setAccountCode(accountEntity.getEnCode()); monitorEntity.setAccountName(accountEntity.getFullName()); } monitorEntity.setContent(content); return monitorEntity; } private String getShortLink(String pcLink, String userId, String shortLink, String type) { if (StringUtil.isNotBlank(shortLink)) { ShortLinkEntity entity = shortLInkMapper.getInfoByLink(shortLink); if (entity != null) { if (pcLink.equals(entity.getRealPcLink())) { return shortLink; } else { shortLink = shortLInkMapper.shortLink(pcLink + userId + type); return getShortLink(pcLink, userId, shortLink, type); } } else { return shortLink; } } else { shortLink = shortLInkMapper.shortLink(pcLink + userId + type); return getShortLink(pcLink, userId, shortLink, type); } } public void saveShortLink(String pcLink, String appLink, String shortLink, UserInfo userInfo, String userId, String bodyText) { ShortLinkEntity shortLinkEntity = shortLInkMapper.getInfoByLink(shortLink); if (shortLinkEntity == null) { ShortLinkEntity entity = new ShortLinkEntity(); Map sysConfig = getSystemConfig(); String linkTime = sysConfig.get("linkTime"); Integer isClick = 0; if (StringUtil.isNotBlank(sysConfig.get("isClick")) && !"null".equals(sysConfig.get("isClick"))) { isClick = Integer.parseInt(sysConfig.get("isClick")); } int unClickNum = 20; if (StringUtil.isNotBlank(sysConfig.get("unClickNum")) && !"null".equals(sysConfig.get("unClickNum"))) { unClickNum = Integer.parseInt(sysConfig.get("unClickNum")); } entity.setId(RandomUtil.uuId()); entity.setRealPcLink(pcLink); entity.setRealAppLink(appLink); entity.setShortLink(shortLink); entity.setBodyText(bodyText); // entity.setTenantId(userInfo.getTenantId()); entity.setUserId(userId); entity.setIsUsed(isClick); entity.setUnableNum(unClickNum); entity.setClickNum(0); if (StringUtil.isNotEmpty(linkTime)) { Date unableTime = getUnableTime(linkTime); entity.setUnableTime(unableTime); } else { entity.setUnableTime(DateUtil.dateAddHours(DateUtil.getNowDate(), 24)); } entity.setCreatorTime(DateUtil.getNowDate()); entity.setCreatorUserId(userInfo.getUserId()); shortLInkMapper.insert(entity); } } public static Date getUnableTime(String linkTime) { Double time = Double.parseDouble(linkTime); int second = Double.valueOf(time * 60 * 60).intValue(); Date unableTime = DateUtil.dateAddSeconds(DateUtil.getNowDate(), second); return unableTime; } public static boolean isPhone(String phone) { if (StringUtil.isNotBlank(phone) && !"null".equals(phone)) { return Pattern.matches("^1[3-9]\\d{9}$", phone); } return false; } /** * 系统参数替换 * * @param parameterMap * @param contentMsg * @param title * @param userInfo * @return */ public static String systemParam(Map parameterMap, Map contentMsg, String title, UserInfo userInfo) { if (parameterMap.isEmpty()) { return title = title.replaceAll("\\{@Title}", contentMsg.get("Title") != null ? contentMsg.get("Title") : "") .replaceAll("\\{@CreatorUserName}", userInfo.getUserName()) .replaceAll("\\{@SendTime}", DateUtil.getNow().substring(11)) .replaceAll("\\{@Content}", contentMsg.get("Content") != null ? contentMsg.get("Content") : "") .replaceAll("\\{@Remark}", contentMsg.get("Remark") != null ? contentMsg.get("Remark") : "") .replaceAll("\\{@StartDate}", contentMsg.get("StartDate") != null ? contentMsg.get("StartDate") : "") .replaceAll("\\{@StartTime}", contentMsg.get("StartTime") != null ? contentMsg.get("StartTime") : "") .replaceAll("\\{@EndDate}", contentMsg.get("EndDate") != null ? contentMsg.get("EndDate") : "") .replaceAll("\\{@FlowLink}", "") .replaceAll("\\{@EndTime}", contentMsg.get("EndTime") != null ? contentMsg.get("EndTime") : ""); } return title; } }