package cn.gistack.alerts.push.utils;
|
|
import com.alibaba.csp.sentinel.util.IdUtil;
|
import com.getui.push.v2.sdk.api.PushApi;
|
import com.getui.push.v2.sdk.common.ApiResult;
|
import com.getui.push.v2.sdk.dto.req.Audience;
|
import com.getui.push.v2.sdk.dto.req.Settings;
|
import com.getui.push.v2.sdk.dto.req.Strategy;
|
import com.getui.push.v2.sdk.dto.req.message.PushBatchDTO;
|
import com.getui.push.v2.sdk.dto.req.message.PushChannel;
|
import com.getui.push.v2.sdk.dto.req.message.PushDTO;
|
import com.getui.push.v2.sdk.dto.req.message.PushMessage;
|
import com.getui.push.v2.sdk.dto.req.message.android.AndroidDTO;
|
import com.getui.push.v2.sdk.dto.req.message.android.GTNotification;
|
import com.getui.push.v2.sdk.dto.req.message.android.ThirdNotification;
|
import com.getui.push.v2.sdk.dto.req.message.android.Ups;
|
import com.getui.push.v2.sdk.dto.req.message.ios.Alert;
|
import com.getui.push.v2.sdk.dto.req.message.ios.Aps;
|
import com.getui.push.v2.sdk.dto.req.message.ios.IosDTO;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.UUID;
|
|
@Slf4j
|
@Component
|
public class GeTuiUtils {
|
|
@Resource(name = "myPushApi")
|
private PushApi myPushApi;
|
|
private final String APP_PACKAGE_NAME = "com.hubei.jingchuReservoir";
|
|
/**
|
* 单点推送（离线不推送）
|
*
|
* @param cid 目标
|
* @param title 标题
|
* @param content 内容
|
*/
|
public void pushMsg(String cid, String title, String content) {
|
//根据cid进行单推
|
PushDTO<Audience> pushDTO = new PushDTO<>();
|
// 设置推送参数
|
pushDTO.setRequestId(UUID.randomUUID().toString());
|
// 个推推送消息参数
|
PushMessage pushMessage = new PushMessage();
|
pushDTO.setPushMessage(pushMessage);
|
/** 带跳转url*/
|
// GTNotification notification = new GTNotification();
|
// pushMessage.setNotification(notification);
|
// notification.setTitle(title + new Date());
|
// notification.setBody(content);
|
// notification.setClickType("url");
|
// notification.setUrl("https://www.baidu.com");// 跳转地址
|
/** 不带跳转url*/
|
pushMessage.setTransmission(" {title:\"" + title + "\",content:\"" + content + "\",payload:\"自定义数据\"}");
|
pushDTO.setPushMessage(pushMessage);
|
// 设置接收人信息
|
Audience audience = new Audience();
|
pushDTO.setAudience(audience);
|
audience.addCid(cid);
|
// 进行cid单推
|
ApiResult<Map<String, Map<String, String>>> apiResult = myPushApi.pushToSingleByCid(pushDTO);
|
if (apiResult.isSuccess()) {
|
// success
|
System.out.println(apiResult.getData());
|
} else {
|
// failed
|
System.out.println("code:" + apiResult.getCode() + ", msg: " + apiResult.getMsg());
|
}
|
}
|
|
/**
|
* 推送给多个
|
*
|
* @param cids 目标集
|
* @param title 标题
|
* @param content 内容
|
*/
|
public Boolean pushMsg(List<String> cids, String title, String content) {
|
List<PushDTO<Audience>> list = new ArrayList<>(cids.size());
|
cids.forEach(cid -> {
|
PushDTO<Audience> pushDTO = new PushDTO<>();
|
// 唯一标识
|
pushDTO.setRequestId(UUID.randomUUID().toString());
|
// 消息内容
|
PushMessage pushMessage = new PushMessage();
|
pushMessage.setNetworkType(0);
|
// 透传消息内容
|
// pushMessage.setTransmission(" {title:\"" + title + "\",content:\"" + content + "\",payload:\"自定义数据\"}");
|
|
GTNotification gtNotification = new GTNotification();
|
pushMessage.setNotification(gtNotification);
|
gtNotification.setTitle(title);
|
gtNotification.setBody(content);
|
gtNotification.setClickType("none");
|
|
|
pushDTO.setPushMessage(pushMessage);
|
// 消息接受人
|
Audience audience = new Audience();
|
audience.addCid(cid);
|
pushDTO.setAudience(audience);
|
list.add(pushDTO);
|
});
|
PushBatchDTO pushBatchDTO = new PushBatchDTO();
|
pushBatchDTO.setAsync(true);
|
pushBatchDTO.setMsgList(list);
|
ApiResult<Map<String, Map<String, String>>> mapApiResult = myPushApi.pushBatchByCid(pushBatchDTO);
|
if (mapApiResult.isSuccess()) {
|
// success
|
System.out.println(mapApiResult.getData());
|
} else {
|
// failed
|
System.out.println("code:" + mapApiResult.getCode() + ", msg: " + mapApiResult.getMsg());
|
}
|
|
return mapApiResult.isSuccess();
|
|
}
|
|
/**
|
* 消息推送（离线推送）
|
*
|
* @param cid 目标
|
* @param title 标题
|
* @param content 内容
|
*/
|
public void offlinePushMsg(String cid, String title, String content) {
|
//根据cid进行单推
|
PushDTO<Audience> pushDTO = new PushDTO<>();
|
// 设置推送参数
|
pushDTO.setRequestId(System.currentTimeMillis() + "");//requestid需要每次变化唯一
|
//配置推送条件
|
// 1: 表示该消息在用户在线时推送个推通道，用户离线时推送厂商通道;
|
// 2: 表示该消息只通过厂商通道策略下发，不考虑用户是否在线;
|
// 3: 表示该消息只通过个推通道下发，不考虑用户是否在线；
|
// 4: 表示该消息优先从厂商通道下发，若消息内容在厂商通道代发失败后会从个推通道下发。
|
Strategy strategy = new Strategy();
|
strategy.setDef(1);
|
Settings settings = new Settings();
|
settings.setStrategy(strategy);
|
pushDTO.setSettings(settings);
|
settings.setTtl(3600000);//消息有效期，走厂商消息需要设置该值
|
//推送苹果离线通知标题内容
|
Alert alert = new Alert();
|
alert.setTitle(title);//苹果离线通知栏标题
|
alert.setBody(content);//苹果离线通知栏内容
|
Aps aps = new Aps();
|
//1表示静默推送(无通知栏消息)，静默推送时不需要填写其他参数。
|
//苹果建议1小时最多推送3条静默消息
|
aps.setContentAvailable(0);
|
aps.setSound("default");
|
aps.setAlert(alert);
|
IosDTO iosDTO = new IosDTO();
|
iosDTO.setAps(aps);
|
iosDTO.setType("notify");
|
|
|
PushChannel pushChannel = new PushChannel();
|
pushChannel.setIos(iosDTO);
|
//安卓离线厂商通道推送消息体
|
PushChannel pushChannel1 = new PushChannel();
|
AndroidDTO androidDTO = new AndroidDTO();
|
Ups ups = new Ups();
|
ThirdNotification notification1 = new ThirdNotification();
|
ups.setNotification(notification1);
|
notification1.setTitle(title);//安卓离线展示的标题
|
notification1.setBody(content);//安卓离线展示的内容
|
notification1.setClickType("intent");
|
notification1.setIntent("intent:#Intent;launchFlags=0x04000000;action=android.intent.action.oppopush;component=io.dcloud.HBuilder/io.dcloud.PandoraEntry;S.UP-OL-SU=true;S.title=测试标题;S.content=测试内容;S.payload=test;end");
|
//各厂商自有功能单项设置
|
//ups.addOption("HW", "/message/android/notification/badge/class", "io.dcloud.PandoraEntry ");
|
//ups.addOption("HW", "/message/android/notification/badge/add_num", 1);
|
//ups.addOption("HW", "/message/android/notification/importance", "HIGH");
|
//ups.addOption("VV","classification",1);
|
androidDTO.setUps(ups);
|
pushChannel1.setAndroid(androidDTO);
|
pushDTO.setPushChannel(pushChannel1);
|
|
// PushMessage在线走个推通道才会起作用的消息体
|
PushMessage pushMessage = new PushMessage();
|
pushDTO.setPushMessage(pushMessage);
|
pushMessage.setTransmission(" {title:\"" + title + "\",content:\"" + content + "\",payload:\"自定义数据\"}");
|
// 设置接收人信息
|
Audience audience = new Audience();
|
pushDTO.setAudience(audience);
|
audience.addCid(cid);// cid
|
// 进行cid单推
|
ApiResult<Map<String, Map<String, String>>> apiResult = myPushApi.pushToSingleByCid(pushDTO);
|
if (apiResult.isSuccess()) {
|
// success
|
System.out.println(apiResult.getData());
|
} else {
|
// failed
|
System.out.println("code:" + apiResult.getCode() + ", msg: " + apiResult.getMsg());
|
}
|
}
|
|
/**
|
* 官方api案例
|
*/
|
public void offlinePushMsg1() {
|
//根据cid进行单推
|
PushDTO<Audience> pushDTO = new PushDTO<Audience>();
|
// 设置推送参数
|
pushDTO.setRequestId(System.currentTimeMillis() + "");
|
/**** 设置个推通道参数 *****/
|
PushMessage pushMessage = new PushMessage();
|
pushDTO.setPushMessage(pushMessage);
|
GTNotification notification = new GTNotification();
|
pushMessage.setNotification(notification);
|
notification.setTitle("个title");
|
notification.setBody("个body");
|
notification.setClickType("url");
|
notification.setUrl("https://www.getui.com");
|
/**** 设置个推通道参数，更多参数请查看文档或对象源码 *****/
|
|
/**** 设置厂商相关参数 ****/
|
PushChannel pushChannel = new PushChannel();
|
pushDTO.setPushChannel(pushChannel);
|
/*配置安卓厂商参数*/
|
AndroidDTO androidDTO = new AndroidDTO();
|
pushChannel.setAndroid(androidDTO);
|
Ups ups = new Ups();
|
androidDTO.setUps(ups);
|
ThirdNotification thirdNotification = new ThirdNotification();
|
ups.setNotification(thirdNotification);
|
thirdNotification.setTitle("厂商title");
|
thirdNotification.setBody("厂商body");
|
thirdNotification.setClickType("url");
|
thirdNotification.setUrl("https://www.getui.com");
|
// 两条消息的notify_id相同，新的消息会覆盖老的消息，取值范围：0-2147483647
|
// thirdNotification.setNotifyId("11177");
|
/*配置安卓厂商参数结束，更多参数请查看文档或对象源码*/
|
|
/*设置ios厂商参数*/
|
IosDTO iosDTO = new IosDTO();
|
pushChannel.setIos(iosDTO);
|
// 相同的collapseId会覆盖之前的消息
|
iosDTO.setApnsCollapseId("xxx");
|
Aps aps = new Aps();
|
iosDTO.setAps(aps);
|
Alert alert = new Alert();
|
aps.setAlert(alert);
|
alert.setTitle("通知消息标题");
|
alert.setBody("通知消息内容");
|
/*设置ios厂商参数结束，更多参数请查看文档或对象源码*/
|
|
/*设置接收人信息*/
|
Audience audience = new Audience();
|
pushDTO.setAudience(audience);
|
audience.addCid("xxx");
|
/*设置接收人信息结束*/
|
/**** 设置厂商相关参数，更多参数请查看文档或对象源码 ****/
|
|
// 进行cid单推
|
ApiResult<Map<String, Map<String, String>>> apiResult = myPushApi.pushToSingleByCid(pushDTO);
|
if (apiResult.isSuccess()) {
|
// success
|
System.out.println(apiResult.getData());
|
} else {
|
// failed
|
System.out.println("code:" + apiResult.getCode() + ", msg: " + apiResult.getMsg());
|
}
|
}
|
|
/**
|
* 自定义消息批量推送，支持离线和在线推送
|
* @param cids
|
* @param title
|
* @param content
|
*/
|
public Boolean myPushMessage(List<String> cids,String title,String content){
|
List<PushDTO<Audience>> list = new ArrayList<>(cids.size());
|
cids.forEach(cid -> {
|
PushDTO<Audience> pushDTO = new PushDTO<>();
|
/**设置个推通道**/
|
// 唯一标识
|
pushDTO.setRequestId(UUID.randomUUID().toString());
|
// 消息内容
|
PushMessage pushMessage = new PushMessage();
|
//0无限制、1仅wifi
|
pushMessage.setNetworkType(0);
|
|
GTNotification gtNotification = new GTNotification();
|
pushMessage.setNotification(gtNotification);
|
gtNotification.setTitle(title);
|
gtNotification.setBody(content);
|
gtNotification.setClickType("none");
|
pushDTO.setPushMessage(pushMessage);
|
|
// 消息接受人
|
Audience audience = new Audience();
|
audience.addCid(cid);
|
pushDTO.setAudience(audience);
|
/**设置个推通道结束**/
|
|
//配置推送条件
|
// 1: 表示该消息在用户在线时推送个推通道，用户离线时推送厂商通道;
|
// 2: 表示该消息只通过厂商通道策略下发，不考虑用户是否在线;
|
// 3: 表示该消息只通过个推通道下发，不考虑用户是否在线；
|
// 4: 表示该消息优先从厂商通道下发，若消息内容在厂商通道代发失败后会从个推通道下发。
|
Strategy strategy = new Strategy();
|
strategy.setDef(1);
|
Settings settings = new Settings();
|
settings.setStrategy(strategy);
|
pushDTO.setSettings(settings);
|
settings.setTtl(3600000);//消息有效期，走厂商消息需要设置该值
|
/**设置厂商通道**/
|
PushChannel pushChannel = new PushChannel();
|
/**设置Android配置**/
|
AndroidDTO androidDTO = new AndroidDTO();
|
Ups ups = new Ups();
|
ThirdNotification notification1 = new ThirdNotification();
|
ups.setNotification(notification1);
|
notification1.setTitle(title);//安卓离线展示的标题
|
notification1.setBody(content);//安卓离线展示的内容
|
notification1.setClickType("intent");
|
notification1.setIntent("intent:#Intent;launchFlags=0x04000000;action=android.intent.action.oppopush;component=com.hubei.jingchuReservoir/io.dcloud.PandoraEntry;S.UP-OL-SU=true;S.title="+title +";S.content="+content+";S.payload=test;end");
|
|
//对不同厂商进行配置
|
// ups.addOption("HW", "/message/android/notification/badge/class", "io.dcloud.PandoraEntry ");
|
ups.addOption("VV","/networkType",-1);
|
|
androidDTO.setUps(ups);
|
pushChannel.setAndroid(androidDTO);
|
/**设置Android配置结束**/
|
|
/**设置IOS配置**/
|
//推送苹果离线通知标题内容
|
Alert alert = new Alert();
|
alert.setTitle(title);//苹果离线通知栏标题
|
alert.setBody(content);//苹果离线通知栏内容
|
Aps aps = new Aps();
|
//1表示静默推送(无通知栏消息)，静默推送时不需要填写其他参数。
|
//苹果建议1小时最多推送3条静默消息
|
aps.setContentAvailable(0);
|
aps.setSound("default");
|
aps.setAlert(alert);
|
IosDTO iosDTO = new IosDTO();
|
iosDTO.setAps(aps);
|
iosDTO.setType("notify");
|
pushChannel.setIos(iosDTO);
|
/**设置IOS配置结束**/
|
pushDTO.setPushChannel(pushChannel);
|
/**设置厂商通道结束**/
|
|
|
list.add(pushDTO);
|
});
|
|
PushBatchDTO pushBatchDTO = new PushBatchDTO();
|
pushBatchDTO.setAsync(true);
|
pushBatchDTO.setMsgList(list);
|
|
|
//推送消息
|
ApiResult<Map<String, Map<String, String>>> mapApiResult = myPushApi.pushBatchByCid(pushBatchDTO);
|
|
return mapApiResult.isSuccess();
|
}
|
}
|
