package com.nuvole.util;
|
|
import com.gexin.rp.sdk.base.IAliasResult;
|
import com.gexin.rp.sdk.base.IPushResult;
|
import com.gexin.rp.sdk.base.impl.AppMessage;
|
import com.gexin.rp.sdk.base.impl.ListMessage;
|
import com.gexin.rp.sdk.base.impl.SingleMessage;
|
import com.gexin.rp.sdk.base.impl.Target;
|
import com.gexin.rp.sdk.base.notify.Notify;
|
import com.gexin.rp.sdk.base.payload.APNPayload;
|
import com.gexin.rp.sdk.exceptions.RequestException;
|
import com.gexin.rp.sdk.http.IGtPush;
|
import com.gexin.rp.sdk.template.AbstractTemplate;
|
import com.gexin.rp.sdk.template.TransmissionTemplate;
|
import com.nuvole.common.domain.emnu.CommonResultEmnu;
|
import com.nuvole.common.domain.result.CommonResult;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
|
|
/**
|
* 推送工具类（个推）
|
*
|
* @Author: lc
|
* @Date: 2020/4/26 13:41
|
*/
|
|
public class GeTuiPush {
|
|
private static String url = "http://sdk.open.api.igexin.com/apiex.htm";
|
// private static String appId = "0TrCn76GcW8T4y3wediOn9";
|
private static String appId = "g1FYuSXD2x5HY2KfWswP19";
|
// private static String appKey = "FUPAiYeLSo5hbPIZrRDT21";
|
private static String appKey = "kkMqLLBGLd7wx0mhIbG9l5";
|
// private static String masterSecret = "ne5FG9hfS77RNyGAnQF5p1";
|
private static String masterSecret = "AEuOKMlvTY9aLrdjtPhzy7";
|
private static IGtPush igtPush = new IGtPush(url, appKey, masterSecret);
|
|
|
/**
|
* 为用户绑定别名
|
*
|
* @param clientId 客户端身份id
|
* @param alias 别名
|
* @Author: lc
|
* @Date: 2020/4/26 13:36
|
*/
|
public static CommonResult bindAlias(String clientId, String alias) {
|
|
IAliasResult ret = null;
|
try {
|
ret = igtPush.bindAlias(appId, alias, clientId);
|
System.out.println("is bindAlias res:" + ret.getResponse());
|
} catch (RequestException e) {
|
e.printStackTrace();
|
}
|
if (ret != null) {
|
Map res = ret.getResponse();
|
if ("ok".equals(res.get("result").toString())) {
|
return new CommonResult(res);
|
} else {
|
return new CommonResult(CommonResultEmnu.ERROR, res.get("error_msg").toString());
|
}
|
} else {
|
return new CommonResult(CommonResultEmnu.ERROR, "绑定个推别名时出现异常！");
|
}
|
}
|
|
|
//测试
|
public static void main(String[] args) {
|
|
bindAlias("0482fa489fe285cbb8b96054f81a0b4f", "123456789");
|
pushMessageToSingle("测试demo", "测试demo内容", 2, "123456789");
|
}
|
|
/**
|
* 单推（单个clientId/别名）
|
*
|
* @param title 标题
|
* @param content 内容
|
* @param type 类型【1.设备id（clientId） 2.别名】
|
* @param val 类型值（clientId/别名）
|
* @Author: lc
|
* @Date: 2020/4/26 13:31
|
*/
|
public static Map pushMessageToSingle(String title, String content, int type, String val) {
|
|
/*透传消息模版*/
|
AbstractTemplate template = getTransmissionTemplate(title, content);
|
|
// 单推消息类型
|
SingleMessage message = getSingleMessage(template);
|
Target target = new Target();
|
target.setAppId(appId);
|
if (type == 1) {
|
target.setClientId(val);
|
} else {
|
target.setAlias(val);//别名需要提前绑定
|
}
|
IPushResult ret = null;
|
try {
|
ret = igtPush.pushMessageToSingle(message, target);
|
System.out.println("is pushMessageToSingle res:" + ret.getResponse());
|
} catch (RequestException e) {
|
e.printStackTrace();
|
ret = igtPush.pushMessageToSingle(message, target, e.getRequestId());
|
}
|
if (ret != null) {
|
return ret.getResponse();
|
} else {
|
System.out.println("个推单条推送服务器响应异常");
|
return null;
|
}
|
}
|
|
|
/**
|
* 推送一个列表
|
*
|
* @param title 标题
|
* @param content 内容
|
* @parma type 类型【1.设备id（clientId） 2.别名】
|
* @parma jsonArray 类型值（clientId/别名）
|
* @Author: lc
|
* @Date: 2020/4/26 13:37
|
*/
|
public static Map pushMessageToList(String title, String content, int type, List<String> list) {
|
/*透传消息模版*/
|
AbstractTemplate template = getTransmissionTemplate(title, content);
|
|
ListMessage message = new ListMessage();
|
message.setData(template);
|
// 设置消息离线，并设置离线时间
|
message.setOffline(true);
|
// 离线有效时间，单位为毫秒，可选
|
message.setOfflineExpireTime(24 * 1000 * 3600);
|
message.setPriority(1);
|
String taskId = igtPush.getContentId(message);
|
// 配置推送目标
|
List targets = new ArrayList();
|
for (int i = 0; i < list.size(); i++) {
|
String cid = list.get(i);
|
Target target = new Target();
|
target.setAppId(appId);
|
if (type == 1) {
|
target.setClientId(cid);
|
} else {
|
target.setAlias(cid);
|
}
|
targets.add(target);
|
}
|
|
IPushResult ret = null;
|
try {
|
ret = igtPush.pushMessageToList(taskId, targets);
|
System.out.println("is pushMessageToList:" + ret.getResponse());
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
if (ret != null) {
|
return ret.getResponse();
|
} else {
|
System.out.println("个推推送一个列表服务器响应异常");
|
return null;
|
}
|
}
|
|
|
/**
|
* 推送所有手机用户
|
*
|
* @param title 标题
|
* @param content 内容
|
* @Author: lc
|
* @Date: 2020/4/26 13:36
|
*/
|
public static Map pushMessageToApp(String title, String content) {
|
/*透传消息模版*/
|
AbstractTemplate template = getTransmissionTemplate(title, content);
|
|
// 单推消息类型
|
AppMessage message = new AppMessage();
|
message.setData(template);
|
message.setOffline(true);
|
message.setOfflineExpireTime(24 * 1000 * 3600); //离线有效时间，单位为毫秒，可选
|
//全量推送时希望能控制推送速度不要太快，缓减服务器连接压力，可设置定速推送。如果未设置则按默认推送速度发送
|
message.setSpeed(100); // 设置为100，含义为个推控制下发速度在100条/秒左右
|
List<String> appIdList = new ArrayList<String>();
|
appIdList.add(appId);
|
message.setAppIdList(appIdList);
|
|
IPushResult ret = null;
|
try {
|
ret = igtPush.pushMessageToApp(message);
|
System.out.println("is pushMessageToApp res:" + ret.getResponse());
|
} catch (RequestException e) {
|
e.printStackTrace();
|
ret = igtPush.pushMessageToApp(message, e.getRequestId());
|
}
|
if (ret != null) {
|
return ret.getResponse();
|
} else {
|
System.out.println("个推推送所有手机用户服务器响应异常");
|
return null;
|
}
|
}
|
|
/**
|
* 透传消息模版
|
*
|
* @param title 标题
|
* @param content 内容
|
* @Author: lc
|
* @Date: 2020/4/26 13:46
|
*/
|
private static TransmissionTemplate getTransmissionTemplate(String title, String content) {
|
TransmissionTemplate template = new TransmissionTemplate();
|
/*设置APPID与APPKEY*/
|
template.setAppId(appId);
|
template.setAppkey(appKey);
|
/*透传消息设置，1为强制启动应用，客户端接收到消息后就会立即启动应用；2为等待应用启动*/
|
template.setTransmissionType(2);
|
template.setTransmissionContent(content);
|
/*ios消息推送*/
|
template.setAPNInfo(getAPNPayload());
|
|
Notify notify = new Notify();
|
// notify.setIntent("intent:#intent;action=android.intent.action.oppopush;package=cn.com.pconline.android.browser;component=cn.com.android.browser/cn.com.android.browser.push.MultivendorPushActivity;S.protocol=pconlinebrowser://information-article/8270922;end");
|
notify.setIntent("intent:#Intent;action=android.intent.action.oppopush;launchFlags=0x14000000;component=com.liuqit.notebook/io.dcloud.PandoraEntry;S.UP-OL-SU=true;S.title=" + title + ";S.content=" + content + ";S.payload=" + content + ";end");
|
notify.setTitle(title);
|
notify.setContent(content);
|
/*第三方*/
|
template.set3rdNotifyInfo(notify);
|
return template;
|
}
|
|
private static SingleMessage getSingleMessage(AbstractTemplate template) {
|
SingleMessage message = new SingleMessage();
|
message.setData(template);
|
// 设置消息离线，并设置离线时间
|
message.setOffline(true);
|
// 离线有效时间，单位为毫秒，可选
|
message.setOfflineExpireTime(72 * 3600 * 1000);
|
message.setPriority(1);
|
// 判断客户端是否wifi环境下推送。1为仅在wifi环境下推送，0为不限制网络环境，默认不限
|
message.setPushNetWorkType(0);
|
return message;
|
}
|
|
private static APNPayload getAPNPayload() {
|
APNPayload payload = new APNPayload();
|
//在已有数字基础上加1显示，设置为-1时，在已有数字上减1显示，设置为数字时，显示指定数字
|
payload.setAutoBadge("+1");
|
payload.setContentAvailable(1);
|
//ios 12.0 以上可以使用 Dictionary 类型的 sound
|
payload.setSound("default");
|
payload.setCategory("$由客户端定义");
|
payload.addCustomMsg("由客户自定义消息key", "由客户自定义消息value");
|
|
//简单模式APNPayload.SimpleMsg
|
payload.setAlertMsg(new APNPayload.SimpleAlertMsg("hello"));
|
// payload.setAlertMsg(getDictionaryAlertMsg()); //字典模式使用APNPayload.DictionaryAlertMsg
|
|
//设置语音播报类型，int类型，0.不可用 1.播放body 2.播放自定义文本
|
payload.setVoicePlayType(0);
|
|
return payload;
|
}
|
|
}
|
