|
@@ -79,11 +79,10 @@ public class DispatchMessage {
|
|
|
messageDto.setDate(date);
|
|
|
List<String> connectInfos = redisUtil.opsForList().range(userConnections, 0, size);
|
|
|
if(channel==1){
|
|
|
- List<String>alias=new ArrayList<>();
|
|
|
- alias.add(receiveMessage.getUserId()+"");
|
|
|
- MessagePush.sendAlias(receiveMessage.getMessageContent(),alias);
|
|
|
- //app推送
|
|
|
+ sendAppMsg(receiveMessage.getUserId()+"",receiveMessage.getMessageContent());
|
|
|
+
|
|
|
}else{
|
|
|
+
|
|
|
connectInfos.forEach(connectInfo ->{
|
|
|
WebsocketConnectInfo websocketConnectInfo =
|
|
|
JSONObject.parseObject(connectInfo, WebsocketConnectInfo.class);
|
|
@@ -101,4 +100,11 @@ public class DispatchMessage {
|
|
|
}
|
|
|
|
|
|
}
|
|
|
+ //app推送
|
|
|
+ private void sendAppMsg(String userId,String content){
|
|
|
+ List<String>alias=new ArrayList<>();
|
|
|
+ alias.add(userId);
|
|
|
+ MessagePush.sendAlias(content,alias);
|
|
|
+
|
|
|
+ }
|
|
|
}
|