diff --git a/src/main/java/com/ifish/helper/JpushHelper.java b/src/main/java/com/ifish/helper/JpushHelper.java index fac3bc8..a919b9e 100644 --- a/src/main/java/com/ifish/helper/JpushHelper.java +++ b/src/main/java/com/ifish/helper/JpushHelper.java @@ -26,8 +26,8 @@ public class JpushHelper implements JpushHelperI { // private static final String masterSecret = "60162c8cf195ce9f4dc76629"; // private static final String appKey = "d970d5e193cb2a0bbe41653c"; //测试 - private final static String masterSecret = "a7d41825e75082b13675c326"; - private final static String appKey = "d147124018074eb970474e48"; + private final static String masterSecret = "4f759a0609dcd9d2edb06125"; + private final static String appKey = "6e5e9d757570859b3f274bb8"; static { jPushClient = new JPushClient(masterSecret, appKey); @@ -40,12 +40,12 @@ public class JpushHelper implements JpushHelperI { * @return */ @Override - public boolean pushMessageByAndroid(String message, String registrationID, Map map) { + public boolean pushMessageByAndroid(String title, String message, String userId, Map map) { try { PushPayload payload = PushPayload.newBuilder() .setPlatform(Platform.android()) - .setAudience(Audience.registrationId(registrationID)) - .setNotification(Notification.android("爱鱼奇提示", message, map)) + .setAudience(Audience.alias(userId)) + .setNotification(Notification.android(title, message, map)) .build(); PushResult result = jPushClient.sendPush(payload); @@ -65,12 +65,12 @@ public class JpushHelper implements JpushHelperI { * @return */ @Override - public boolean pushMessageByIOS(String message, String registrationID, Map map) { + public boolean pushMessageByIOS(String title, String message, String userId, Map map) { try { PushPayload payload = PushPayload.newBuilder() .setPlatform(Platform.ios()) - .setAudience(Audience.registrationId(registrationID)) - .setNotification(Notification.android("爱鱼奇提示", message, map)) + .setAudience(Audience.alias(userId)) + .setNotification(Notification.ios(message, map)) .build(); PushResult result = jPushClient.sendPush(payload); diff --git a/src/main/java/com/ifish/helper/JpushHelperI.java b/src/main/java/com/ifish/helper/JpushHelperI.java index ae21f87..74e317f 100644 --- a/src/main/java/com/ifish/helper/JpushHelperI.java +++ b/src/main/java/com/ifish/helper/JpushHelperI.java @@ -19,7 +19,7 @@ public interface JpushHelperI { * @param message * @return */ - boolean pushMessageByAndroid(String message, String registrationID, Map map); + boolean pushMessageByAndroid(String title, String message, String userId, Map map); /** * 向苹果手机推送一条信息 @@ -27,5 +27,5 @@ public interface JpushHelperI { * @param message * @return */ - boolean pushMessageByIOS(String message, String registrationID, Map map); + boolean pushMessageByIOS(String title, String message, String userId, Map map); } diff --git a/src/main/java/com/ifish/push/JiGuangPush.java b/src/main/java/com/ifish/push/JiGuangPush.java deleted file mode 100644 index 86d7c0c..0000000 --- a/src/main/java/com/ifish/push/JiGuangPush.java +++ /dev/null @@ -1,18 +0,0 @@ -/* - * To change this license header, choose License Headers in Project Properties. - * To change this template file, choose Tools | Templates - * and open the template in the editor. - */ -package com.ifish.push; - -import cn.jiguang.common.ClientConfig; -import cn.jpush.api.JPushClient; -import cn.jpush.api.push.model.PushPayload; - -/** - * - * @author Administrator - */ -public class JiGuangPush { - -} diff --git a/src/main/java/com/ifish/socket/config/ExecuteJob.java b/src/main/java/com/ifish/socket/config/ExecuteJob.java index 9382561..bb487bf 100644 --- a/src/main/java/com/ifish/socket/config/ExecuteJob.java +++ b/src/main/java/com/ifish/socket/config/ExecuteJob.java @@ -80,8 +80,7 @@ public class ExecuteJob implements Job { Integer deviceId = deviceUser.getDeviceId(); if (user != null) { String loginType = user.getLoginType(); - String registrationID = user.getJiguangUserid(); - if (StringUtils.isNotBlank(loginType) && StringUtils.isNotBlank(registrationID)) { + if (StringUtils.isNotBlank(loginType) && userId != null) { Map map = new HashMap(); map.put("device_id", deviceId.toString()); map.put("device_name", showName); @@ -90,9 +89,9 @@ public class ExecuteJob implements Job { //极光推送 boolean result = false; if (loginType.equals("android")) { - result = jpushHelperI.pushMessageByAndroid(msg, registrationID, map); + result = jpushHelperI.pushMessageByAndroid(title, msg, userId.toString(), map); } else if (loginType.equals("ios")) { - result = jpushHelperI.pushMessageByAndroid(msg, registrationID, map); + result = jpushHelperI.pushMessageByIOS(title, msg, userId.toString(), map); } if (result) { //推送记录 diff --git a/src/main/java/com/ifish/socket/config/SomeServer.java b/src/main/java/com/ifish/socket/config/SomeServer.java index 1899327..7e95d7f 100644 --- a/src/main/java/com/ifish/socket/config/SomeServer.java +++ b/src/main/java/com/ifish/socket/config/SomeServer.java @@ -45,7 +45,7 @@ import org.springframework.beans.factory.annotation.Autowired; * @author Administrator */ public class SomeServer { - + @Autowired private UserHelperI userHelperI; @Autowired @@ -60,7 +60,7 @@ public class SomeServer { //是否回复心跳 public static boolean isReplay = true; - + private static Logger log = LoggerFactory.getLogger(SomeServer.class); public static ConcurrentHashMap remoteAddress = new ConcurrentHashMap(); public static ConcurrentHashMap sessions_cz = new ConcurrentHashMap(); @@ -310,8 +310,7 @@ public class SomeServer { //极光推送 boolean result = false; String loginType = user.getLoginType(); - String registrationID = user.getJiguangUserid(); - if (StringUtils.isNotBlank(loginType) && StringUtils.isNotBlank(registrationID)) { + if (StringUtils.isNotBlank(loginType) && userId != null) { //推送记录 Tbl_Push_List pushList = new Tbl_Push_List(); Map map = new HashMap(); @@ -319,11 +318,11 @@ public class SomeServer { map.put("device_name", showName); map.put("timestamp", timestamp); map.put("msg_type", PushTypeEnum.wendu_warn.getKey()); - + if (loginType.equals("android")) { - result = jpushHelperI.pushMessageByAndroid(msg, registrationID, map); + result = jpushHelperI.pushMessageByAndroid(title, msg, userId.toString(), map); } else if (loginType.equals("ios")) { - result = jpushHelperI.pushMessageByAndroid(msg, registrationID, map); + result = jpushHelperI.pushMessageByIOS(title, msg, userId.toString(), map); } //记录推送 if (result) { @@ -346,7 +345,7 @@ public class SomeServer { } } } - + } } } catch (Exception e) {