qiubinghui
/
zhywpt-issuer
보기 1
좋아요 0
포크 0
코드 이슈 0 풀 리퀘스트 0 릴리즈 0 위키 Activity
소스 검색

极光推送相关代码

master
zouhantao 3 달 전
부모
cb3b19eeb4
커밋
c195df0184
5개의 변경된 파일과 122개의 추가작업 그리고 849개의 파일을 삭제
분할 보기 변경상태 보기
  1. 5
    5
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/ats/jpush/JPushServiceCmd.java
  2. 4
    6
      zhywpt-service-ats/src/main/java/cn/com/taiji/ats/manager/jpush/JpushAllAppManager.java
  3. 24
    16
      zhywpt-service-ats/src/main/java/cn/com/taiji/ats/manager/jpush/JpushAllAppManagerImpl.java
  4. 9
    27
      zhywpt-service-ats/src/main/java/cn/com/taiji/ats/model/jpush/JpushManager.java
  5. 80
    795
      zhywpt-service-ats/src/main/java/cn/com/taiji/ats/model/jpush/JpushManagerImpl.java

gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/ats/jpush/JpushServiceCmd.java → gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/ats/jpush/JPushServiceCmd.java 파일 보기

@@ -5,14 +5,14 @@ import cn.com.taiji.core.model.comm.protocol.SignServiceCommand;
import cn.com.taiji.core.model.comm.protocol.SignServiceType;
import cn.com.taiji.core.model.comm.protocol.ats.AtsServiceType;

public enum JpushServiceCmd implements SignServiceCommand {
JPUSHALLRIDNOTIFICATION("极光推送发送", JpushAllRidNotificationMessageRequest.class),
public enum JPushServiceCmd implements SignServiceCommand {
JPUSHALLRIDNOTIFICATION("极光推送发送", JPushSendMessageRequest.class),
;

private final String value;
private final Class<? extends AbstractSignTypeRequest<?>> reqClass;

JpushServiceCmd(String value, Class<? extends AbstractSignTypeRequest<?>> reqClass) {
JPushServiceCmd(String value, Class<? extends AbstractSignTypeRequest<?>> reqClass) {
this.value = value;
this.reqClass = reqClass;
}
@@ -22,8 +22,8 @@ public enum JpushServiceCmd implements SignServiceCommand {
return AtsServiceType.JPUSH;
}

public static JpushServiceCmd fromIfCode(String ifCode) {
return SignServiceCommand.fromName(JpushServiceCmd.class, SignServiceCommand.getCmdStr(ifCode));
public static JPushServiceCmd fromIfCode(String ifCode) {
return SignServiceCommand.fromName(JPushServiceCmd.class, SignServiceCommand.getCmdStr(ifCode));
}

@Override

+ 4
- 6
zhywpt-service-ats/src/main/java/cn/com/taiji/ats/manager/jpush/JpushAllAppManager.java 파일 보기

@@ -1,13 +1,11 @@
package cn.com.taiji.ats.manager.jpush;

import cn.com.taiji.common.manager.net.http.ServiceHandleException;
import cn.com.taiji.core.model.comm.protocol.ats.jpush.JpushAllRidNotificationMessageRequest;
import cn.com.taiji.core.model.comm.protocol.ats.jpush.JpushAllRidNotificationMessageResponse;


public interface JpushAllAppManager {
JpushAllRidNotificationMessageResponse jpushAllRidNotificationMessageHandler(JpushAllRidNotificationMessageRequest request) throws ServiceHandleException;
import cn.com.taiji.core.model.comm.protocol.ats.jpush.JPushSendMessageRequest;
import cn.com.taiji.core.model.comm.protocol.ats.jpush.JPushSendMessageResponse;


public interface JPushAllAppManager {
JPushSendMessageResponse jpushSendMessageHandler(JPushSendMessageRequest request) throws ServiceHandleException;

}

+ 24
- 16
zhywpt-service-ats/src/main/java/cn/com/taiji/ats/manager/jpush/JpushAllAppManagerImpl.java 파일 보기

@@ -1,24 +1,22 @@
package cn.com.taiji.ats.manager.jpush;

import cn.com.taiji.ats.api.TokenHelper;
import cn.com.taiji.ats.model.jpush.JpushManager;
import cn.com.taiji.common.manager.net.http.ServiceHandleException;
import cn.com.taiji.core.entity.dict.msgw.MessageJPushType;
import cn.com.taiji.core.model.comm.protocol.ats.jpush.JpushAllRidNotificationMessageRequest;
import cn.com.taiji.core.model.comm.protocol.ats.jpush.JpushAllRidNotificationMessageResponse;
import cn.com.taiji.core.model.comm.protocol.valid.GlyServiceError;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import cn.com.taiji.ats.api.TokenHelper;
import cn.com.taiji.ats.model.jpush.JPushManager;
import cn.com.taiji.common.manager.ManagerException;
import cn.com.taiji.common.manager.net.http.ServiceHandleException;
import cn.com.taiji.core.entity.dict.msgw.MessageJPushType;
import cn.com.taiji.core.model.comm.protocol.ats.jpush.JPushSendMessageRequest;
import cn.com.taiji.core.model.comm.protocol.ats.jpush.JPushSendMessageResponse;
import cn.com.taiji.core.model.comm.protocol.valid.GlyServiceError;

@Service
public class JpushAllAppManagerImpl implements JpushAllAppManager{
public class JPushAllAppManagerImpl implements JPushAllAppManager{

@Autowired
private JpushManager jpushManager;
private String apikeyPrefix = "PUSH_CHANNEL_";

private JPushManager jpushManager;
/**
* * 极光推送-指定的registrationId列表(android/ios)-通知栏通知和自定义消息
* @param request
@@ -26,16 +24,26 @@ public class JpushAllAppManagerImpl implements JpushAllAppManager{
* @throws ManagerException
*/
@Override
public JpushAllRidNotificationMessageResponse jpushAllRidNotificationMessageHandler(JpushAllRidNotificationMessageRequest request) throws ServiceHandleException {
String suffix = "JPUSHALLRIDNM";
JpushAllRidNotificationMessageResponse response = null;
public JPushSendMessageResponse jpushSendMessageHandler(JPushSendMessageRequest request) throws ServiceHandleException {
JPushSendMessageResponse response = null;
TokenHelper.logger.info("------- 极光推送-指定的registrationId列表-通知栏通知和自定义消息 START -------");
TokenHelper.logger.info("接收的request：{}", request.toJson());
//1、入参校验
request.valid();
try {
// todo 这里区分类型？
response = jpushManager.sendToAllRidNotificationMessage(request, apikeyPrefix+suffix);
if (request.getJPushType().equals(MessageJPushType.JPUSHALLAPPN)){
response = jpushManager.sendToAllAppMessage(request);
}else if (request.getJPushType().equals(MessageJPushType.JPUSHALLAPPM)){
response = jpushManager.sendToAllAppNotification(request);
}else if (request.getJPushType().equals(MessageJPushType.JPUSHALLAPPNM)){
response = jpushManager.sendToAllAppNotificationMessage(request);
}else if (request.getJPushType().equals(MessageJPushType.JPUSHALLRIDN)){
response = jpushManager.sendToAllRidMessage(request);
}else if (request.getJPushType().equals(MessageJPushType.JPUSHALLRIDM)){
response = jpushManager.sendToAllRidNotification(request);
}else if (request.getJPushType().equals(MessageJPushType.JPUSHALLRIDNM)){
response = jpushManager.sendToAllRidNotificationMessage(request);
}
} catch (Exception e) {
TokenHelper.logger.error("", e);
throw GlyServiceError.RESPONSE_ERROR.toHandleException("极光推动发送消息失败！");

+ 9
- 27
zhywpt-service-ats/src/main/java/cn/com/taiji/ats/model/jpush/JpushManager.java 파일 보기

@@ -1,45 +1,27 @@
package cn.com.taiji.ats.model.jpush;

import cn.com.taiji.common.manager.ManagerException;
import cn.com.taiji.core.model.comm.protocol.ats.jpush.JpushAllRidNotificationMessageRequest;
import cn.com.taiji.core.model.comm.protocol.ats.jpush.JpushAllRidNotificationMessageResponse;
import cn.com.taiji.core.model.comm.protocol.ats.jpush.JPushSendMessageRequest;
import cn.com.taiji.core.model.comm.protocol.ats.jpush.JPushSendMessageResponse;


public interface JpushManager {
public interface JPushManager {
/**极光推送-全体App用户(android/ios)-自定义消息*/
// JpushAllAppMessageResponse sendToAllAppMessage(JpushAllAppMessageRequest request, String apiKey, QtkMessage message) throws ManagerException;
// JpushAllAppMessageResponse sendWaitToAllAppMessage(JpushAllAppMessageRequest request, String apiKey, QtkMessage message) throws ServiceHandleException;
// JpushAllAppMessageResponse sendToAllAppMessageAndMq(JpushAllAppMessageRequest request, String apiKey, QtkMessage message) throws ManagerException;
// JpushAllAppMessageResponse sendToAllAppMessageAndQuartz(JpushAllAppMessageRequest request, String apiKey, QtkMessage message) throws ManagerException;
JPushSendMessageResponse sendToAllAppMessage(JPushSendMessageRequest request) throws ManagerException;

/**极光推送-全体App用户(android/ios)-通知栏通知*/
// JpushAllAppNotificationResponse sendToAllAppNotification(JpushAllAppNotificationRequest request, String apiKey, QtkMessage message) throws ManagerException;
// JpushAllAppNotificationResponse sendWaitToAllAppNotification(JpushAllAppNotificationRequest request, String apiKey, QtkMessage message) throws ServiceHandleException;
// JpushAllAppNotificationResponse sendToAllAppNotificationAndMq(JpushAllAppNotificationRequest request, String apiKey, QtkMessage message) throws ManagerException;
// JpushAllAppNotificationResponse sendToAllAppNotificationAndQuartz(JpushAllAppNotificationRequest request, String apiKey, QtkMessage message) throws ManagerException;
JPushSendMessageResponse sendToAllAppNotification(JPushSendMessageRequest request) throws ManagerException;

/**极光推送-全体App用户(android/ios)-通知栏通知和自定义消息*/
// JpushAllAppNotificationMessageResponse sendToAllAppNotificationMessage(JpushAllAppNotificationMessageRequest request, String apiKey, QtkMessage message) throws ManagerException;
// JpushAllAppNotificationMessageResponse sendWaitToAllAppNotificationMessage(JpushAllAppNotificationMessageRequest request, String apiKey, QtkMessage message) throws ServiceHandleException;
// JpushAllAppNotificationMessageResponse sendToAllAppNotificationMessageAndMq(JpushAllAppNotificationMessageRequest request, String apiKey, QtkMessage message) throws ManagerException;
// JpushAllAppNotificationMessageResponse sendToAllAppNotificationMessageAndQuartz(JpushAllAppNotificationMessageRequest request, String apiKey, QtkMessage message) throws ManagerException;
JPushSendMessageResponse sendToAllAppNotificationMessage(JPushSendMessageRequest request) throws ManagerException;

/**极光推送-指定registrationId(android/ios)-自定义消息*/
// JpushAllRidMessageResponse sendToAllRidMessage(JpushAllRidMessageRequest request, String apiKey, QtkMessage message) throws ManagerException;
// JpushAllRidMessageResponse sendWaitToAllRidMessage(JpushAllRidMessageRequest request, String apiKey, QtkMessage message) throws ServiceHandleException;
// JpushAllRidMessageResponse sendToAllRidMessageAndMq(JpushAllRidMessageRequest request, String apiKey, QtkMessage message) throws ManagerException;
// JpushAllRidMessageResponse sendToAllRidMessageAndQuartz(JpushAllRidMessageRequest request, String apiKey, QtkMessage message) throws ManagerException;
JPushSendMessageResponse sendToAllRidMessage(JPushSendMessageRequest request) throws ManagerException;

/**极光推送-指定registrationId(android/ios)-通知栏通知*/
// JpushAllRidNotificationResponse sendToAllRidNotification(JpushAllRidNotificationRequest request, String apiKey, QtkMessage message) throws ManagerException;
// JpushAllRidNotificationResponse sendWaitToAllRidNotification(JpushAllRidNotificationRequest request, String apiKey, QtkMessage message) throws ServiceHandleException;
// JpushAllRidNotificationResponse sendToAllRidNotificationAndMq(JpushAllRidNotificationRequest request, String apiKey, QtkMessage message) throws ManagerException;
// JpushAllRidNotificationResponse sendToAllRidNotificationAndQuartz(JpushAllRidNotificationRequest request, String apiKey, QtkMessage message) throws ManagerException;
JPushSendMessageResponse sendToAllRidNotification(JPushSendMessageRequest request) throws ManagerException;

/**极光推送-指定registrationId(android/ios)-通知栏通知和自定义消息*/
JpushAllRidNotificationMessageResponse sendToAllRidNotificationMessage(JpushAllRidNotificationMessageRequest request, String apiKey) throws ManagerException;
// JpushAllRidNotificationMessageResponse sendWaitToAllRidNotificationMessage(JpushAllRidNotificationMessageRequest request, String apiKey, QtkMessage message) throws ServiceHandleException;
// JpushAllRidNotificationMessageResponse sendToAllRidNotificationMessageAndMq(JpushAllRidNotificationMessageRequest request, String apiKey, QtkMessage message) throws ManagerException;
// JpushAllRidNotificationMessageResponse sendToAllRidNotificationMessageAndQuartz(JpushAllRidNotificationMessageRequest request, String apiKey, QtkMessage message) throws ManagerException;
JPushSendMessageResponse sendToAllRidNotificationMessage(JPushSendMessageRequest request) throws ManagerException;

}

+ 80
- 795
zhywpt-service-ats/src/main/java/cn/com/taiji/ats/model/jpush/JpushManagerImpl.java 파일 보기

@@ -1,819 +1,104 @@
package cn.com.taiji.ats.model.jpush;

import cn.com.taiji.ats.manager.jpush.messageChannelClients.MyJpushClient;
import cn.com.taiji.ats.manager.tools.ThreadPoolTools;
import cn.com.taiji.core.model.comm.protocol.ats.jpush.JpushAllRidNotificationMessageRequest;
import cn.com.taiji.core.model.comm.protocol.ats.jpush.JpushAllRidNotificationMessageResponse;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import cn.com.taiji.ats.manager.jpush.messageChannelClients.MyJpushClient;
import cn.com.taiji.common.manager.ManagerException;
import cn.com.taiji.common.manager.net.http.ServiceHandleException;
import cn.com.taiji.common.pub.CommonAbstract;
import cn.com.taiji.core.model.comm.protocol.ats.jpush.JPushSendMessageRequest;
import cn.com.taiji.core.model.comm.protocol.ats.jpush.JPushSendMessageResponse;


@Service
public class JpushManagerImpl extends CommonAbstract implements JpushManager {
private final String JPUSH_ALL_MSG_DESC = "极光推送-全体App用户(android/ios)-自定义消息";
private final String JPUSH_ALL_MSG_IMPORT_DESC = "极光推送-全体App用户(android/ios)-自定义消息（批量导入）";
private final String JPUSH_ALL_NTF_DESC = "极光推送-全体App用户(android/ios)-通知栏通知";
private final String JPUSH_ALL_NTF_IMPORT_DESC = "极光推送-全体App用户(android/ios)-通知栏通知（批量导入）";
private final String JPUSH_ALL_MSG_NTF_DESC = "极光推送-全体App用户(android/ios)-通知栏通知和自定义消息";
private final String JPUSH_ALL_MSG_NTF_IMPORT_DESC = "极光推送-全体App用户(android/ios)-通知栏通知和自定义消息（批量导入）";
private final String JPUSH_RID_MSG_DESC = "极光推送-指定registrationId(android/ios)-自定义消息";
private final String JPUSH_RID_MSG_IMPORT_DESC = "极光推送-指定registrationId(android/ios)-自定义消息（批量导入）";
private final String JPUSH_RID_NTF_DESC = "极光推送-指定registrationId(android/ios)-通知栏通知";
private final String JPUSH_RID_NTF_IMPORT_DESC = "极光推送-指定registrationId(android/ios)-通知栏通知（批量导入）";
private final String JPUSH_RID_MSG_NTF_DESC = "极光推送-指定registrationId(android/ios)-通知栏通知和自定义消息";
private final String JPUSH_RID_MSG_NTF_IMPORT_DESC = "极光推送-指定registrationId(android/ios)-通知栏通知和自定义消息（批量导入）";

private static final Logger logger = LoggerFactory.getLogger(JpushManagerImpl.class);
public class JPushManagerImpl extends CommonAbstract implements JPushManager {
private static final Logger logger = LoggerFactory.getLogger(JPushManagerImpl.class);

@Autowired
private MyJpushClient myJpushClient;
// @Autowired
// private MessageWaitSendMq messageWaitSendMq;
// @Autowired
// private MessageManager messageManager;
// @Autowired
// private PushMessageAlarmManager pushMessageAlarmManager;
@Autowired
private ThreadPoolTools threadPoolTools;
// @Autowired
// private MessageRecordAspectManager messageRecordAspectManager;


//极光推送-全体App用户(android/ios)-自定义消息
// @PushRecord(description = JPUSH_ALL_MSG_DESC)
// @Override
// public JpushAllAppMessageResponse sendToAllAppMessage(JpushAllAppMessageRequest request, String apiKey, QtkMessage message) throws ManagerException {
// jpushSendToAllAppMessage(request, message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_ALL_MSG_DESC,MessageResult.SEND);
// JpushAllAppMessageResponse response = new JpushAllAppMessageResponse();
// return response;
// }
//
// @Override
// public JpushAllAppMessageResponse sendWaitToAllAppMessage(JpushAllAppMessageRequest request, String apiKey, QtkMessage message) throws ServiceHandleException {
// jpushSendToAllAppMessage(request, message);
// JpushAllAppMessageResponse response = new JpushAllAppMessageResponse();
// return response;
// }
//
// private void jpushSendToAllAppMessage(JpushAllAppMessageRequest request, QtkMessage message) {
// threadPoolTools.execute(() -> {
// logger.info("********** 极光推送全体用户自定义消息发送 START **********");
// try {
// myJpushClient.sendToAllAppMessage(request.getTitle(), request.getMsgContent(), request.getMsgExtra());
// } catch (Exception e) {
// logger.error(e.toString());
//
// //消息发送失败告警
// MessageAlarmRequest alarmRequest = new MessageAlarmRequest(message.getId(), null, 1, 0, e.getMessage());
// pushMessageAlarmManager.messageAlarm(alarmRequest);
// }
// logger.info("********** 极光推送全体用户自定义消息发送 END **********");
// });
// }
//
//
// @PushRecord(description = JPUSH_ALL_MSG_DESC)
// @Override
// public JpushAllAppMessageResponse sendToAllAppMessageAndMq(JpushAllAppMessageRequest request, String apiKey, QtkMessage message) throws ManagerException {
// //mq发送消息
// messageWaitSendMq.sendMqByQtkMessage(message);
// return new JpushAllAppMessageResponse();
// }
//
//// @PushRecord(description = JPUSH_ALL_MSG_DESC)
// @Override
// public JpushAllAppMessageResponse sendToAllAppMessageAndQuartz(JpushAllAppMessageRequest request, String apiKey, QtkMessage message) throws ManagerException {
// //创建定时消息
// messageManager.quartzMessageCreate(message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_ALL_MSG_DESC,MessageResult.WAIT);
// return new JpushAllAppMessageResponse();
// }
//
//// @PushRecord(description = JPUSH_ALL_MSG_IMPORT_DESC)
// @Override
// public MessageImportSendResponse sendToAllAppMessageImport(MessageImportSendRequest request, String apiKey, QtkMessage message, ImportMessageDto importMessageDto) throws ManagerException {
// jpushSendToAllAppMessageImport(importMessageDto, message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_ALL_MSG_IMPORT_DESC,MessageResult.SEND);
// return new MessageImportSendResponse(message.getId());
// }
//
// @Override
// public MessageImportSendResponse sendWaitToAllAppMessageImport(MessageImportSendRequest request, String apiKey, QtkMessage message, ImportMessageDto importMessageDto) throws ServiceHandleException {
// jpushSendToAllAppMessageImport(importMessageDto, message);
// return new MessageImportSendResponse(message.getId());
// }
//
//
// private void jpushSendToAllAppMessageImport(ImportMessageDto importMessageDto, QtkMessage message) {
// threadPoolTools.execute(() -> {
// logger.info("********** 极光推送全体用户自定义消息发送（批量导入） START **********");
// logger.info("表格内容：{}", JSON.toJSONString(importMessageDto.getJpushAllAppMessageDataList()));
//
// int successCount = 0;
// String errorReason = "（批量导入）部分极光推送全体用户自定义消息发送失败！";
// List<String> failTouserList = new ArrayList<>();
//
// for (JpushAllAppMessageData jpushAllAppMessageData : importMessageDto.getJpushAllAppMessageDataList()) {
// try {
// myJpushClient.sendToAllAppMessage(jpushAllAppMessageData.getMsgTitle(), jpushAllAppMessageData.getMsgContent(), null);
// successCount++;
// } catch (Exception e) {
// errorReason = e.getMessage();
// logger.error(e.toString());
// failTouserList.add(jpushAllAppMessageData.getMsgNo());//记录消息编号
// }
// }
//
// logger.info("********** 极光推送全体用户自定义消息发送（批量导入） END **********");
//
// //消息发送失败告警
// if (successCount != importMessageDto.getJpushAllAppMessageDataList().size()) {
// //消息发送失败告警
// MessageAlarmRequest alarmRequest = new MessageAlarmRequest(
// message.getId(),
// failTouserList,
// importMessageDto.getJpushAllAppMessageDataList().size(),
// successCount,
// errorReason);
// pushMessageAlarmManager.messageAlarm(alarmRequest);
// }
// });
// }
//
//// @PushRecord(description = JPUSH_ALL_MSG_IMPORT_DESC)
// @Override
// public MessageImportSendResponse sendToAllAppMessageImportAndQuartz(MessageImportSendRequest request, String apiKey, QtkMessage message) throws ManagerException {
// //创建定时消息
// messageManager.quartzMessageCreate(message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_ALL_MSG_IMPORT_DESC,MessageResult.WAIT);
// return new MessageImportSendResponse(message.getId());
// }
//
//
// //极光推送-全体App用户(android/ios)-通知栏通知
//// @PushRecord(description = JPUSH_ALL_NTF_DESC)
// @Override
// public JpushAllAppNotificationResponse sendToAllAppNotification(JpushAllAppNotificationRequest request, String apiKey, QtkMessage message) throws ManagerException {
// jpushSendToAllAppNotification(request, message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_ALL_NTF_DESC,MessageResult.SEND);
// JpushAllAppNotificationResponse response = new JpushAllAppNotificationResponse();
// return response;
// }
//
// @Override
// public JpushAllAppNotificationResponse sendWaitToAllAppNotification(JpushAllAppNotificationRequest request, String apiKey, QtkMessage message) throws ServiceHandleException {
// jpushSendToAllAppNotification(request, message);
//
// JpushAllAppNotificationResponse response = new JpushAllAppNotificationResponse();
// return response;
// }
//
// private void jpushSendToAllAppNotification(JpushAllAppNotificationRequest request, QtkMessage message) {
// threadPoolTools.execute(() -> {
// logger.info("********** 极光推送全体用户通知栏通知发送 START **********");
// try {
// myJpushClient.sendToAllAppNotification(
// request.getTitle(),
// request.getNotificationContent(),
// request.getNotificationExtras());
// } catch (Exception e) {
// logger.error(e.toString());
//
// //消息发送失败告警
// MessageAlarmRequest alarmRequest = new MessageAlarmRequest(message.getId(), null, 1, 0, e.getMessage());
// pushMessageAlarmManager.messageAlarm(alarmRequest);
// }
// logger.info("********** 极光推送全体用户通知栏通知发送 END **********");
// });
// }
//
//
// @PushRecord(description = JPUSH_ALL_NTF_DESC)
// @Override
// public JpushAllAppNotificationResponse sendToAllAppNotificationAndMq(JpushAllAppNotificationRequest request, String apiKey, QtkMessage message) throws ManagerException {
// //mq发送消息
// messageWaitSendMq.sendMqByQtkMessage(message);
// return new JpushAllAppNotificationResponse();
// }
//
//// @PushRecord(description = JPUSH_ALL_NTF_DESC)
// @Override
// public JpushAllAppNotificationResponse sendToAllAppNotificationAndQuartz(JpushAllAppNotificationRequest request, String apiKey, QtkMessage message) throws ManagerException {
// //创建定时消息
// messageManager.quartzMessageCreate(message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_ALL_NTF_DESC,MessageResult.WAIT);
// return new JpushAllAppNotificationResponse();
// }
//
//// @PushRecord(description = JPUSH_ALL_NTF_IMPORT_DESC)
// @Override
// public MessageImportSendResponse sendToAllAppNotificationImport(MessageImportSendRequest request, String apiKey, QtkMessage message, ImportMessageDto importMessageDto) throws ManagerException {
// jpushSendToAllAppNotificationImport(importMessageDto, message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_ALL_NTF_IMPORT_DESC,MessageResult.SEND);
// return new MessageImportSendResponse(message.getId());
// }
//
// @Override
// public MessageImportSendResponse sendWaitToAllAppNotificationImport(MessageImportSendRequest request, String apiKey, QtkMessage message, ImportMessageDto importMessageDto) {
// jpushSendToAllAppNotificationImport(importMessageDto, message);
// return new MessageImportSendResponse(message.getId());
// }
//
// private void jpushSendToAllAppNotificationImport(ImportMessageDto importMessageDto, QtkMessage message) {
// threadPoolTools.execute(() -> {
// logger.info("********** 极光推送全体用户通知栏通知发送（批量导入） START **********");
// logger.info("表格内容：{}", JSON.toJSONString(importMessageDto.getJpushAllAppNotificationDataList()));
//
// int successCount = 0;
// String errorReason = "（批量导入）部分极光推送全体用户通知栏通知发送失败！";
// List<String> failTouserList = new ArrayList<>();
//
// for (JpushAllAppNotificationData jpushAllAppNotificationData : importMessageDto.getJpushAllAppNotificationDataList()) {
// try {
// myJpushClient.sendToAllAppNotification(
// jpushAllAppNotificationData.getNotificationTitle(),
// jpushAllAppNotificationData.getNotificationContent(),
// null);
// successCount++;
// } catch (Exception e) {
// errorReason = e.getMessage();
// logger.error(e.toString());
// failTouserList.add(jpushAllAppNotificationData.getMsgNo());//记录消息编号
// }
// }
//
// logger.info("********** 极光推送全体用户通知栏通知发送（批量导入） END **********");
//
// //消息发送失败告警
// if (successCount != importMessageDto.getJpushAllAppNotificationDataList().size()) {
// //消息发送失败告警
// MessageAlarmRequest alarmRequest = new MessageAlarmRequest(
// message.getId(),
// failTouserList,
// importMessageDto.getJpushAllAppNotificationDataList().size(),
// successCount,
// errorReason);
// pushMessageAlarmManager.messageAlarm(alarmRequest);
// }
// });
// }
//
//// @PushRecord(description = JPUSH_ALL_NTF_IMPORT_DESC)
// @Override
// public MessageImportSendResponse sendToAllAppNotificationImportAndQuartz(MessageImportSendRequest request, String apiKey, QtkMessage message) throws ManagerException {
// //创建定时消息
// messageManager.quartzMessageCreate(message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_ALL_NTF_IMPORT_DESC,MessageResult.WAIT);
// return new MessageImportSendResponse(message.getId());
// }
//
//
// //极光推送-全体App用户(android/ios)-通知栏通知和自定义消息
//// @PushRecord(description = JPUSH_ALL_MSG_NTF_DESC)
// @Override
// public JpushAllAppNotificationMessageResponse sendToAllAppNotificationMessage(JpushAllAppNotificationMessageRequest request, String apiKey, QtkMessage message) throws ManagerException {
// jpushSendToAllAppNotificationMessage(request, message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_ALL_MSG_NTF_DESC,MessageResult.SEND);
// JpushAllAppNotificationMessageResponse response = new JpushAllAppNotificationMessageResponse();
// return response;
// }
//
// @Override
// public JpushAllAppNotificationMessageResponse sendWaitToAllAppNotificationMessage(JpushAllAppNotificationMessageRequest request, String apiKey, QtkMessage message) throws ServiceHandleException {
// jpushSendToAllAppNotificationMessage(request, message);
//
// JpushAllAppNotificationMessageResponse response = new JpushAllAppNotificationMessageResponse();
// return response;
// }
//
//
// private void jpushSendToAllAppNotificationMessage(JpushAllAppNotificationMessageRequest request, QtkMessage message) {
// threadPoolTools.execute(() -> {
// logger.info("********** 极光推送全体用户通知栏通知和自定义消息发送 START **********");
// try {
// myJpushClient.sendToAllAppNotificationMessage(
// request.getNotificationTitle(),
// request.getNotificationContent(),
// request.getNotificationExtras(),
// request.getMsgTitle(),
// request.getMsgContent(),
// request.getMsgExtra());
// } catch (Exception e) {
// logger.error(e.toString());
//
// //消息发送失败告警
// MessageAlarmRequest alarmRequest = new MessageAlarmRequest(message.getId(), null, 1, 0, e.getMessage());
// pushMessageAlarmManager.messageAlarm(alarmRequest);
// }
// logger.info("********** 极光推送全体用户通知栏通知和自定义消息发送 END **********");
// });
// }
//
//
// @PushRecord(description = JPUSH_ALL_MSG_NTF_DESC)
// @Override
// public JpushAllAppNotificationMessageResponse sendToAllAppNotificationMessageAndMq(JpushAllAppNotificationMessageRequest request, String apiKey, QtkMessage message) throws ManagerException {
// //mq发送消息
// messageWaitSendMq.sendMqByQtkMessage(message);
// return new JpushAllAppNotificationMessageResponse();
// }
//
//// @PushRecord(description = JPUSH_ALL_MSG_NTF_DESC)
// @Override
// public JpushAllAppNotificationMessageResponse sendToAllAppNotificationMessageAndQuartz(JpushAllAppNotificationMessageRequest request, String apiKey, QtkMessage message) throws ManagerException {
// //创建定时消息
// messageManager.quartzMessageCreate(message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_ALL_MSG_NTF_DESC,MessageResult.WAIT);
// return new JpushAllAppNotificationMessageResponse();
// }
//
//// @PushRecord(description = JPUSH_ALL_MSG_NTF_IMPORT_DESC)
// @Override
// public MessageImportSendResponse sendToAllAppNotificationMessageImport(MessageImportSendRequest request, String apiKey, QtkMessage message, ImportMessageDto importMessageDto) throws ManagerException {
// jpushSendToAllAppNotificationMessageImport(importMessageDto, message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_ALL_MSG_NTF_IMPORT_DESC,MessageResult.SEND);
// return new MessageImportSendResponse(message.getId());
// }
//
// @Override
// public MessageImportSendResponse sendWaitToAllAppNotificationMessageImport(MessageImportSendRequest request, String apiKey, QtkMessage message, ImportMessageDto importMessageDto) throws ServiceHandleException {
// jpushSendToAllAppNotificationMessageImport(importMessageDto, message);
// return new MessageImportSendResponse(message.getId());
// }
//
//
// private void jpushSendToAllAppNotificationMessageImport(ImportMessageDto importMessageDto, QtkMessage message) {
// threadPoolTools.execute(() -> {
// logger.info("********** 极光推送全体用户通知栏通知和自定义消息发送（批量导入） START **********");
// logger.info("表格内容：{}", JSON.toJSONString(importMessageDto.getJpushAllAppNotificationMessageDataList()));
//
// int successCount = 0;
// String errorReason = "（批量导入）部分极光推送全体用户通知栏通知和自定义消息发送失败！";
// List<String> failTouserList = new ArrayList<>();
//
// for (JpushAllAppNotificationMessageData jpushAllAppNotificationMessageData : importMessageDto.getJpushAllAppNotificationMessageDataList()) {
// try {
// myJpushClient.sendToAllAppNotificationMessage(
// jpushAllAppNotificationMessageData.getNotificationTitle(),
// jpushAllAppNotificationMessageData.getNotificationContent(),
// null,
// jpushAllAppNotificationMessageData.getMsgTitle(),
// jpushAllAppNotificationMessageData.getMsgContent(),
// null);
// successCount++;
// } catch (Exception e) {
// errorReason = e.getMessage();
// logger.error(e.toString());
// failTouserList.add(jpushAllAppNotificationMessageData.getMsgNo());//记录消息编号
// }
// }
//
// logger.info("********** 极光推送全体用户通知栏通知和自定义消息发送（批量导入） END **********");
//
// //消息发送失败告警
// if (successCount != importMessageDto.getJpushAllAppNotificationMessageDataList().size()) {
// //消息发送失败告警
// MessageAlarmRequest alarmRequest = new MessageAlarmRequest(
// message.getId(),
// failTouserList,
// importMessageDto.getJpushAllAppNotificationMessageDataList().size(),
// successCount,
// errorReason);
// pushMessageAlarmManager.messageAlarm(alarmRequest);
// }
// });
// }
//
//// @PushRecord(description = JPUSH_ALL_MSG_NTF_IMPORT_DESC)
// @Override
// public MessageImportSendResponse sendToAllAppNotificationMessageImportAndQuartz(MessageImportSendRequest request, String apiKey, QtkMessage message) throws ManagerException {
// //创建定时消息
// messageManager.quartzMessageCreate(message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_ALL_MSG_NTF_IMPORT_DESC,MessageResult.WAIT);
// return new MessageImportSendResponse(message.getId());
// }
//
//
// //极光推送-指定registrationId(android/ios)-自定义消息
//// @PushRecord(description = JPUSH_RID_MSG_DESC)
// @Override
// public JpushAllRidMessageResponse sendToAllRidMessage(JpushAllRidMessageRequest request, String apiKey, QtkMessage message) throws ManagerException {
// jpushSendToAllRidMessage(request, message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_RID_MSG_DESC,MessageResult.SEND);
// JpushAllRidMessageResponse response = new JpushAllRidMessageResponse();
// return response;
// }
//
// @Override
// public JpushAllRidMessageResponse sendWaitToAllRidMessage(JpushAllRidMessageRequest request, String apiKey, QtkMessage message) throws ServiceHandleException {
// jpushSendToAllRidMessage(request, message);
//
// JpushAllRidMessageResponse response = new JpushAllRidMessageResponse();
// return response;
// }
//
// private void jpushSendToAllRidMessage(JpushAllRidMessageRequest request, QtkMessage message) {
// threadPoolTools.execute(() -> {
// logger.info("********** 极光推送指定rid自定义消息发送 START **********");
// try {
// myJpushClient.sendToAllRidMessage(
// request.getRegistrationIdList(),
// request.getTitle(),
// request.getMsgContent(),
// request.getMsgExtra());
// } catch (Exception e) {
// logger.error(e.toString());
//
// //消息发送失败告警
// MessageAlarmRequest alarmRequest = new MessageAlarmRequest(message.getId(), request.getRegistrationIdList(), request.getRegistrationIdList().size(), 0, e.getMessage());
// pushMessageAlarmManager.messageAlarm(alarmRequest);
// }
// logger.info("********** 极光推送指定rid自定义消息发送 END **********");
// });
// }
//
//
// @PushRecord(description = JPUSH_RID_MSG_DESC)
// @Override
// public JpushAllRidMessageResponse sendToAllRidMessageAndMq(JpushAllRidMessageRequest request, String apiKey, QtkMessage message) throws ManagerException {
// //mq发送消息
// messageWaitSendMq.sendMqByQtkMessage(message);
// return new JpushAllRidMessageResponse();
// }
//
//// @PushRecord(description = JPUSH_RID_MSG_DESC)
// @Override
// public JpushAllRidMessageResponse sendToAllRidMessageAndQuartz(JpushAllRidMessageRequest request, String apiKey, QtkMessage message) throws ManagerException {
// //创建定时消息
// messageManager.quartzMessageCreate(message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_RID_MSG_DESC,MessageResult.WAIT);
// return new JpushAllRidMessageResponse();
// }
//
//// @PushRecord(description = JPUSH_RID_MSG_IMPORT_DESC)
// @Override
// public MessageImportSendResponse sendToAllRidMessageImport(MessageImportSendRequest request, String apiKey, QtkMessage message, ImportMessageDto importMessageDto, Map<String, String> dbDataRidMap) throws ManagerException {
// jpushSendToAllRidMessageImport(importMessageDto, message, dbDataRidMap);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_RID_MSG_IMPORT_DESC,MessageResult.SEND);
// return new MessageImportSendResponse(message.getId());
// }
//
// @Override
// public MessageImportSendResponse sendWaitToAllRidMessageImport(MessageImportSendRequest request, String apiKey, QtkMessage message, ImportMessageDto importMessageDto, Map<String, String> dbDataRidMap) throws ServiceHandleException {
// jpushSendToAllRidMessageImport(importMessageDto, message, dbDataRidMap);
// return new MessageImportSendResponse(message.getId());
// }
//
// private void jpushSendToAllRidMessageImport(ImportMessageDto importMessageDto, QtkMessage message, Map<String, String> dbDataRidMap) {
// threadPoolTools.execute(() -> {
// logger.info("********** 极光推送指定用户自定义消息发送（批量导入） START **********");
// logger.info("表格内容：{}", JSON.toJSONString(importMessageDto.getJpushAllRidMessageDataList()));
// logger.info("数据库查询内容：{}", JSON.toJSONString(dbDataRidMap));
//
// int successCount = 0;
// String errorReason = "批量导入时，部分用户的极光推送registrationId在数据库中找不到对应数据，从而导致自定义消息发送失败！";
// List<String> failTouserList = new ArrayList<>();
//
// for (JpushAllRidMessageData jpushAllRidMessageData : importMessageDto.getJpushAllRidMessageDataList()) {
// String registrationId = dbDataRidMap.get(jpushAllRidMessageData.getUserMobile());
// try {
// if (StringUtils.hasText(registrationId)) {
// myJpushClient.sendToAllRidMessage(
// Arrays.asList(registrationId),
// jpushAllRidMessageData.getMsgTitle(),
// jpushAllRidMessageData.getMsgContent(),
// null);
// successCount++;
// } else {
// failTouserList.add(jpushAllRidMessageData.getUserMobile());
// }
// } catch (Exception e) {
// errorReason = e.getMessage();
// logger.error(e.toString());
// failTouserList.add(jpushAllRidMessageData.getUserMobile());
// }
// }
//
// logger.info("********** 极光推送指定用户自定义消息发送（批量导入） END **********");
//
// //消息发送失败告警
// if (successCount != importMessageDto.getJpushAllRidMessageDataList().size()) {
// //消息发送失败告警
// MessageAlarmRequest alarmRequest = new MessageAlarmRequest(
// message.getId(),
// failTouserList,
// importMessageDto.getJpushAllRidMessageDataList().size(),
// successCount,
// errorReason);
// pushMessageAlarmManager.messageAlarm(alarmRequest);
// }
// });
// }
//
//// @PushRecord(description = JPUSH_RID_MSG_IMPORT_DESC)
// @Override
// public MessageImportSendResponse sendToAllRidMessageImportAndQuartz(MessageImportSendRequest request, String apiKey, QtkMessage message) throws ManagerException {
// //创建定时消息
// messageManager.quartzMessageCreate(message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_RID_MSG_IMPORT_DESC,MessageResult.WAIT);
// return new MessageImportSendResponse(message.getId());
// }
//
//
// //极光推送-指定registrationId(android/ios)-通知栏通知
//// @PushRecord(description = JPUSH_RID_NTF_DESC)
// @Override
// public JpushAllRidNotificationResponse sendToAllRidNotification(JpushAllRidNotificationRequest request, String apiKey, QtkMessage message) throws ManagerException {
// jpushSendToAllRidNotification(request, message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_RID_NTF_DESC,MessageResult.SEND);
// JpushAllRidNotificationResponse response = new JpushAllRidNotificationResponse();
// return response;
// }
//
// @Override
// public JpushAllRidNotificationResponse sendWaitToAllRidNotification(JpushAllRidNotificationRequest request, String apiKey, QtkMessage message) throws ServiceHandleException {
// jpushSendToAllRidNotification(request, message);
//
// JpushAllRidNotificationResponse response = new JpushAllRidNotificationResponse();
// return response;
// }
//
// private void jpushSendToAllRidNotification(JpushAllRidNotificationRequest request, QtkMessage message) {
// threadPoolTools.execute(() -> {
// logger.info("********** 极光推送指定rid通知栏通知发送 START **********");
// try {
// myJpushClient.sendToAllRidNotification(
// request.getRegistrationIdList(),
// request.getTitle(),
// request.getNotificationContent(),
// request.getNotificationExtras());
// } catch (Exception e) {
// logger.error(e.toString());
//
// //消息发送失败告警
// MessageAlarmRequest alarmRequest = new MessageAlarmRequest(message.getId(), request.getRegistrationIdList(), request.getRegistrationIdList().size(), 0, e.getMessage());
// pushMessageAlarmManager.messageAlarm(alarmRequest);
// }
// logger.info("********** 极光推送指定rid通知栏通知发送 END **********");
// });
// }
//
// @PushRecord(description = JPUSH_RID_NTF_DESC)
// @Override
// public JpushAllRidNotificationResponse sendToAllRidNotificationAndMq(JpushAllRidNotificationRequest request, String apiKey, QtkMessage message) throws ManagerException {
// //mq发送消息
// messageWaitSendMq.sendMqByQtkMessage(message);
// return new JpushAllRidNotificationResponse();
// }
//
//// @PushRecord(description = JPUSH_RID_NTF_DESC)
// @Override
// public JpushAllRidNotificationResponse sendToAllRidNotificationAndQuartz(JpushAllRidNotificationRequest request, String apiKey, QtkMessage message) throws ManagerException {
// //创建定时消息
// messageManager.quartzMessageCreate(message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_RID_NTF_DESC,MessageResult.WAIT);
// return new JpushAllRidNotificationResponse();
// }
//
//// @PushRecord(description = JPUSH_RID_NTF_IMPORT_DESC)
// @Override
// public MessageImportSendResponse sendToAllRidNotificationImport(MessageImportSendRequest request, String apiKey, QtkMessage message, ImportMessageDto importMessageDto, Map<String, String> dbDataRidMap) throws ManagerException {
// jpushSendToAllRidNotificationImport(importMessageDto, message, dbDataRidMap);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_RID_NTF_IMPORT_DESC,MessageResult.SEND);
// return new MessageImportSendResponse(message.getId());
// }
//
// @Override
// public MessageImportSendResponse sendWaitToAllRidNotificationImport(MessageImportSendRequest request, String apiKey, QtkMessage message, ImportMessageDto importMessageDto, Map<String, String> dbDataRidMap) throws ServiceHandleException {
// jpushSendToAllRidNotificationImport(importMessageDto, message, dbDataRidMap);
// return new MessageImportSendResponse(message.getId());
// }
//
// private void jpushSendToAllRidNotificationImport(ImportMessageDto importMessageDto, QtkMessage message, Map<String, String> dbDataRidMap) {
// threadPoolTools.execute(() -> {
// logger.info("********** 极光推送指定用户通知栏通知发送（批量导入） START **********");
// logger.info("表格内容：{}", JSON.toJSONString(importMessageDto.getJpushAllRidNotificationDataList()));
// logger.info("数据库查询内容：{}", JSON.toJSONString(dbDataRidMap));
//
// int successCount = 0;
// String errorReason = "批量导入时，部分用户的极光推送registrationId在数据库中找不到对应数据，从而导致通知栏通知发送失败！";
// List<String> failTouserList = new ArrayList<>();
//
// for (JpushAllRidNotificationData jpushAllRidNotificationData : importMessageDto.getJpushAllRidNotificationDataList()) {
// String registrationId = dbDataRidMap.get(jpushAllRidNotificationData.getUserMobile());
// try {
// if (StringUtils.hasText(registrationId)) {
// myJpushClient.sendToAllRidNotification(
// Arrays.asList(registrationId),
// jpushAllRidNotificationData.getNotificationTitle(),
// jpushAllRidNotificationData.getNotificationContent(),
// null);
// successCount++;
// } else {
// failTouserList.add(jpushAllRidNotificationData.getUserMobile());
// }
// } catch (Exception e) {
// errorReason = e.getMessage();
// logger.error(e.toString());
// failTouserList.add(jpushAllRidNotificationData.getUserMobile());
// }
// }
//
// logger.info("********** 极光推送指定用户通知栏通知发送（批量导入） END **********");
//
// //消息发送失败告警
// if (successCount != importMessageDto.getJpushAllRidNotificationDataList().size()) {
// //消息发送失败告警
// MessageAlarmRequest alarmRequest = new MessageAlarmRequest(
// message.getId(),
// failTouserList,
// importMessageDto.getJpushAllRidNotificationDataList().size(),
// successCount,
// errorReason);
// pushMessageAlarmManager.messageAlarm(alarmRequest);
// }
// });
// }
//
//// @PushRecord(description = JPUSH_RID_NTF_IMPORT_DESC)
// @Override
// public MessageImportSendResponse sendToAllRidNotificationImportAndQuartz(MessageImportSendRequest request, String apiKey, QtkMessage message) throws ManagerException {
// //创建定时消息
// messageManager.quartzMessageCreate(message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_RID_NTF_IMPORT_DESC,MessageResult.WAIT);
// return new MessageImportSendResponse(message.getId());
// }


//极光推送-指定registrationId(android/ios)-通知栏通知和自定义消息
// @PushRecord(description = JPUSH_RID_MSG_NTF_DESC)
// 极光推送-全体App用户(android/ios)-自定义消息
@Override
public JpushAllRidNotificationMessageResponse sendToAllRidNotificationMessage(JpushAllRidNotificationMessageRequest request, String apiKey) throws ManagerException {
jpushSendToAllRidNotificationMessage(request);
//切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_RID_MSG_NTF_DESC,MessageResult.SEND);
JpushAllRidNotificationMessageResponse response = new JpushAllRidNotificationMessageResponse();
public JPushSendMessageResponse sendToAllAppMessage(JPushSendMessageRequest request) throws ManagerException {
logger.info("********** 极光推送全体用户自定义消息发送 START **********");
myJpushClient.sendToAllAppMessage(request.getMsgTitle(),
request.getMsgContent(),
request.getMsgExtra());
logger.info("********** 极光推送全体用户自定义消息发送 END **********");
JPushSendMessageResponse response = new JPushSendMessageResponse();
return response;
}
//极光推送-全体App用户(android/ios)-通知栏通知
@Override
public JPushSendMessageResponse sendToAllAppNotification(JPushSendMessageRequest request) throws ManagerException {
logger.info("********** 极光推送全体用户通知栏通知发送 START **********");
myJpushClient.sendToAllAppNotification(
request.getNotificationTitle(),
request.getNotificationContent(),
request.getNotificationExtras());
logger.info("********** 极光推送全体用户通知栏通知发送 END **********");
JPushSendMessageResponse response = new JPushSendMessageResponse();
return response;
}
//极光推送-全体App用户(android/ios)-通知栏通知和自定义消息
@Override
public JPushSendMessageResponse sendToAllAppNotificationMessage(JPushSendMessageRequest request) throws ManagerException {
logger.info("********** 极光推送全体用户通知栏通知和自定义消息发送 START **********");
myJpushClient.sendToAllAppNotificationMessage(
request.getNotificationTitle(),
request.getNotificationContent(),
request.getNotificationExtras(),
request.getMsgTitle(),
request.getMsgContent(),
request.getMsgExtra());
logger.info("********** 极光推送全体用户通知栏通知和自定义消息发送 END **********");
JPushSendMessageResponse response = new JPushSendMessageResponse();
return response;
}
//极光推送-指定registrationId(android/ios)-自定义消息
@Override
public JPushSendMessageResponse sendToAllRidMessage(JPushSendMessageRequest request) throws ManagerException {
logger.info("********** 极光推送指定rid自定义消息发送 START **********");
myJpushClient.sendToAllRidMessage(
request.getRegistrationIdList(),
request.getMsgTitle(),
request.getMsgContent(),
request.getMsgExtra());
logger.info("********** 极光推送指定rid自定义消息发送 END **********");
JPushSendMessageResponse response = new JPushSendMessageResponse();
return response;
}
//极光推送-指定registrationId(android/ios)-通知栏通知
@Override
public JPushSendMessageResponse sendToAllRidNotification(JPushSendMessageRequest request) throws ManagerException {
logger.info("********** 极光推送指定rid通知栏通知发送 START **********");
myJpushClient.sendToAllRidNotification(
request.getRegistrationIdList(),
request.getNotificationTitle(),
request.getNotificationContent(),
request.getNotificationExtras());
logger.info("********** 极光推送指定rid通知栏通知发送 END **********");
JPushSendMessageResponse response = new JPushSendMessageResponse();
return response;
}

// @Override
// public JpushAllRidNotificationMessageResponse sendWaitToAllRidNotificationMessage(JpushAllRidNotificationMessageRequest request, String apiKey, QtkMessage message) throws ServiceHandleException {
// jpushSendToAllRidNotificationMessage(request, message);
//
// JpushAllRidNotificationMessageResponse response = new JpushAllRidNotificationMessageResponse();
// return response;
// }

private void jpushSendToAllRidNotificationMessage(JpushAllRidNotificationMessageRequest request) throws ServiceHandleException {
threadPoolTools.execute(() -> {
//极光推送-指定registrationId(android/ios)-通知栏通知和自定义消息
@Override
public JPushSendMessageResponse sendToAllRidNotificationMessage(JPushSendMessageRequest request) throws ManagerException {
logger.info("********** 极光推送指定rid通知栏通知和自定义消息发送 START **********");
try {
myJpushClient.sendToAllRidNotificationMessage(
request.getRegistrationId(),
request.getNotificationTitle(),
request.getNotificationContent(),
request.getNotificationExtras(),
request.getMsgTitle(),
request.getMsgContent(),
request.getMsgExtra());
} catch (Exception e) {
logger.error(e.toString());
// //消息发送失败告警
// MessageAlarmRequest alarmRequest = new MessageAlarmRequest(message.getId(), request.getRegistrationIdList(), request.getRegistrationIdList().size(), 0, e.getMessage());
// pushMessageAlarmManager.messageAlarm(alarmRequest);
}
// 发送
myJpushClient.sendToAllRidNotificationMessage(
request.getRegistrationIdList().toString(),
request.getNotificationTitle(),
request.getNotificationContent(),
request.getNotificationExtras(),
request.getMsgTitle(),
request.getMsgContent(),
request.getMsgExtra());
logger.info("********** 极光推送指定rid通知栏通知和自定义消息发送 END **********");
});
JPushSendMessageResponse response = new JPushSendMessageResponse();
return response;
}
////
//// @PushRecord(description = JPUSH_RID_MSG_NTF_DESC)
//// @Override
//// public JpushAllRidNotificationMessageResponse sendToAllRidNotificationMessageAndMq(JpushAllRidNotificationMessageRequest request, String apiKey, QtkMessage message) throws ManagerException {
//// //mq发送消息
//// messageWaitSendMq.sendMqByQtkMessage(message);
//// return new JpushAllRidNotificationMessageResponse();
//// }
////
////// @PushRecord(description = JPUSH_RID_MSG_NTF_DESC)
//// @Override
//// public JpushAllRidNotificationMessageResponse sendToAllRidNotificationMessageAndQuartz(JpushAllRidNotificationMessageRequest request, String apiKey, QtkMessage message) throws ManagerException {
//// //创建定时消息
//// messageManager.quartzMessageCreate(message);
//// //切面相关业务拿出来，去掉切面
//// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_RID_MSG_NTF_DESC,MessageResult.WAIT);
//// return new JpushAllRidNotificationMessageResponse();
//// }
////
////// @PushRecord(description = JPUSH_RID_MSG_NTF_IMPORT_DESC)
//// @Override
//// public MessageImportSendResponse sendToAllRidNotificationMessageImport(MessageImportSendRequest request, String apiKey, QtkMessage message, ImportMessageDto importMessageDto, Map<String, String> dbDataRidMap) throws ManagerException {
//// jpushSendToAllRidNotificationMessageImport(importMessageDto, message, dbDataRidMap);
//// //切面相关业务拿出来，去掉切面
//// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_RID_MSG_NTF_IMPORT_DESC,MessageResult.SEND);
//// return new MessageImportSendResponse(message.getId());
//// }
////
//// @Override
//// public MessageImportSendResponse sendWaitToAllRidNotificationMessageImport(MessageImportSendRequest request, String apiKey, QtkMessage message, ImportMessageDto importMessageDto, Map<String, String> dbDataRidMap) throws ServiceHandleException {
//// jpushSendToAllRidNotificationMessageImport(importMessageDto, message, dbDataRidMap);
//// return new MessageImportSendResponse(message.getId());
//// }
//
// private void jpushSendToAllRidNotificationMessageImport(ImportMessageDto importMessageDto, QtkMessage message, Map<String, String> dbDataRidMap) {
// threadPoolTools.execute(() -> {
// logger.info("********** 极光推送指定用户通知栏通知和自定义消息发送（批量导入） START **********");
// logger.info("表格内容：{}", JSON.toJSONString(importMessageDto.getJpushAllRidNotificationMessageDataList()));
// logger.info("数据库查询内容：{}", JSON.toJSONString(dbDataRidMap));
//
// int successCount = 0;
// String errorReason = "批量导入时，部分用户的极光推送registrationId在数据库中找不到对应数据，从而导致通知栏通知和自定义消息发送失败！";
// List<String> failTouserList = new ArrayList<>();
//
// for (JpushAllRidNotificationMessageData jpushAllRidNotificationMessageData : importMessageDto.getJpushAllRidNotificationMessageDataList()) {
// String registrationId = dbDataRidMap.get(jpushAllRidNotificationMessageData.getUserMobile());
// try {
// if (StringUtils.hasText(registrationId)) {
// myJpushClient.sendToAllRidNotificationMessage(
// Arrays.asList(registrationId),
// jpushAllRidNotificationMessageData.getNotificationTitle(),
// jpushAllRidNotificationMessageData.getNotificationContent(),
// null,
// jpushAllRidNotificationMessageData.getMsgTitle(),
// jpushAllRidNotificationMessageData.getMsgContent(),
// null);
// successCount++;
// } else {
// failTouserList.add(jpushAllRidNotificationMessageData.getUserMobile());
// }
// successCount++;
// } catch (Exception e) {
// errorReason = e.getMessage();
// logger.error(e.toString());
// failTouserList.add(jpushAllRidNotificationMessageData.getUserMobile());
// }
// }
//
// logger.info("********** 极光推送指定用户通知栏通知和自定义消息发送（批量导入） END **********");
//
// //消息发送失败告警
// if (successCount != importMessageDto.getJpushAllRidNotificationMessageDataList().size()) {
// //消息发送失败告警
// MessageAlarmRequest alarmRequest = new MessageAlarmRequest(
// message.getId(),
// failTouserList,
// importMessageDto.getJpushAllRidNotificationMessageDataList().size(),
// successCount,
// errorReason);
// pushMessageAlarmManager.messageAlarm(alarmRequest);
// }
// });
// }
//
//// @PushRecord(description = JPUSH_RID_MSG_NTF_IMPORT_DESC)
// @Override
// public MessageImportSendResponse sendToAllRidNotificationMessageImportAndQuartz(MessageImportSendRequest request, String apiKey, QtkMessage message) throws ManagerException {
// //创建定时消息
// messageManager.quartzMessageCreate(message);
// //切面相关业务拿出来，去掉切面
// extracted(request.toJson(),request.getClass().getName(), apiKey, message,JPUSH_RID_MSG_IMPORT_DESC,MessageResult.WAIT);
// return new MessageImportSendResponse(message.getId());
// }
//
// private void extracted(String json, String calssName, String apiKey, QtkMessage message, String description, MessageResult result) throws ManagerException {
// MessageRecord messageRecord = messageRecordAspectManager.createMessageRecord(apiKey);
// messageRecord.setRequestDataJson(json);
// messageRecord.setRequestClassName(calssName);
// messageRecord.setQtkMessageId(message.getId());
// messageRecord.setTitle(message.getMessageTitle());
// messageRecord.setDescription(description);
// messageRecord.setSendResult(result);
// messageRecordAspectManager.record(messageRecord);
// }
}

Write Preview
Loading…
취소
저장