package com.iplatform.base.util;
|
|
import com.iplatform.base.config.PushProperties;
|
import com.iplatform.model.po.SfTemplateMessage;
|
import com.iplatform.model.vo.NotificationConfigVo;
|
import com.walker.infrastructure.arguments.Variable;
|
import com.walker.infrastructure.utils.DateUtils;
|
import com.walker.infrastructure.utils.JsonUtils;
|
import com.walker.infrastructure.utils.NumberGenerator;
|
import com.walker.infrastructure.utils.StringUtils;
|
import com.walker.push.Notification;
|
import com.walker.push.NotificationChannel;
|
import com.walker.push.SmsMessage;
|
import com.walker.push.util.PushUtils;
|
import com.walker.push.wx.MessageTemplate;
|
import com.walker.push.wx.MessageValue;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
public class NotificationUtils {
|
|
public static final Notification acquireSmsNotification(String templateId
|
, String userPhone, List<Variable> variableList, String title){
|
Map<String, String> param = new HashMap<>(4);
|
for(Variable variable : variableList){
|
param.put(variable.getId(), variable.getStringValue());
|
}
|
SmsMessage smsMessage = new SmsMessage();
|
smsMessage.setTemplateId(templateId);
|
smsMessage.setTemplateParam(param);
|
|
try {
|
return PushUtils.acquireSmsNotification(title, JsonUtils.objectToJsonString(smsMessage), userPhone, "平台");
|
} catch (Exception e) {
|
throw new RuntimeException(e);
|
}
|
}
|
|
/**
|
* 获得一个微信公众号提醒消息。
|
* @param accessToken 基础 access_token
|
* @param templateId 公众号消息模板ID
|
* @param userOpenId 用户openId
|
* @return
|
* @date 2023-08-25
|
*/
|
public static final Notification acquireWechatNotification(String accessToken
|
, String templateId, String userOpenId, List<Variable> variableList){
|
Notification notification = new Notification();
|
notification.setId(NumberGenerator.getLongSequenceId());
|
notification.setTitle("微信公众号推送");
|
notification.setPersistent(true);
|
notification.setFrom("平台");
|
notification.setCreateTime(DateUtils.getDateTimeNumber());
|
|
List<NotificationChannel> channels = new ArrayList<>(2);
|
channels.add(NotificationChannel.OfficialAccount);
|
notification.setChannelList(channels);
|
|
List<String> accessTokenList = new ArrayList<>(2);
|
accessTokenList.add(accessToken);
|
notification.setReceiverList(accessTokenList);
|
notification.setCreator("platform");
|
notification.setParallel(false);
|
|
//
|
MessageTemplate messageTemplate = new MessageTemplate();
|
messageTemplate.setTemplate_id(templateId);
|
messageTemplate.setTouser(userOpenId);
|
|
HashMap<String, MessageValue> param = new HashMap<>(4);
|
for(Variable variable : variableList){
|
param.put(variable.getId(), new MessageValue(variable.getStringValue()));
|
}
|
messageTemplate.setData(param);
|
try {
|
notification.setContent(JsonUtils.objectToJsonString(messageTemplate));
|
} catch (Exception e) {
|
throw new RuntimeException(e);
|
}
|
return notification;
|
}
|
|
public static final NotificationConfigVo acquireNotificationConfigVo(SfTemplateMessage templateMessage){
|
NotificationConfigVo vo = new NotificationConfigVo();
|
vo.setId(templateMessage.getId());
|
vo.setName(templateMessage.getName());
|
vo.setTempId(templateMessage.getTempId());
|
vo.setTempKey(templateMessage.getTempKey());
|
vo.setContent(templateMessage.getContent());
|
// vo.setStatus();
|
return vo;
|
}
|
|
// /**
|
// * 平台业务通知可用的通道集合，我们会尝试每个通道，只要一个成功就不再发送。
|
// * @date 2023-04-25
|
// */
|
// public static final List<NotificationChannel> platformNotificationTypes = new ArrayList<>(4);
|
// static {
|
// platformNotificationTypes.add(NotificationChannel.WebSocket);
|
// platformNotificationTypes.add(NotificationChannel.Tcp);
|
// platformNotificationTypes.add(NotificationChannel.System);
|
// }
|
|
/**
|
* 解析推送普通消息配置的规则。详细参考：{@linkplain PushProperties#getMessageType()}
|
* @param messageType
|
* @return
|
* @date 2023-04-26
|
*/
|
public static final Object[] acquireMessagePushRules(String messageType){
|
if(StringUtils.isEmpty(messageType)){
|
return null;
|
}
|
messageType = messageType.replace(StringUtils.CHAR_SPACE, StringUtils.EMPTY_STRING);
|
|
Object[] data = new Object[2];
|
String[] indexList = null;
|
if(messageType.indexOf("&&") > 0){
|
data[0] = true;
|
indexList = messageType.split("&&");
|
|
} else if(messageType.indexOf("||") > 0){
|
data[0] = false;
|
indexList = messageType.split("\\|\\|");
|
} else {
|
data[0] = false;
|
indexList = new String[]{messageType};
|
}
|
data[1] = indexList;
|
|
return data;
|
}
|
|
/**
|
* 获取发送短信验证码通知
|
* @param templateId 模板ID
|
* @param code 验证码
|
* @param targetUserId 目标用户ID
|
* @param creator 创建人ID
|
* @return
|
* @date 2023-04-25
|
*/
|
public static final Notification acquireSmsValidateCode(String templateId
|
, String code, String targetUserId, String creator){
|
Map<String, String> param = new HashMap<>(2);
|
param.put("code", code);
|
return acquireSmsNotification(templateId, param, "发送验证码", targetUserId, creator);
|
}
|
|
public static final Notification acquireSmsNotification(String templateId
|
, Map<String, String> param, String title, String targetUserId, String creator){
|
SmsMessage smsMessage = new SmsMessage();
|
smsMessage.setTemplateId(templateId);
|
smsMessage.setTemplateParam(param);
|
|
try {
|
return PushUtils.acquireSmsNotification(title, JsonUtils.objectToJsonString(smsMessage), targetUserId, creator);
|
} catch (Exception e) {
|
throw new RuntimeException(e);
|
}
|
}
|
}
|
