极光推送官网的web推送页面
因为是对接它的api，所以我参照这这个样式实现了一个，效果如下：
- 定时任务推送界面，可定制。实现了推送一次和每日定时推送，如果再扩展的话有每周、每月的功能，只是没有这个业务需求。
- 普通的单次消息推送
极光的官方文档地址：https://docs.jiguang.cn/jpush/server/push/rest_api_v3_push
如果实在没看懂的话，也可以到官方的代码仓库把demo下下来看，有很多案例。地址：https://github.com/jpush/jpush-api-java-client.git。首先我们需要创建自己的应用程序，会给出appKey和masterSecret。
下面贴一下我这边的关键代码，业务代码就省略了，具体可以根据自己的业务来实现
首先是引入jar包，由于我的是springcloud项目，所以其他的引用就省略了。
pom.xml
<dependency>
<groupId>cn.jpush.api</groupId>
<artifactId>jpush-client</artifactId>
<version>3.6.6</version>
</dependency>
如果报错的话，可能还需要引入以下依赖
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.5.3</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
<version>4.1.6.Final</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.3</version>
</dependency>
通用的常量 Constants，用来判断是否设置为生产环境
/**
* 生产环境标识
*/
public static final String PROD_ENV = "prod";
极光推送配置的读取，使用的是nacos作为配置中心，当然也可以写到本地
JPushConfig
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
/**
* 极光推送配置
* @author:
* @date: 2023/1/4
*/
@Data
@Component
@ConfigurationProperties(prefix = "jpush.push")
public class JPushConfig {
/**
* AppKey
*/
private String appKey;
/**
* 密钥
*/
private String masterSecret;
/**
* 离线消息保留时长(秒)
*/
private int liveTime;
/**
* 回调url
*/
private String callback;
}
极光推送的常量
JPushConstants
package com.xx.config;
/**
* JPush常量
* @author:
* @date: 2023/1/4
*/
public class JPushConstants {
/** 任务类型 */
/** 普通类型 */
public static final String TASK_TYPE_COMMON = "common";
/** 定时任务 */
public static final String TASK_TYPE_SCHEDULE = "schedule";
/** 指定推送平台 */
public static final String PLATFORM_ALL = "all";
public static final String PLATFORM_ANDROID = "android";
public static final String PLATFORM_IOS = "ios";
public static final String PLATFORM_WINPHONE = "winphone";
public static final String PLATFORM_ANDROID_IOS = "android_ios";
public static final String PLATFORM_ANDROID_WINPHONE = "android_winphone";
public static final String PLATFORM_IOS_WINPHONE = "ios_winphone";
/** 指定推送目标 */
/** 广播推送（全部设备） */
public static final String AUDIENCE_ALL = "all";
/** 标签推送，多个标签之间是 OR 的关系，即取并集。一次推送最多 20 个。 */
public static final String AUDIENCE_TAG_AND = "tag_and";
/** 标签推送，多个标签之间是 AND 关系，即取交集。一次推送最多 20 个。 */
public static final String AUDIENCE_TAG_NOT = "tag_not";
/** 标签推送，多个标签之间，先取多标签的并集，再对该结果取补集。一次推送最多 20 个。 */
public static final String AUDIENCE_TAG = "tag";
/** 别名推送，多个别名之间是 OR 关系，即取并集。一次推送最多 1000 个。 */
public static final String AUDIENCE_ALIAS = "alias";
/** 注册ID推送，多个注册ID之间是 OR 关系，即取并集。一次推送最多 1000 个。 */
public static final String AUDIENCE_REGISTRATION_ID = "registration_id";
/** 用户分群ID推送，定义为数组，但目前限制一次只能推送一个。 */
public static final String AUDIENCE_SEGMENT = "segment";
/** A/B Test ID推送，定义为数组，但目前限制是一次只能推送一个。 */
public static final String AUDIENCE_ABTEST = "abtest";
/** 指定通知对象 */
public static final String NOTIFICATION_ANDROID = "android";
public static final String NOTIFICATION_IOS = "ios";
public static final String NOTIFICATION_ANDROID_IOS = "android_ios";
public static final String NOTIFICATION_WINPHONE = "winphone";
}
从前端传入的附加字段Bean
Extra
@Data
public class Extra {
String label;
String value;
}
从前端传入的推送消息Bean，下面出现的SysMessage结构与其类似，故省略。
PushBean
import com.fasterxml.jackson.annotation.JsonInclude;
import lombok.Data;
import javax.validation.constraints.NotBlank;
import java.util.List;
import java.util.Map;
/**
* @author:
* @date: 2023/1/4
*/
@Data
public class PushBean {
/**
* 主键
*/
private Long id;
/**
* 必填, 通知内容, 内容可以为空字符串，则表示不展示到通知栏
*/
@NotBlank
private String content;
/**
* 可选, 附加信息, 供业务使用
*/
private List<Extra> extras;
/**
* android专用 可选, 通知标题，如果指定了，则通知里原来展示 App名称的地方，将展示成这个字段
*/
private String title;
/**
* 指定推送平台
*/
private String platform;
/**
* 指定推送范围
*/
private String audience;
/**
* 指定推送目标
*/
private List<String> audienceValues;
/**
* 任务类型: common(普通类型)、schedule(定时任务)
*/
private String taskType;
/**
* 定时推送
*/
private String time;
/**
* 请求参数
*/
@JsonInclude(JsonInclude.Include.NON_EMPTY)
private Map<String, String> params;
}
极光推送的关键代码，这里包含了推送业务和数据库的存储、读取（代码省略）。
JPushService
import cn.jiguang.common.ClientConfig;
import cn.jiguang.common.ServiceHelper;
import cn.jiguang.common.connection.NativeHttpClient;
import cn.jiguang.common.resp.APIConnectionException;
import cn.jiguang.common.resp.APIRequestException;
import cn.jiguang.common.resp.DefaultResult;
import cn.jpush.api.JPushClient;
import cn.jpush.api.push.PushResult;
import cn.jpush.api.push.model.*;
import cn.jpush.api.push.model.audience.Audience;
import cn.jpush.api.push.model.notification.AndroidNotification;
import cn.jpush.api.push.model.notification.IosNotification;
import cn.jpush.api.push.model.notification.Notification;
import cn.jpush.api.report.MessagesResult;
import cn.jpush.api.report.ReceivedsResult;
import cn.jpush.api.schedule.ScheduleMsgIdsResult;
import cn.jpush.api.schedule.ScheduleResult;
import com.alibaba.fastjson.JSONObject;
import com.google.common.collect.Lists;
import com.google.gson.JsonObject;
import com.xx.common.Constants;
import com.xx.exception.ServiceException;
import com.xx.utils.id.UUID;
import com.xx.utils.SecurityUtils;
import com.xx.config.JPushConfig;
import com.xx.config.JPushConstants;
import com.xx.domain.Extra;
import com.xx.domain.PushBean;
import com.xx.domain.SysMessage;
import com.xx.domain.SysMessageTarget;
import com.xx.mapper.SysMessageMapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* 极光推送
* 封装第三方API
*
* @author:
* @date: 2023/1/4
*/
@Service
@Slf4j
public class JPushService {
@Value("${spring.profiles.active}")
private String profile;
/**
* 一次推送最大数量 (极光限制1000)
*/
private static final int MAX_SIZE = 1000;
@Autowired
private JPushConfig config;
@Autowired
private SysMessageMapper messageMapper;
/**
* 向所有用户推送push消息
*
* @param pushBean
* @return boolean
*/
public boolean sendPush(PushBean pushBean) {
SysMessage message = genSysMessage(pushBean);
// 默认全部用户
pushBean.setAudience(JPushConstants.AUDIENCE_ALL);
PushPayload payload = buildPushPayload(pushBean, null, message.getCode());
message.setSendNo(payload.getSendno());
message.setPayload(payload.toString());
boolean result;
if (JPushConstants.TASK_TYPE_COMMON.equals(pushBean.getTaskType())) {
result = sendPush(payload, message);
} else {
//定时推送
String time = pushBean.getTime();
Map<String, String> params = pushBean.getParams();
result = createSchedule(params, time, payload, message);
}
if (pushBean.getId() != null) {
messageMapper.updateMessage(message);
} else {
messageMapper.insertMessage(message);
}
return result;
}
/**
* 分批推送push消息
*
* @param pushBean
* @param audienceValues
* @return boolean
*/
public boolean sendPush(PushBean pushBean, List<String> audienceValues) {
SysMessage message = genSysMessage(pushBean);
boolean result = false;
//由于jpush接口最大限制1000，需要分批推送
List<List<String>> partition = Lists.partition(audienceValues, MAX_SIZE);
// 推送push消息
for (List<String> values : partition) {
// 构建推送对象
PushPayload payload = buildPushPayload(pushBean, values, message.getCode());
message.setPayload(payload.toString());
if (StringUtils.isBlank(message.getSendNo())) {
message.setSendNo(payload.getSendno());
}
if (JPushConstants.TASK_TYPE_COMMON.equals(pushBean.getTaskType())) {
result = sendPush(payload, message);
} else {
//定时推送
String time = pushBean.getTime();
Map<String, String> params = pushBean.getParams();
result = createSchedule(params, time, payload, message);
}
if (result) {
if (pushBean.getId() != null) {
//如果是修改，则把历史数据全部删除，然后再重新插入
SysMessage sysMessage = messageMapper.getMessageById(pushBean.getId());
messageMapper.deleteMessageTargetByCode(sysMessage.getCode());
}
// 批量保存指定用户的ID
List<SysMessageTarget> list = new ArrayList<>(MAX_SIZE);
values.forEach(item -> {
SysMessageTarget target = new SysMessageTarget();
target.setCode(message.getCode());
//未读状态
target.setStatus(0);
target.setTarget(item);
list.add(target);
});
messageMapper.batchAddMessageTarget(list);
}
}
if (pushBean.getId() != null) {
messageMapper.updateMessage(message);
} else {
messageMapper.insertMessage(message);
}
return result;
}
/**
* 定时推送push消息
*
* @param time 定时
* @param payload 推送对象
* @return int
*/
public boolean createSchedule(Map<String, String> params, String time, PushPayload payload, SysMessage message) {
log.info("开始定时推送push消息:{}", payload);
JPushClient jpushClient = buildJPushClient();
try {
ScheduleResult result;
if (params == null || params.isEmpty()) {
// 定时推送
String name = "schedule_push_task";
result = jpushClient.createSingleSchedule(name, time, payload, config.getMasterSecret(), config.getAppKey());
} else {
// 每日定时推送
String name = "daily_schedule_push_task";
// 开始日期
String start = params.get("start");
// 结束日期
String end = params.get("end");
message.setStart(start);
message.setEnd(end);
result = jpushClient.createDailySchedule(name, start, end, time, payload, config.getMasterSecret(), config.getAppKey());
}
log.info("定时推送请求完成: {}", result);
message.setTime(time);
message.setScheduleId(result.getSchedule_id());
message.setEnabled(result.isResultOK());
message.setStatus(result.isResultOK() ? 0 : 1);
return result.isResultOK();
} catch (APIConnectionException e) {
log.error("Connection error. Should retry later. ", e);
throw new ServiceException(e.getMessage());
} catch (APIRequestException e) {
log.error("Error response from JPush server. Should review and fix it. ", e);
log.info("Error Code: " + e.getErrorCode());
throw new ServiceException(e.getErrorMessage());
}
}
/**
* 推送push消息
*
* @param payload 推送对象
* @return int
*/
public boolean sendPush(PushPayload payload, SysMessage message) {
log.info("开始推送push消息:{}", payload);
JPushClient jpushClient = buildJPushClient();
try {
PushResult result = jpushClient.sendPush(payload);
log.info("推送请求完成: {}", result);
message.setMsgId(result.msg_id + "");
message.setStatus(result.isResultOK() ? 0 : 1);
return result.isResultOK();
} catch (APIConnectionException e) {
log.error("Connection error. Should retry later. ", e);
throw new ServiceException(e.getMessage());
} catch (APIRequestException e) {
log.error("Error response from JPush server. Should review and fix it. {}", e.getErrorMessage());
log.info("Error Code: " + e.getStatus());
throw new ServiceException(e.getErrorMessage());
}
}
/**
* 生成JpushClient
*
* @return
*/
private JPushClient buildJPushClient() {
ClientConfig clientConfig = ClientConfig.getInstance();
// ClientConfig.getInstance().setPushHostName("https://api.jpush.cn/v3/push");
// ClientConfig.getInstance().setPushHostName("https://bjapi.push.jiguang.cn");
clientConfig.setMaxRetryTimes(5);
// 10 seconds
clientConfig.setConnectionTimeout(10 * 1000);
// JPush server supports SSLv3, TLSv1, TLSv1.1, TLSv1.2
clientConfig.setSSLVersion("TLSv1.2");
String authCode = ServiceHelper.getBasicAuthorization(config.getAppKey(), config.getMasterSecret());
NativeHttpClient httpClient = new NativeHttpClient(authCode, null, clientConfig);
JPushClient jpushClient = new JPushClient(config.getMasterSecret(), config.getAppKey(), null, clientConfig);
jpushClient.getPushClient().setHttpClient(httpClient);
return jpushClient;
}
/**
* 构建推送对象
*
* @param pushBean 参数
* @return PushPayload
*/
private PushPayload buildPushPayload(PushBean pushBean, List<String> audienceValues, String code) {
List<Extra> extrasArr = pushBean.getExtras();
Map<String, String> extras = CollectionUtils.isEmpty(extrasArr) ? null : extrasArr.stream().collect(Collectors.toMap(Extra::getLabel, Extra::getValue));
return PushPayload.newBuilder()
// Platform指定推送平台
.setPlatform(buildPlatform(pushBean.getPlatform()))
// Audience指定推送目标
.setAudience(buildAudience(pushBean.getAudience(), audienceValues))
// Notification推送通知内容体
.setNotification(buildNotification(pushBean, extras))
// 构建回调信息
.addCustom("callback", buildCallback(config.getCallback(), code))
// Message推送通知内容体
.setMessage(buildMessage(pushBean.getContent(), extras))
// 应用内提醒，当用户前台运行 APP 时，会通过应用内消息的方式展示通知栏消息内容
.setInappMessage(InappMessage.newBuilder().setInappMessage(true).build())
// Options推送参数，设置离线消息保留时长
.setOptions(Options.newBuilder()
//推送当前用户不在线时，为该用户保留多长时间的离线消息，以便其上线时再次推送。默认 86400 （1 天）
.setTimeToLive(config.getLiveTime())
//该字段仅对 iOS 的 Notification 有效, true：表示推送生产环境。false：表示推送开发环境, 默认
.setApnsProduction(Constants.PROD_ENV.equals(profile))
//API 调用标识
//.setSendno()
.build())
.build();
}
/**
* 构建通知内容体
*
* @param pushBean 通知
* @param extras 扩展字段
* @return Notification
*/
private Notification buildNotification(PushBean pushBean, Map<String, String> extras) {
Notification.Builder notification = Notification.newBuilder()
// alert通知，推送到Platform指定的多个平台
.setAlert(pushBean.getContent())
// 构建Android平台上的通知结构
.addPlatformNotification(androidNotificationBuilder(pushBean, extras))
// 构建iOS平台上的通知结构
.addPlatformNotification(iosNotificationBuilder(pushBean, extras));
return notification.build();
}
/**
* 构建通知内容体
*
* @param message 通知内容
* @param extras 扩展字段
* @return Notification
*/
private Message buildMessage(String message, Map<String, String> extras) {
if (extras == null || extras.isEmpty()) {
return Message.newBuilder().setMsgContent(message).build();
}
return Message.newBuilder().setMsgContent(message).addExtras(extras).build();
}
/**
* 处理附加信息
*
* @param extras
* @return
*/
private IosNotification iosNotificationBuilder(PushBean pushBean, Map<String, String> extras) {
if (extras == null || extras.isEmpty()) {
return IosNotification.newBuilder()
.setAlert(pushBean.getContent())
.incrBadge(1)
.build();
}
return IosNotification.newBuilder()
.setAlert(pushBean.getContent())
//通知扩展,说明是支持 iOS 10 的 UNNotificationServiceExtension
//.setMutableContent(true)
.incrBadge(1)
// 这个 key（my-attachment）值，需要与客户端的值对应，客户端工程拿到 key 值对应的 url 图标加载出来
// .addExtra("my-attachment","https://raw.githubusercontent.com/Tikon/imgRepo/master/ic_launcher.png")
.addExtras(extras)
.build();
}
/**
* 处理附加信息
*
* @param extras
* @return
*/
private AndroidNotification androidNotificationBuilder(PushBean pushBean, Map<String, String> extras) {
String title = pushBean.getTitle();
String msg = pushBean.getContent();
//文本条目通知栏样式
JsonObject inbox = new JsonObject();
inbox.addProperty("key", "value");
//跳转路径,应用首页
JsonObject intent = new JsonObject();
intent.addProperty("url", "intent:#Intent;action=android.intent.action.MAIN;end");
if (extras == null || extras.isEmpty()) {
return AndroidNotification.newBuilder()
//通知内容
.setAlert(msg)
//通知提醒方式, 可选范围为 -1～7 ，默认-1, 即0111二进制，左数第二位代表 light,第三位代表 vibrate，第四位代表 sound。 0：不生效，1：生效
.setAlertType(-1)
//通知标题
.setTitle(title)
//通知栏展示优先级，默认为 0，范围为 -2～2
.setPriority(0)
//通知栏样式类型,默认为 0, 1-bigText; 2-Inbox; 3-bigPicture
//.setStyle(3)
//大文本通知栏样式,style=1时生效
//.setBigText(msg)
//文本条目通知栏样式,style=2时生效,json 的每个 key 对应的 value 会被当作文本条目逐条展示
//.setInbox(inbox)
//大图片通知栏样式,style=3时生效
//.setBigPicPath("")
//通知栏大图标
//.setLargeIcon("")
//通知栏小图标
//.setSmallIconUri("")
//指定跳转页面,三种类型:
// 1. 跳转到目标页: intent:#Intent;action=action 路径;component= 包名 /Activity 全名;end （OPPO 和 FCM 通道必须传 "action 路径", 其他厂商必须传 "Activity 全名", 否则将出现对应厂商无法跳转问题）
// 2. 跳转到deeplink地址: scheme://test?key1=val1&key2=val2
// 3. 应用首页: intent:#Intent;action=android.intent.action.MAIN;end (固定为此地址)
//.setIntent(intent)
//通知栏样式 ID
.setBuilderId(2)
//定时展示开始时间（yyyy-MM-dd HH:mm:ss），默认立即展示
//.setShowBeginTime("")
.build();
}
return AndroidNotification.newBuilder()
//通知内容
.setAlert(msg)
//通知提醒方式, 可选范围为 -1～7 ，默认-1, 即0111二进制，左数第二位代表 light,第三位代表 vibrate，第四位代表 sound。 0：不生效，1：生效
.setAlertType(-1)
//通知标题
.setTitle(title)
//通知栏展示优先级，默认为 0，范围为 -2～2
.setPriority(0)
//通知栏样式类型,默认为 0, 1-bigText; 2-Inbox; 3-bigPicture
//.setStyle(3)
//大文本通知栏样式,style=1时生效
//.setBigText(msg)
//文本条目通知栏样式,style=2时生效,json 的每个 key 对应的 value 会被当作文本条目逐条展示
//.setInbox(inbox)
//大图片通知栏样式,style=3时生效
//.setBigPicPath("https://lmg.jj20.com/up/allimg/1114/040221103339/210402103339-10-1200.jpg")
//通知栏大图标
//.setLargeIcon("")
//通知栏小图标
//.setSmallIconUri("")
//指定跳转页面,三种类型:
// 1. 跳转到目标页: intent:#Intent;action=action 路径;component= 包名 /Activity 全名;end （OPPO 和 FCM 通道必须传 "action 路径", 其他厂商必须传 "Activity 全名", 否则将出现对应厂商无法跳转问题）
// 2. 跳转到deeplink地址: scheme://test?key1=val1&key2=val2
// 3. 应用首页: intent:#Intent;action=android.intent.action.MAIN;end (固定为此地址)
//.setIntent(intent)
//通知栏样式 ID
.setBuilderId(2)
//定时展示开始时间（yyyy-MM-dd HH:mm:ss），默认立即展示
//.setShowBeginTime("")
//扩展字段
.addExtras(extras)
.build();
}
/**
* 构建推送平台
*
* @param platform 指定推送平台
* @return Platform
*/
private Platform buildPlatform(String platform) {
switch (platform) {
case JPushConstants.PLATFORM_ANDROID:
return Platform.android();
case JPushConstants.PLATFORM_IOS:
return Platform.ios();
case JPushConstants.PLATFORM_WINPHONE:
return Platform.winphone();
case JPushConstants.PLATFORM_ANDROID_IOS:
return Platform.android_ios();
case JPushConstants.PLATFORM_ANDROID_WINPHONE:
return Platform.android_winphone();
case JPushConstants.PLATFORM_IOS_WINPHONE:
return Platform.ios_winphone();
default:
return Platform.all();
}
}
/**
* 构建推送目标
*
* @param audience 指定推送范围
* @param audienceValues 指定推送目标
* @return Audience
*/
private Audience buildAudience(String audience, List<String> audienceValues) {
switch (audience) {
case JPushConstants.AUDIENCE_TAG:
return Audience.tag(audienceValues);
case JPushConstants.AUDIENCE_TAG_AND:
return Audience.tag_and(audienceValues);
case JPushConstants.AUDIENCE_TAG_NOT:
return Audience.tag_not(audienceValues);
case JPushConstants.AUDIENCE_ALIAS:
return Audience.alias(audienceValues);
case JPushConstants.AUDIENCE_REGISTRATION_ID:
return Audience.registrationId(audienceValues);
case JPushConstants.AUDIENCE_SEGMENT:
return Audience.segment(audienceValues);
case JPushConstants.AUDIENCE_ABTEST:
return Audience.abTest(audienceValues);
default:
return Audience.all();
}
}
/**
* 构建回调信息
*
* @return
*/
private JsonObject buildCallback(String url, String code) {
JsonObject callback = new JsonObject();
//回调url
callback.addProperty("url", url);
JsonObject params = new JsonObject();
//唯一标识
params.addProperty("code", code);
callback.add("params", params);
// 可选，1: 送达回执, 2: 点击回执, 3: 送达和点击回执, 8: 推送成功回执, 9: 成功和送达回执, 10: 成功和点击回执, 11: 成功和送达以及点击回执
callback.addProperty("type", 3);
return callback;
}
/**
* 装配SysMessage
*
* @param pushBean 前端传的参数
* @return SysMessage
*/
private SysMessage genSysMessage(PushBean pushBean) {
SysMessage message = new SysMessage();
if (pushBean.getId() != null) {
message = messageMapper.getMessageById(pushBean.getId());
} else {
message.setCode(UUID.fastUUID().toString(true));
}
message.setAudience(pushBean.getAudience());
message.setContent(pushBean.getContent());
message.setTitle(pushBean.getTitle());
message.setPlatform(pushBean.getPlatform());
message.setType("notification");
message.setTaskType(pushBean.getTaskType());
if (!CollectionUtils.isEmpty(pushBean.getExtras())) {
message.setExtras(JSONObject.toJSONString(pushBean.getExtras()));
}
message.setCreateBy(SecurityUtils.getUsername());
return message;
}
/**
* 撤回推送消息
*
* @param msgId
* @return
* @throws APIConnectionException
* @throws APIRequestException
*/
public boolean delMessage(String msgId) {
try {
JPushClient jpushClient = buildJPushClient();
DefaultResult result = jpushClient.deletePush(msgId);
log.info("撤回推送消息请求完成: {}", result);
return result.isResultOK();
} catch (APIConnectionException e) {
log.error("Connection error. Should retry later. ", e);
throw new ServiceException(e.getMessage());
} catch (APIRequestException e) {
log.error("Error response from JPush server. Should review and fix it. {}", e.getErrorMessage());
log.info("Error Code: " + e.getStatus());
throw new ServiceException(e.getErrorMessage());
}
}
/**
* 删除定时任务
*
* @param scheduleId
* @return
* @throws APIConnectionException
* @throws APIRequestException
*/
public boolean delSchedule(String scheduleId) {
try {
JPushClient jpushClient = buildJPushClient();
jpushClient.deleteSchedule(scheduleId);
return Boolean.TRUE;
} catch (APIConnectionException e) {
log.error("Connection error. Should retry later. ", e);
throw new ServiceException(e.getMessage());
} catch (APIRequestException e) {
log.error("Error response from JPush server. Should review and fix it. {}", e.getErrorMessage());
log.info("Error Code: " + e.getStatus());
throw new ServiceException(e.getErrorMessage());
}
}
/**
* 禁用定时任务
*
* @param scheduleId
* @return
* @throws APIConnectionException
* @throws APIRequestException
*/
public boolean disableSchedule(String scheduleId) {
try {
JPushClient jpushClient = buildJPushClient();
ScheduleResult result = jpushClient.disableSchedule(scheduleId);
log.info("禁用定时任务请求完成: {}", result);
boolean ok = result.isResultOK();
return ok;
} catch (APIConnectionException e) {
log.error("Connection error. Should retry later. ", e);
throw new ServiceException(e.getMessage());
} catch (APIRequestException e) {
log.error("Error response from JPush server. Should review and fix it. {}", e.getErrorMessage());
log.info("Error Code: " + e.getStatus());
throw new ServiceException(e.getErrorMessage());
}
}
/**
* 启用定时任务
*
* @param scheduleId
* @return
* @throws APIConnectionException
* @throws APIRequestException
*/
public boolean enableSchedule(String scheduleId) {
try {
JPushClient jpushClient = buildJPushClient();
ScheduleResult result = jpushClient.enableSchedule(scheduleId);
log.info("启用定时任务请求完成: {}", result);
boolean ok = result.isResultOK();
return ok;
} catch (APIConnectionException e) {
log.error("Connection error. Should retry later. ", e);
throw new ServiceException(e.getMessage());
} catch (APIRequestException e) {
log.error("Error response from JPush server. Should review and fix it. {}", e.getErrorMessage());
log.info("Error Code: " + e.getStatus());
throw new ServiceException(e.getErrorMessage());
}
}
/**
* 获取定时任务的的msgIds
*
* @param scheduleId
* @return
* @throws APIConnectionException
* @throws APIRequestException
*/
public ScheduleMsgIdsResult getScheduleMsgIds(String scheduleId) {
try {
JPushClient jpushClient = buildJPushClient();
ScheduleMsgIdsResult result = jpushClient.getScheduleMsgIds(scheduleId);
log.info("获取定时任务的的msgIds请求完成: {}", result);
return result;
} catch (APIConnectionException e) {
log.error("Connection error. Should retry later. ", e);
throw new ServiceException(e.getMessage());
} catch (APIRequestException e) {
log.error("Error response from JPush server. Should review and fix it. {}", e.getErrorMessage());
log.info("Error Code: " + e.getStatus());
throw new ServiceException(e.getErrorMessage());
}
}
/**
* 根据msgId获取推送统计
*
* @param msgId
* @return
* @throws APIConnectionException
* @throws APIRequestException
*/
public ReceivedsResult getReport(String msgId) {
try {
JPushClient jpushClient = buildJPushClient();
ReceivedsResult result = jpushClient.getReportReceiveds(msgId);
//测试账号没有下面这个api的权限，会报错
MessagesResult messages = jpushClient.getReportMessages(msgId);
return result;
} catch (APIConnectionException e) {
log.error("Connection error. Should retry later. ", e);
throw new ServiceException(e.getMessage());
} catch (APIRequestException e) {
log.error("Error response from JPush server. Should review and fix it. {}", e.getErrorMessage());
log.info("Error Code: " + e.getStatus());
throw new ServiceException(e.getErrorMessage());
}
}
}
本篇就介绍到这里了。
