package com.ks.push.utils;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.google.gson.Gson;
|
import com.ks.push.pojo.DO.BPushMessage;
|
import com.ks.push.pojo.DO.PushPlatform;
|
import com.ks.push.utils.push.*;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.yeshi.utils.StringUtil;
|
import org.yeshi.utils.push.entity.PushAppInfo;
|
import org.yeshi.utils.push.entity.PushMessage;
|
|
import java.util.HashMap;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.Map;
|
|
public class PushUtil {
|
|
static Logger logger = LoggerFactory.getLogger(PushUtil.class);
|
|
/**
|
* 推送通知
|
*
|
* @param platform
|
* @param appInfo
|
* @param pushMessage
|
* @param tokenList
|
* @throws Exception
|
*/
|
public static void pushNotifyCation(PushPlatform platform, PushAppInfo appInfo, BPushMessage pushMessage, String identifyCode, List<String> tokenList) throws Exception {
|
if (appInfo == null) {
|
throw new Exception("应用参数为空");
|
}
|
|
if (pushMessage == null) {
|
throw new Exception("消息为空");
|
}
|
|
if (tokenList == null || tokenList.size() == 0) {
|
throw new Exception("token为空");
|
}
|
|
logger.info("{}推送应用信息：{}", platform.name(), new Gson().toJson(appInfo));
|
logger.info("{}推送内容信息：{}", platform.name(), new Gson().toJson(pushMessage));
|
logger.info("{}推送token信息：{}", platform.name(), new Gson().toJson(tokenList));
|
|
|
Map<String, String> extras = null;
|
if (pushMessage.getExtras() != null) {
|
extras = new HashMap<>();
|
for (Iterator<String> its = pushMessage.getExtras().keySet().iterator(); its.hasNext(); ) {
|
String key = its.next();
|
String value = pushMessage.getExtras().get(key);
|
if (!StringUtil.isNullOrEmpty(key) && !StringUtil.isNullOrEmpty(value)) {
|
extras.put(key, value);
|
}
|
}
|
}
|
|
PushMessage message = new PushMessage(pushMessage.getTitle(), pushMessage.getContent(), pushMessage.getAndroidActivity(), pushMessage.getAndroidActivityScheme(), pushMessage.getAndroidHostPath(), extras);
|
|
if (platform == PushPlatform.xm) {
|
pushXM(appInfo, message, tokenList);
|
} else if (platform == PushPlatform.hw) {
|
pushHW(appInfo, message, identifyCode, tokenList);
|
} else if (platform == PushPlatform.oppo) {
|
pushOPPO(appInfo, message, tokenList);
|
} else if (platform == PushPlatform.vivo) {
|
pushVIVO(appInfo, message, tokenList);
|
} else if (platform == PushPlatform.mz) {
|
pushMZ(appInfo, message, tokenList);
|
} else if (platform == PushPlatform.jpush) {
|
pushJPush(appInfo, message, tokenList,!pushMessage.isMessage());
|
}
|
}
|
|
/**
|
* 小米推送
|
*
|
* @param appInfo
|
* @param message
|
* @param tokenList
|
* @throws Exception
|
*/
|
private static void pushXM(PushAppInfo appInfo, PushMessage message, List<String> tokenList) throws Exception {
|
XiaoMiPushUtil.pushNotificationByRegIds(appInfo, message, tokenList);
|
}
|
|
/**
|
* 华为推送
|
*
|
* @param appInfo
|
* @param message
|
* @param bigTag
|
* @param tokenList
|
* @throws Exception
|
*/
|
private static void pushHW(PushAppInfo appInfo, PushMessage message, String bigTag, List<String> tokenList) throws Exception {
|
HuaWeiPushUtil.pushNotificationByTokens(appInfo, message, bigTag, tokenList);
|
}
|
|
/**
|
* OPPO推送
|
*
|
* @param appInfo
|
* @param message
|
* @param tokenList
|
* @throws Exception
|
*/
|
private static void pushOPPO(PushAppInfo appInfo, PushMessage message, List<String> tokenList) throws Exception {
|
OppoPushUtil.pushNotificationByRegIds(appInfo, message, tokenList);
|
}
|
|
/**
|
* VIVO推送
|
*
|
* @param appInfo
|
* @param message
|
* @param tokenList
|
* @throws Exception
|
*/
|
private static void pushVIVO(PushAppInfo appInfo, PushMessage message, List<String> tokenList) throws Exception {
|
VIVOPushUtil.pushNotificationByRegIds(appInfo, message, tokenList);
|
}
|
|
/**
|
* 魅族推送
|
*
|
* @param appInfo
|
* @param message
|
* @param tokenList
|
* @throws Exception
|
*/
|
private static void pushMZ(PushAppInfo appInfo, PushMessage message, List<String> tokenList) throws Exception {
|
MeiZuPushUtil.pushNotificationByPushId(appInfo, message, tokenList);
|
}
|
|
|
/**
|
* 极光推送
|
*
|
* @param appInfo
|
* @param message
|
* @param tokenList
|
* @throws Exception
|
*/
|
private static void pushJPush(PushAppInfo appInfo, PushMessage message, List<String> tokenList, boolean alert) throws Exception {
|
if (alert) {
|
JpushUtil.pushNotification(appInfo, message, tokenList, null);
|
} else {
|
JSONObject data = new JSONObject();
|
if (message.getActivityParams() != null) {
|
for (Iterator<String> its = message.getActivityParams().keySet().iterator(); its.hasNext(); ) {
|
String key = its.next();
|
data.put(key, message.getActivityParams().get(key));
|
}
|
}
|
JpushUtil.pushMessage(appInfo, data, tokenList, null);
|
}
|
}
|
|
|
}
|
