package com.ks.push.utils.push;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.google.gson.Gson;
|
import com.ks.push.utils.Constant;
|
import com.xiaomi.xmpush.server.Constants;
|
import com.xiaomi.xmpush.server.Message;
|
import com.xiaomi.xmpush.server.Result;
|
import com.xiaomi.xmpush.server.Sender;
|
import org.json.simple.parser.ParseException;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.yeshi.utils.push.entity.PushAppInfo;
|
import org.yeshi.utils.push.entity.PushMessage;
|
import org.yeshi.utils.push.exception.MeiZuPushException;
|
|
import java.io.IOException;
|
import java.io.UnsupportedEncodingException;
|
import java.net.URLEncoder;
|
import java.util.*;
|
|
/**
|
* 小米推送
|
* 推送文档：https://dev.mi.com/console/doc/detail?pId=1278
|
*/
|
public class XiaoMiPushUtil {
|
|
static Logger logger = LoggerFactory.getLogger(XiaoMiPushUtil.class);
|
|
private static Message createMessage(PushAppInfo appInfo, PushMessage message) {
|
String title = message.getTitle();
|
String content = message.getContent();
|
|
if (title.length() > 50) {
|
title = title.substring(0, 50 - 3) + "...";
|
}
|
if (content.length() > 128) {
|
content = content.substring(0, 128 - 3) + "...";
|
}
|
//示例:intent:#Intent;component=com.doudou.ysvideo/com.weikou.beibeivideo.ui.push.OpenClickActivity;S.activity=test;S.params=%7B%22id%22%3A%22123123%22%7D;end
|
String uri = String.format("intent:#Intent;component=%s/%s;", appInfo.getPackageName(), message.getActivity().replace(appInfo.getPackageName(), ""));
|
//增加Activity的跳转参数
|
for (Iterator<String> its = message.getActivityParams().keySet().iterator(); its.hasNext(); ) {
|
String k = its.next();
|
try {
|
if (message.getActivityParams().get(k) != null) {
|
uri += String.format("S.%s=%s;", k, URLEncoder.encode(message.getActivityParams().get(k), "UTF-8"));
|
}
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
}
|
|
uri += "end";
|
|
|
Message msg = new Message.Builder()
|
//设置在通知栏展示的通知的标题, 不允许全是空白字符, 长度小于50, 一个中英文字符均计算为1(通知栏消息必填)
|
.title(title)
|
//设置在通知栏展示的通知描述, 不允许全是空白字符, 长度小于128, 一个中英文字符均计算为1(通知栏消息必填)
|
.description(content)
|
.restrictedPackageName(appInfo.getPackageName())
|
//1：使用默认提示音提示
|
//2：使用默认震动提示
|
//4：使用默认led灯光提示
|
//-1（系统默认值）：以上三种效果都有
|
//0：以上三种效果都无，即静默推送。
|
//并且支持1，2，4的任意OR运算来实现声音、震动和闪光灯的任意组合。
|
|
.notifyType(1) // 使用默认提示音提示
|
//可选项, 对app提供一些扩展功能（除了这些扩展功能,
|
// 开发者还可以定义一些key和value来控制客户端的行为,
|
// 注：key和value的字符数不能超过1024, 至多可以设置10个key-value键值对）
|
//.extra()
|
.extra(Constants.EXTRA_PARAM_NOTIFY_EFFECT, Constants.NOTIFY_ACTIVITY)
|
// 启动Activity的intent uri
|
.extra(Constants.EXTRA_PARAM_INTENT_URI, uri)
|
//消息回执 https://dev.mi.com/console/doc/detail?pId=1278#_3_6
|
.extra("callback", Constant.PUSH_CALLBACK_XM_URL)
|
.extra("callback.param", appInfo.getAppId())
|
.extra("callback.type", "19")//收到消息送达、消息点击和目标设备无效三种状态的回执
|
|
.build();
|
return msg;
|
}
|
|
/**
|
* 推送通知
|
*
|
* @param appInfo
|
* @param message
|
* @param regIds 不能超过1000个
|
* @return
|
* @throws IOException
|
* @throws MeiZuPushException
|
*/
|
public static String pushNotificationByRegIds(PushAppInfo appInfo, PushMessage message, List<String> regIds) throws IOException {
|
//推送标题限制字数1-32，推送内容限制字数1-100
|
Sender sender = new Sender(appInfo.getAppSecret());
|
Message msg = createMessage(appInfo, message);
|
Result result = sender.unionSend(msg, regIds, 3);
|
logger.info("小米推送响应结果：{}", new Gson().toJson(result));
|
return result.getMessageId();
|
}
|
|
/**
|
* 推送所有
|
*
|
* @param appInfo
|
* @param message
|
* @return
|
* @throws IOException
|
* @throws MeiZuPushException
|
*/
|
public static String pushNotificationAll(PushAppInfo appInfo, PushMessage message) throws IOException, ParseException {
|
Sender sender = new Sender(appInfo.getAppSecret());
|
Message msg = createMessage(appInfo, message);
|
Result result = sender.broadcastAll(msg, 3);
|
logger.info("小米推送响应结果：{}", new Gson().toJson(result));
|
return result.getMessageId();
|
}
|
|
|
public static void main(String[] args) {
|
PushAppInfo appInfo = new PushAppInfo("2882303761519871448", "5161987181448", "OcdMXvErcGtf1XyXnwrhOg==");
|
appInfo.setPackageName("com.tejia.lijin");
|
Map<String, String> activityParams = new HashMap<>();
|
activityParams.put("activity", "com.weikou.beibeivideo.ui.media.VideoDetailActivity2");
|
JSONObject jumpParams = new JSONObject();
|
jumpParams.put("Id", "8219668");
|
jumpParams.put("Share", 0);
|
jumpParams.put("ThirdType", 0);
|
activityParams.put("params", jumpParams.toJSONString());
|
|
PushMessage message = new PushMessage("她们创业的那些事儿", "讲述了三个不同年龄、不同性格的女生因缘际会在一起创业的故事，在这条不被看好的创业之路上，她们终将学会，对鸟事一笑置之，不是认输，而是成长！", "com.tejia.lijin.app.ui.PushOpenClickActivity", null, null, activityParams);
|
|
String[] ids = new String[]{
|
"t76FQBHolG/YQ9V7qmhtsTbLXNDcCNHfSfNK2k3iKI6B8RYL9FPSWJvXDaBNKy8N"
|
};
|
|
try {
|
XiaoMiPushUtil.pushNotificationByRegIds(appInfo, message, Arrays.asList(ids));
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
// try {
|
// XiaoMiPushUtil.pushNotificationByRegIds(appInfo, message, Arrays.asList(ids));
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// }
|
|
}
|
|
|
}
|
