admin/push_server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ios平台也可能使用个推

Browse Source
This commit is contained in:
heavyrian2012
2023-10-08 10:47:22 +08:00
parent 7251995cea
commit 2f31ff1fe0
3 changed files with 15 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/cn/wildfirechat/push/android/AndroidPushServiceImpl.java
View File

@@ -89,7 +89,7 @@ public class AndroidPushServiceImpl implements AndroidPushService {
fcmPush.push(pushMessage); fcmPush.push(pushMessage);
break; break;
case AndroidPushType.ANDROID_PUSH_TYPE_GETUI: case AndroidPushType.ANDROID_PUSH_TYPE_GETUI:
getuiPush.push(pushMessage); getuiPush.push(pushMessage, true);
break; break;
default: default:
LOG.info("unknown push type"); LOG.info("unknown push type");

2
src/main/java/cn/wildfirechat/push/android/getui/GetuiPush.java
View File

@@ -61,7 +61,7 @@ public class GetuiPush {
} }
public void push(PushMessage pushMessage) { public void push(PushMessage pushMessage, boolean isAndroid) {
if (pushMessage.pushMessageType == PushMessageType.PUSH_MESSAGE_TYPE_RECALLED || pushMessage.pushMessageType == PushMessageType.PUSH_MESSAGE_TYPE_DELETED) { if (pushMessage.pushMessageType == PushMessageType.PUSH_MESSAGE_TYPE_RECALLED || pushMessage.pushMessageType == PushMessageType.PUSH_MESSAGE_TYPE_DELETED) {
//Todo not implement //Todo not implement
//撤回或者删除消息，需要更新远程通知，暂未实现 //撤回或者删除消息，需要更新远程通知，暂未实现

14
src/main/java/cn/wildfirechat/push/ios/IOSPushServiceImpl.java
View File

@@ -3,6 +3,8 @@ package cn.wildfirechat.push.ios;
import cn.wildfirechat.push.PushMessage; import cn.wildfirechat.push.PushMessage;
import cn.wildfirechat.push.PushMessageType; import cn.wildfirechat.push.PushMessageType;
import cn.wildfirechat.push.Utility; import cn.wildfirechat.push.Utility;
import cn.wildfirechat.push.android.AndroidPushType;
import cn.wildfirechat.push.android.getui.GetuiPush;
import com.google.gson.Gson; import com.google.gson.Gson;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -20,6 +22,9 @@ public class IOSPushServiceImpl implements IOSPushService {
@Autowired @Autowired
public ApnsServer apnsServer; public ApnsServer apnsServer;
@Autowired
private GetuiPush getuiPush;
private ExecutorService executorService = new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors(), Runtime.getRuntime().availableProcessors() * 100, private ExecutorService executorService = new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors(), Runtime.getRuntime().availableProcessors() * 100,
60L, TimeUnit.SECONDS, 60L, TimeUnit.SECONDS,
new SynchronousQueue<Runnable>()); new SynchronousQueue<Runnable>());
@@ -38,7 +43,14 @@ public class IOSPushServiceImpl implements IOSPushService {
LOG.error("等待太久，消息抛弃"); LOG.error("等待太久，消息抛弃");
return; return;
} }
apnsServer.pushMessage(pushMessage); if(pushMessage.pushType < 3) {
apnsServer.pushMessage(pushMessage);
} else if(pushMessage.pushType == AndroidPushType.ANDROID_PUSH_TYPE_GETUI) {
getuiPush.push(pushMessage, false);
} else {
LOG.error("Unknown ios push type: {}", pushMessage.pushType);
}
}); });
return "OK"; return "OK";
} }