package jnpf.message.util;
|
|
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.http.HttpRequest;
|
import cn.hutool.http.Method;
|
import com.alibaba.fastjson.JSONObject;
|
import jnpf.base.SysConfigApi;
|
import jnpf.base.UserInfo;
|
import jnpf.base.entity.SysConfigEntity;
|
import jnpf.config.ConfigValueUtil;
|
import jnpf.constant.MsgCode;
|
import jnpf.message.entity.*;
|
import jnpf.message.enums.MessageTypeEnum;
|
import jnpf.message.mapper.*;
|
import jnpf.message.model.SentMessageForm;
|
import jnpf.message.model.TriggerModel;
|
import jnpf.message.model.WxgzhMessageModel;
|
import jnpf.permission.UserApi;
|
import jnpf.permission.entity.UserEntity;
|
import jnpf.util.*;
|
import jnpf.util.wxutil.mp.WXGZHWebChatUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.text.StringSubstitutor;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.nio.charset.StandardCharsets;
|
import java.util.*;
|
import java.util.concurrent.Callable;
|
import java.util.concurrent.Future;
|
import java.util.stream.Collectors;
|
|
@Component
|
@Slf4j
|
public class SendFlowMsgUtil {
|
@Autowired
|
private RedisUtil redisUtil;
|
@Autowired
|
private SentMessageUtil sentMessageUtil;
|
@Autowired
|
private ConfigValueUtil configValueUtil;
|
@Autowired
|
private UserApi userApi;
|
@Autowired
|
private SysConfigApi sysconfigService;
|
|
@Autowired
|
private MessageMapper messageMapper;
|
@Autowired
|
private MessagereceiveMapper messagereceiveMapper;
|
@Autowired
|
private MessageMonitorMapper messageMonitorMapper;
|
@Autowired
|
private SendMessageConfigMapper sendMessageConfigMapper;
|
@Autowired
|
private SendConfigTemplateMapper sendConfigTemplateMapper;
|
@Autowired
|
private MessageTemplateConfigMapper messageTemplateConfigMapper;
|
@Autowired
|
private ShortLInkMapper shortLInkMapper;
|
@Autowired
|
private AccountConfigMapper accountConfigMapper;
|
@Autowired
|
private SmsFieldMapper smsFieldMapper;
|
@Autowired
|
private AuthUtil authUtil;
|
@Autowired
|
private WechatUserMapper wechatUserMapper;
|
|
|
public void sendMessage(SentMessageForm sentMessageForm) {
|
List<String> toUserIdsList = sentMessageForm.getToUserIds();
|
// 模板id
|
String templateId = sentMessageForm.getTemplateId();
|
// 参数
|
Map<String, Object> parameterMap = sentMessageForm.getParameterMap();
|
UserInfo userInfo = sentMessageForm.getUserInfo();
|
boolean flag = true;
|
if (!(toUserIdsList != null && toUserIdsList.size() > 0)) {
|
log.error("接收人员为空");
|
flag = false;
|
}
|
if (StringUtil.isEmpty(templateId)) {
|
log.error("模板Id为空");
|
flag = false;
|
}
|
if (flag) {
|
// 获取发送配置详情
|
// MessageTemplateEntity entity = messageTemplateService.getInfo(templateId);
|
SendMessageConfigEntity entity = sendMessageConfigMapper.getInfoByEnCode(templateId);
|
if (entity != null) {
|
templateId = entity.getId();
|
} else {
|
entity = sendMessageConfigMapper.getInfo(templateId);
|
}
|
if (entity != null) {
|
List<SendConfigTemplateEntity> list = sendConfigTemplateMapper.getDetailListByParentId(templateId);
|
if (list != null && list.size() > 0) {
|
for (SendConfigTemplateEntity entity1 : list) {
|
if (parameterMap.get(entity1.getId() + "@Title") == null) {
|
parameterMap.put(entity1.getId() + "@Title", sentMessageForm.getTitle());
|
}
|
if (parameterMap.get(entity1.getId() + "@CreatorUserName") == null || StringUtil.isEmpty(String.valueOf(parameterMap.get(entity1.getId() + "@CreatorUserName")))) {
|
parameterMap.put(entity1.getId() + "@CreatorUserName", sentMessageForm.getUserInfo().getUserName());
|
}
|
if (parameterMap.get(entity1.getId() + "@SendTime") == null || StringUtil.isEmpty(String.valueOf(parameterMap.get(entity1.getId() + "@SendTime")))) {
|
parameterMap.put(entity1.getId() + "@SendTime", DateUtil.getNow().substring(11));
|
}
|
if (parameterMap.get(entity1.getId() + "@FlowLink") == null) {
|
parameterMap.put(entity1.getId() + "@FlowLink", "");
|
}
|
if ("1".equals(String.valueOf(entity1.getEnabledMark()))) {
|
String sendType = entity1.getMessageType();
|
MessageTypeEnum typeEnum = MessageTypeEnum.getByCode(sendType);
|
Map<String, String> contentMsg = sentMessageForm.getContentMsg();
|
switch (typeEnum) {
|
case SysMessage:
|
// 站内消息、
|
for (String toUserId : toUserIdsList) {
|
List<String> toUser = new ArrayList<>();
|
String content = sentMessageForm.getContent();
|
MessageTemplateConfigEntity templateConfigEntity = messageTemplateConfigMapper.getInfo(entity1.getTemplateId());
|
String title = sentMessageForm.getTitle();
|
String appLink = "";
|
if (templateConfigEntity != null) {
|
title = templateConfigEntity.getTitle();
|
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;
|
appLink = "/pages/workFlow/flowBefore/index?config=" + encode;
|
//转换为短链
|
String shortLink = shortLInkMapper.shortLink(pcLink + toUserId + templateConfigEntity.getMessageType());
|
shortLink = shortLInkMapper.shortLink(pcLink + toUserId + templateConfigEntity.getMessageType());
|
String link = configValueUtil.getApiDomain() + "/api/message/ShortLink/" + shortLink;
|
if (StringUtil.isNotBlank(userInfo.getTenantId())) {
|
link = link + "/" + userInfo.getTenantId();
|
}
|
if (title.contains("{@FlowLink}")) {
|
title = title.replace("{@FlowLink}", link + " ");
|
//链接数据保存
|
sentMessageUtil.saveShortLink(pcLink, appLink, shortLink, userInfo, toUserId, msg);
|
}
|
Map<String, Object> msgMap = new HashMap<>();
|
msgMap = sentMessageUtil.getParamMap(entity1.getId(), parameterMap);
|
if (StringUtil.isNotEmpty(title)) {
|
StringSubstitutor strSubstitutor = new StringSubstitutor(msgMap, "{", "}");
|
title = strSubstitutor.replace(title);
|
}
|
}
|
toUser.add(toUserId);
|
messagereceiveMapper.sentMessage(toUser, title, content, contentMsg, userInfo);
|
//消息监控写入
|
MessageMonitorEntity monitorEntity = new MessageMonitorEntity();
|
monitorEntity.setId(RandomUtil.uuId());
|
monitorEntity.setReceiveUser(JsonUtil.getObjectToString(toUser));
|
monitorEntity.setSendTime(DateUtil.getNowDate());
|
monitorEntity.setCreatorTime(DateUtil.getNowDate());
|
monitorEntity.setCreatorUserId(userInfo.getUserId());
|
sentMessageUtil.createMessageMonitor(monitorEntity, templateConfigEntity, null, null, userInfo, toUser, title);
|
messageMonitorMapper.insert(monitorEntity);
|
}
|
String url = configValueUtil.getApiDomain() + "/api/workflow/trigger/MsgExecute";
|
Map<String, Object> map = new HashMap<>();
|
map.put("id", entity1.getTemplateId());
|
map.put("userInfo", userInfo);
|
HttpRequest request = HttpRequest.of(url).method(Method.POST).body(JsonUtil.getObjectToString(map));
|
request.header(Constants.AUTHORIZATION, userInfo.getToken());
|
request.execute().body();
|
break;
|
case SmsMessage:
|
// 发送短信
|
sentMessageUtil.sendSms(toUserIdsList, userInfo, entity1, parameterMap, contentMsg);
|
break;
|
case MailMessage:
|
// 邮件
|
sentMessageUtil.SendMail(toUserIdsList, userInfo, sendType, entity1, parameterMap, contentMsg);
|
break;
|
case QyMessage:
|
// 企业微信
|
JSONObject jsonObject = sentMessageUtil.SendQyWebChat(toUserIdsList, userInfo, sendType, entity1, parameterMap, contentMsg);
|
if (!(Boolean) jsonObject.get("code")) {
|
log.error("发送企业微信消息失败，错误：" + jsonObject.get("error"));
|
}
|
break;
|
case DingMessage:
|
// 钉钉
|
JSONObject jsonObject1 = sentMessageUtil.SendDingTalk(toUserIdsList, userInfo, sendType, entity1, parameterMap, contentMsg);
|
if (!(Boolean) jsonObject1.get("code")) {
|
log.error("发送企业微信消息失败，错误：" + jsonObject1.get("error"));
|
}
|
break;
|
case WebHookMessage:
|
// webhook
|
this.SendWebHook(sendType, userInfo, entity1, parameterMap, new HashMap<>());
|
break;
|
case WechatMessage:
|
// 微信公众号
|
this.SendWXGzhChat(toUserIdsList, userInfo, sendType, entity1, contentMsg, parameterMap);
|
break;
|
default:
|
break;
|
}
|
}
|
}
|
}
|
}
|
}
|
}
|
|
public List<String> sendScheduleMessage(SentMessageForm sentMessageForm) {
|
List<String> errList = new ArrayList<>();
|
UserInfo userInfo = sentMessageForm.getUserInfo();
|
String templateId = sentMessageForm.getTemplateId();
|
String title = sentMessageForm.getTitle();
|
List<String> toUserIds = sentMessageForm.getToUserIds();
|
//获取发送配置详情
|
SendMessageConfigEntity configEntity = sendMessageConfigMapper.getInfoByEnCode(templateId);
|
if (configEntity != null) {
|
templateId = configEntity.getId();
|
} else {
|
configEntity = sendMessageConfigMapper.getInfo(templateId);
|
}
|
List<SendConfigTemplateEntity> list = sendConfigTemplateMapper.getDetailListByParentId(templateId);
|
if (configEntity != null) {
|
for (SendConfigTemplateEntity sendConfigTemplateEntity : list) {
|
Map<String, Object> objectMap = new HashMap<>(sentMessageForm.getParameterMap());
|
Map<String, Object> parameterMap = new HashMap<>();
|
for (String key : objectMap.keySet()) {
|
if (key.contains(sendConfigTemplateEntity.getId())) {
|
parameterMap.put(key.substring(sendConfigTemplateEntity.getId().length()), objectMap.get(key));
|
}
|
}
|
parameterMap.putAll(objectMap);
|
Map<String, String> contentMsg = new HashMap<>();
|
for (String key : parameterMap.keySet()) {
|
contentMsg.put(key, String.valueOf(parameterMap.get(key)));
|
}
|
String sendType = sendConfigTemplateEntity.getMessageType();
|
switch (sendType) {
|
case "1":
|
MessageTemplateConfigEntity templateConfigEntity = messageTemplateConfigMapper.getInfo(sendConfigTemplateEntity.getTemplateId());
|
String messageTitle = StringUtil.isNotEmpty(templateConfigEntity.getTitle()) ? templateConfigEntity.getTitle() : "";
|
String content = StringUtil.isNotEmpty(templateConfigEntity.getContent()) ? templateConfigEntity.getContent() : "";
|
StringSubstitutor strSubstitutor = new StringSubstitutor(parameterMap, "{", "}");
|
messageTitle = strSubstitutor.replace(messageTitle);
|
content = strSubstitutor.replace(content);
|
sentMessageForm.setTitle(messageTitle);
|
sentMessageForm.setContent(content);
|
// 站内消息
|
message(sentMessageForm);
|
// 通知触发
|
try {
|
String url = configValueUtil.getApiDomain() + "/api/workflow/trigger/MsgExecute";
|
TriggerModel model = new TriggerModel();
|
model.setUserInfo(userInfo);
|
model.setId(templateConfigEntity.getId());
|
HttpRequest request = HttpRequest.of(url).method(Method.POST).body(JsonUtil.getObjectToString(model));
|
request.header(Constants.AUTHORIZATION, userInfo.getToken());
|
request.execute().body();
|
} catch (Exception e) {
|
log.error("消息触发流程报错信息:" + e.getMessage());
|
}
|
break;
|
case "2":
|
// 邮件
|
List<String> mailErrs = sentMessageUtil.SendMail(toUserIds, userInfo, sendType, sendConfigTemplateEntity, new HashMap<>(), contentMsg);
|
errList.addAll(mailErrs.stream().distinct().collect(Collectors.toList()));
|
break;
|
case "3":
|
// 发送短信
|
List<String> smsErrs = sentMessageUtil.sendSms(toUserIds, userInfo, sendConfigTemplateEntity, parameterMap, new HashMap<>());
|
errList.addAll(smsErrs.stream().distinct().collect(Collectors.toList()));
|
break;
|
case "4":
|
// 钉钉
|
JSONObject jsonObject1 = sentMessageUtil.SendDingTalk(toUserIds, userInfo, sendType, sendConfigTemplateEntity, new HashMap<>(), contentMsg);
|
if (!(Boolean) jsonObject1.get("code")) {
|
log.error("发送企业微信消息失败，错误：" + jsonObject1.get("error"));
|
errList.add("发送钉钉消息失败，错误：" + jsonObject1.get("error"));
|
}
|
break;
|
case "5":
|
// 企业微信
|
JSONObject jsonObject = sentMessageUtil.SendQyWebChat(toUserIds, userInfo, sendType, sendConfigTemplateEntity, new HashMap<>(), contentMsg);
|
if (!(Boolean) jsonObject.get("code")) {
|
log.error("发送企业微信消息失败，错误：" + jsonObject.get("error"));
|
errList.add("发送企业微信消息失败，错误：" + jsonObject.get("error"));
|
}
|
break;
|
case "6":
|
// webhook
|
this.SendWebHook(sendType, userInfo, sendConfigTemplateEntity, new HashMap<>(), contentMsg);
|
break;
|
case "7":
|
// 微信公众号
|
JSONObject jsonObject2 = this.SendWXGzhChat(toUserIds, userInfo, sendType, sendConfigTemplateEntity, new HashMap<>(), parameterMap);
|
if (!(Boolean) jsonObject2.get("code")) {
|
errList.add("发送微信公众号消息失败，错误：" + jsonObject2.get("error"));
|
}
|
break;
|
default:
|
break;
|
}
|
}
|
}
|
return errList;
|
}
|
|
public void SendWebHook(String sendType, UserInfo userInfo, SendConfigTemplateEntity entity, Map<String, Object> parameterMap, Map<String, String> contentMsg) {
|
MessageTemplateConfigEntity msgTemEntity = messageTemplateConfigMapper.getInfo(entity.getTemplateId());
|
AccountConfigEntity accountEntity = accountConfigMapper.getInfo(entity.getAccountConfigId());
|
MessageMonitorEntity monitorEntity = new MessageMonitorEntity();
|
monitorEntity.setId(RandomUtil.uuId());
|
monitorEntity.setSendTime(DateUtil.getNowDate());
|
monitorEntity.setCreatorTime(DateUtil.getNowDate());
|
monitorEntity.setCreatorUserId(userInfo.getUserId());
|
String content = msgTemEntity.getContent();
|
//获取消息模板参数
|
parameterMap = SentMessageUtil.getParamMap(entity.getId(), parameterMap);
|
// 替换参数
|
if (StringUtil.isNotEmpty(content)) {
|
StringSubstitutor strSubstitutor = new StringSubstitutor(parameterMap, "{", "}");
|
content = strSubstitutor.replace(content);
|
}
|
String title = msgTemEntity.getTitle();
|
if (StringUtil.isNotEmpty(title)) {
|
StringSubstitutor strSubstitutor = new StringSubstitutor(parameterMap, "{", "}");
|
title = strSubstitutor.replace(title);
|
}
|
title = SentMessageUtil.systemParam(parameterMap, contentMsg, title, userInfo);
|
content = SentMessageUtil.systemParam(parameterMap, contentMsg, content, userInfo);
|
if (entity != null) {
|
if (accountEntity != null) {
|
//创建消息监控
|
monitorEntity = SentMessageUtil.createMessageMonitor(monitorEntity, msgTemEntity, accountEntity, content, userInfo, null, title);
|
messageMonitorMapper.create(monitorEntity);
|
switch (accountEntity.getWebhookType()) {
|
case 1:
|
//钉钉
|
if (Objects.equals(1, accountEntity.getApproveType())) {
|
WebHookUtil.sendDDMessage(accountEntity.getWebhookAddress(), content);
|
} else if (Objects.equals(2, accountEntity.getApproveType())) {
|
WebHookUtil.sendDingDing(accountEntity.getWebhookAddress(), accountEntity.getBearer(), content);
|
}
|
break;
|
case 2:
|
if (Objects.equals(1, accountEntity.getApproveType())) {
|
WebHookUtil.callWeChatBot(accountEntity.getWebhookAddress(), content);
|
}
|
break;
|
default:
|
break;
|
}
|
} else {
|
monitorEntity = SentMessageUtil.createMessageMonitor(monitorEntity, msgTemEntity, null, content, userInfo, null, title);
|
messageMonitorMapper.create(monitorEntity);
|
}
|
} else {
|
monitorEntity = SentMessageUtil.createMessageMonitor(monitorEntity, msgTemEntity, null, content, userInfo, null, title);
|
messageMonitorMapper.create(monitorEntity);
|
}
|
}
|
|
public JSONObject SendWXGzhChat(List<String> toUserIdsList, UserInfo userInfo, String sendType, SendConfigTemplateEntity entity, Map<String, String> contentMsg, Map<String, Object> parameterMap) {
|
//获取短信配置
|
AccountConfigEntity accountEntity = accountConfigMapper.getInfo(entity.getAccountConfigId());
|
// 获取消息模板详情
|
MessageTemplateConfigEntity msgTemEntity = messageTemplateConfigMapper.getInfo(entity.getTemplateId());
|
//消息监控
|
JSONObject retJson = new JSONObject();
|
boolean code = true;
|
StringBuilder error = new StringBuilder();
|
for (String userId : toUserIdsList) {
|
MessageMonitorEntity monitorEntity = new MessageMonitorEntity();
|
monitorEntity.setId(RandomUtil.uuId());
|
monitorEntity.setSendTime(DateUtil.getNowDate());
|
monitorEntity.setCreatorTime(DateUtil.getNowDate());
|
monitorEntity.setCreatorUserId(userInfo.getUserId());
|
error = new StringBuilder();
|
if (StringUtil.isEmpty(userId)) {
|
code = false;
|
error = error.append("；").append("接收人为空！");
|
messageMonitorMapper.create(monitorEntity);
|
continue;
|
}
|
UserEntity userEntity = userApi.getInfoById(userId);
|
if (ObjectUtil.isEmpty(userEntity)) {
|
code = false;
|
error = error.append("；").append("用户不存在！");
|
messageMonitorMapper.create(monitorEntity);
|
continue;
|
}
|
monitorEntity.setReceiveUser(userId);
|
|
if (ObjectUtil.isEmpty(msgTemEntity)) {
|
code = false;
|
error = error.append("；").append(userEntity.getRealName() + "：消息模板数据不存在！");
|
messageMonitorMapper.create(monitorEntity);
|
continue;
|
}
|
monitorEntity.setMessageTemplateId(msgTemEntity.getId());
|
String content = msgTemEntity.getContent();
|
String templateKId = msgTemEntity.getTemplateCode();
|
if (ObjectUtil.isEmpty(accountEntity)) {
|
code = false;
|
error = error.append("；").append(userEntity.getRealName() + "：公众号账号配置数据不存在！");
|
messageMonitorMapper.create(monitorEntity);
|
continue;
|
}
|
monitorEntity.setAccountId(accountEntity.getId());
|
//创建消息监控
|
monitorEntity = SentMessageUtil.createMessageMonitor(monitorEntity, msgTemEntity, accountEntity, content, userInfo, toUserIdsList, null);
|
// 获取系统配置
|
String appId = accountEntity.getAppId();
|
String appsecret = accountEntity.getAppSecret();
|
String wxxcxAppId = msgTemEntity.getXcxAppId();
|
String type = msgTemEntity.getWxSkip();
|
|
String title = "";
|
//获取消息模板参数
|
Map<String, Object> msgMap = SentMessageUtil.getParamMap(entity.getId(), parameterMap);
|
// if(parameterMap.containsKey("@flowLink")){
|
// parameterMap.put("@flowLink",link);
|
// }
|
//微信公众号参数
|
Map<String, Object> smsMap = new HashMap<>();
|
if (entity != null) {
|
smsMap = smsFieldMapper.getParamMap(entity.getTemplateId(), msgMap);
|
}
|
if (smsMap.containsKey("title")) {
|
title = smsMap.get("title").toString();
|
smsMap.keySet().removeIf(k -> k.equals("title"));
|
}
|
monitorEntity.setTitle(title);
|
// 相关参数验证
|
if (StringUtil.isEmpty(templateKId)) {
|
code = false;
|
error = error.append("；").append(userEntity.getRealName() + "：微信公众号模板id未创建！");
|
messageMonitorMapper.create(monitorEntity);
|
continue;
|
}
|
if (StringUtil.isEmpty(appId)) {
|
code = false;
|
error = error.append("；").append(userEntity.getRealName() + "：公众号appid为空为空！");
|
messageMonitorMapper.create(monitorEntity);
|
continue;
|
}
|
if (StringUtil.isEmpty(appsecret)) {
|
code = false;
|
error = error.append("；").append(userEntity.getRealName() + "：公众号appsecret为空为空！");
|
messageMonitorMapper.create(monitorEntity);
|
continue;
|
}
|
// 获取微信公众号的token
|
String token = WXGZHWebChatUtil.getAccessToken(appId, appsecret);
|
if (StringUtil.isEmpty(token)) {
|
code = false;
|
error = error.append("；").append(userEntity.getRealName() + "：获取微信公众号token失败！");
|
messageMonitorMapper.create(monitorEntity);
|
continue;
|
}
|
// 微信公众号发送消息
|
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());
|
if (!"1".equals(type)) {
|
//链接数据保存
|
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 (ObjectUtil.isNotEmpty(smsMap)) {
|
for (String key : smsMap.keySet()) {
|
if (smsMap.get(key).equals("@FlowLink")) {
|
smsMap.put(key, link);
|
}
|
}
|
} else {
|
code = false;
|
error = error.append("；").append(userEntity.getRealName() + "：公众号模板参数为空！");
|
messageMonitorMapper.create(monitorEntity);
|
continue;
|
}
|
WechatUserEntity wechatUserEntity = wechatUserMapper.getInfoByGzhId(userId, accountEntity.getAppKey());
|
if (wechatUserEntity != null) {
|
if (StringUtil.isNotBlank(wechatUserEntity.getOpenId())) {
|
String openid = wechatUserEntity.getOpenId();
|
String apptoken = authUtil.loginTempUser(userId, userInfo.getTenantId());
|
String pagepath = "/pages/workFlow/flowBefore/index?config=" + encode + "&token=" + apptoken;
|
if (ObjectUtil.isNotEmpty(smsMap)) {
|
//参数封装
|
String message = WXGZHWebChatUtil.messageJson(templateKId, openid, wxxcxAppId, pagepath, smsMap, title, type, link);
|
//发送信息
|
retJson = WXGZHWebChatUtil.sendMessage(token, message);
|
}
|
JSONObject rstObj = WXGZHWebChatUtil.getMessageList(token);
|
List<WxgzhMessageModel> wxgzhMessageModelList = JsonUtil.getJsonToList(rstObj.get("template_list"), WxgzhMessageModel.class);
|
WxgzhMessageModel messageModel = wxgzhMessageModelList.stream().filter(t -> t.getTemplateId().equals(templateKId)).findFirst().orElse(null);
|
if (ObjectUtil.isNotEmpty(messageModel)) {
|
content = messageModel.getContent();
|
if (StringUtil.isNotBlank(content) && !"null".equals(content)) {
|
if (ObjectUtil.isNotEmpty(smsMap) && !"null".equals(smsMap)) {
|
if (content.contains(".DATA}")) {
|
for (String key : smsMap.keySet()) {
|
content = content.replace(key, smsMap.get(key).toString());
|
}
|
}
|
}
|
}
|
}
|
if (!retJson.getBoolean("code")) {
|
code = false;
|
error = error.append("；").append(userEntity.getRealName() + "：" + retJson.get("error"));
|
messageMonitorMapper.create(monitorEntity);
|
continue;
|
}
|
messageMonitorMapper.create(monitorEntity);
|
continue;
|
|
} else {
|
code = false;
|
error = error.append("；").append(userEntity.getRealName() + "：" + "账号未绑定公众号");
|
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;
|
}
|
|
public boolean sentNotice(List<String> toUserIds, MessageEntity entity) {
|
// 存到redis中的key对象
|
UserInfo userInfo = UserProvider.getUser();
|
List<String> idList = new ArrayList<>();
|
// 修改发送状态
|
entity.setEnabledMark(1);
|
entity.setLastModifyTime(new Date());
|
entity.setLastModifyUserId(userInfo.getUserId());
|
messageMapper.updateById(entity);
|
// 存到redis，生成Redis的key
|
Callable executeInsert = () -> {
|
executeInsert(toUserIds, idList);
|
return true;
|
};
|
Future<Boolean> submit = ThreadPoolExecutorUtil.getExecutor().submit(executeInsert);
|
try {
|
if (submit.get()) {
|
// 执行发送公告操作
|
Runnable runnable = () -> executeBatch(idList, entity, userInfo);
|
ThreadPoolExecutorUtil.getExecutor().submit(runnable);
|
}
|
return true;
|
} catch (Exception e) {
|
// 还原公告状态
|
entity.setEnabledMark(0);
|
entity.setLastModifyTime(null);
|
entity.setLastModifyUserId(null);
|
messageMapper.updateById(entity);
|
}
|
return false;
|
}
|
|
private void executeBatch(List<String> idList, MessageEntity entity, UserInfo userInfo) {
|
if (idList.size() == 0 || "3".equals(String.valueOf(entity.getRemindCategory()))) {
|
return;
|
}
|
SentMessageForm sentMessageForm = new SentMessageForm();
|
List<String> toUserId = new ArrayList<>();
|
for (String cacheKey : idList) {
|
List<String> cacheValue = (List) redisUtil.get(cacheKey, 0, -1);
|
toUserId.addAll(cacheValue);
|
}
|
sentMessageForm.setToUserIds(toUserId);
|
sentMessageForm.setTitle(entity.getTitle());
|
sentMessageForm.setContent(entity.getBodyText());
|
sentMessageForm.setContentMsg(Collections.EMPTY_MAP);
|
sentMessageForm.setUserInfo(userInfo);
|
sentMessageForm.setType(1);
|
sentMessageForm.setId(entity.getId());
|
|
// 站内信
|
if ("1".equals(String.valueOf(entity.getRemindCategory()))) {
|
message(sentMessageForm);
|
} else if ("2".equals(String.valueOf(entity.getRemindCategory()))) {
|
SendMessageConfigEntity sendMessageConfigEntity = sendMessageConfigMapper.getInfo(entity.getSendConfigId());
|
if (sendMessageConfigEntity != null) {
|
List<SendConfigTemplateEntity> configTemplateEntityList = sendConfigTemplateMapper.getDetailListByParentId(sendMessageConfigEntity.getId());
|
for (SendConfigTemplateEntity sendConfigTemplateEntity : configTemplateEntityList) {
|
Map<String, String> map = new HashMap<>();
|
map.put("Title", entity.getTitle());
|
map.put("Content", entity.getBodyText());
|
map.put("Remark", entity.getExcerpt());
|
Map<String, Object> paramMap = new HashMap<>();
|
paramMap.put("@Title", entity.getTitle());
|
paramMap.put("@Content", entity.getBodyText());
|
paramMap.put("@Remark", entity.getExcerpt());
|
paramMap.put("@CreatorUserName", userInfo.getUserName());
|
paramMap.put("@SendTime", DateUtil.getNow().substring(11));
|
paramMap.put(sendConfigTemplateEntity.getId()+"@Title", entity.getTitle());
|
paramMap.put(sendConfigTemplateEntity.getId()+"@Content", entity.getBodyText());
|
paramMap.put(sendConfigTemplateEntity.getId()+"@Remark", entity.getExcerpt());
|
paramMap.put(sendConfigTemplateEntity.getId()+"@CreatorUserName", userInfo.getUserName());
|
paramMap.put(sendConfigTemplateEntity.getId()+"@SendTime", DateUtil.getNow().substring(11));
|
switch (sendConfigTemplateEntity.getMessageType()) {
|
case "1":
|
MessageTemplateConfigEntity configEntity = messageTemplateConfigMapper.getInfo(sendConfigTemplateEntity.getTemplateId());
|
if (configEntity != null) {
|
sentMessageForm.setTitle(configEntity.getTitle());
|
}
|
message(sentMessageForm);
|
break;
|
case "2":
|
// 邮件
|
sentMessageUtil.SendMail(toUserId, userInfo, "2", sendConfigTemplateEntity, new HashMap<>(), map);
|
break;
|
case "3":
|
// 发送短信
|
sentMessageUtil.sendSms(toUserId, userInfo, sendConfigTemplateEntity, paramMap, new HashMap<>());
|
break;
|
case "4":
|
// 钉钉
|
JSONObject jsonObject1 = sentMessageUtil.SendDingTalk(toUserId, userInfo, "4", sendConfigTemplateEntity, new HashMap<>(), map);
|
if (!(Boolean) jsonObject1.get("code")) {
|
log.error("发送企业微信消息失败，错误：" + jsonObject1.get("error"));
|
}
|
break;
|
case "5":
|
// 企业微信
|
JSONObject jsonObject = sentMessageUtil.SendQyWebChat(toUserId, userInfo, "5", sendConfigTemplateEntity, new HashMap<>(), map);
|
if (!(Boolean) jsonObject.get("code")) {
|
log.error("发送企业微信消息失败，错误：" + jsonObject.get("error"));
|
}
|
break;
|
case "6":
|
// webhook
|
this.SendWebHook(null, userInfo, sendConfigTemplateEntity, new HashMap<>(), map);
|
break;
|
case "7":
|
// 微信公众号
|
this.SendWXGzhChat(toUserId, userInfo, "7", sendConfigTemplateEntity, new HashMap<>(), paramMap);
|
break;
|
default:
|
break;
|
}
|
}
|
|
}
|
}
|
}
|
|
private void message(SentMessageForm sentMessageForm) {
|
List<String> toUserIds = sentMessageForm.getToUserIds();
|
Integer type = sentMessageForm.getType();
|
String title = sentMessageForm.getTitle();
|
String content = sentMessageForm.getContent();
|
String bodyText = Objects.equals(type, 3) ? content : JsonUtil.getObjectToString(sentMessageForm.getContentMsg());
|
UserInfo userInfo = sentMessageForm.getUserInfo();
|
MessageReceiveEntity messageReceiveEntity = new MessageReceiveEntity();
|
messageReceiveEntity.setIsRead(0);
|
messageReceiveEntity.setId(RandomUtil.uuId());
|
messageReceiveEntity.setType(sentMessageForm.getType());
|
if (type != null) {
|
messageReceiveEntity.setId(sentMessageForm.getId());
|
messageReceiveEntity.setType(type);
|
messageReceiveEntity.setCreatorUserId(userInfo.getUserId());
|
messageReceiveEntity.setCreatorTime(DateUtil.getNowDate());
|
}
|
//消息监控写入
|
MessageMonitorEntity monitorEntity = new MessageMonitorEntity();
|
MessageEntity messageEntity = messageMapper.getInfo(sentMessageForm.getId());
|
if (!"1".equals(String.valueOf(messageReceiveEntity.getType()))) {
|
monitorEntity.setMessageSource(sentMessageForm.getType() + "");
|
messageReceiveEntity.setFlowType(sentMessageForm.getFlowType());
|
monitorEntity.setTitle(title);
|
} else {
|
monitorEntity.setMessageSource("1");
|
title = title.replaceAll("\\{@Title}", messageEntity.getTitle())
|
.replaceAll("\\{@CreatorUserName}", userInfo.getUserName())
|
.replaceAll("\\{@SendTime}", DateUtil.getNow().substring(11))
|
.replaceAll("\\{@Content}", messageEntity.getBodyText())
|
.replaceAll("\\{@Remark}", StringUtil.isNotEmpty(messageEntity.getExcerpt()) ? messageEntity.getExcerpt() : "");
|
monitorEntity.setTitle(title);
|
|
MessageEntity messageEntity2 = new MessageEntity();
|
messageEntity2.setId(messageEntity.getId());
|
bodyText = JsonUtil.getObjectToString(messageEntity2);
|
}
|
Map<String, MessageReceiveEntity> map = new HashMap<>();
|
for (String item : toUserIds) {
|
MessageReceiveEntity messageReceiveEntitys = new MessageReceiveEntity();
|
BeanUtils.copyProperties(messageReceiveEntity, messageReceiveEntitys);
|
messageReceiveEntitys.setId(RandomUtil.uuId());
|
messageReceiveEntitys.setUserId(item);
|
messageReceiveEntitys.setTitle(title);
|
// if(ObjectUtil.isNotEmpty(messageEntity)) {
|
// messageReceiveEntitys.setTitle(title.replaceAll("\\{@Title}", messageEntity.getTitle())
|
// .replaceAll("\\{@CreatorUserName}", userInfo.getUserName())
|
// .replaceAll("\\{@Content}", messageEntity.getBodyText())
|
// .replaceAll("\\{@Remark}", StringUtil.isNotEmpty(messageEntity.getExcerpt()) ? messageEntity.getExcerpt() : ""));
|
// }
|
messageReceiveEntitys.setBodyText(bodyText);
|
messagereceiveMapper.insert(messageReceiveEntitys);
|
map.put(messageReceiveEntitys.getUserId(), messageReceiveEntitys);
|
}
|
monitorEntity.setId(RandomUtil.uuId());
|
monitorEntity.setMessageType("1");
|
monitorEntity.setReceiveUser(JsonUtil.getObjectToString(toUserIds));
|
monitorEntity.setSendTime(DateUtil.getNowDate());
|
monitorEntity.setCreatorTime(DateUtil.getNowDate());
|
monitorEntity.setCreatorUserId(userInfo.getUserId());
|
monitorEntity.setContent(content);
|
messageMonitorMapper.insert(monitorEntity);
|
//消息推送 - PC端
|
PushMessageUtil.pushMessage(map, userInfo, type != null ? type : 2);
|
}
|
|
|
/**
|
* 数据存到redis中
|
*
|
* @param toUserIds 接受者id
|
*/
|
private void executeInsert(List<String> toUserIds, List<String> idList) throws Exception {
|
List<String> key = new ArrayList<>();
|
try {
|
int frequency = 10000;
|
int count = toUserIds.size() / frequency + 1;
|
if (toUserIds.size() < 1) return;
|
for (int i = 0; i < count; i++) {
|
// 生成redis的key
|
String cacheKey = RandomUtil.uuId() + toUserIds.get(i);
|
// 存到redis
|
int endSize = Math.min(((i + 1) * frequency), toUserIds.size());
|
redisUtil.insert(cacheKey, toUserIds.subList(i * frequency, endSize));
|
key.add(cacheKey);
|
}
|
} catch (Exception e) {
|
key.forEach(k -> redisUtil.remove(k));
|
key.clear();
|
throw new Exception();
|
}
|
idList.addAll(key);
|
}
|
|
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<String, String> 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 = SentMessageUtil.getUnableTime(linkTime);
|
entity.setUnableTime(unableTime);
|
} else {
|
entity.setUnableTime(DateUtil.dateAddHours(DateUtil.getNowDate(), 24));
|
}
|
entity.setCreatorTime(DateUtil.getNowDate());
|
entity.setCreatorUserId(userInfo.getUserId());
|
shortLInkMapper.insert(entity);
|
}
|
}
|
|
private Map<String, String> getSystemConfig() {
|
// 获取系统配置
|
List<SysConfigEntity> configList = sysconfigService.getList("SysConfig");
|
Map<String, String> objModel = new HashMap<>(16);
|
for (SysConfigEntity entity : configList) {
|
objModel.put(entity.getFkey(), entity.getValue());
|
}
|
return objModel;
|
}
|
|
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);
|
}
|
}
|
}
|
