batch push

config/config.yaml

@@ -236,6 +236,7 @@ groupMessageHasReadReceiptEnable: false
 singleMessageHasReadReceiptEnable: false
 
 
+
 #token config
 tokenpolicy:
   accessSecret: "open_im_server" #token生成相关，默认即可

internal/msg_gateway/gate/batch_push.go

@@ -33,6 +33,15 @@ func (r *RPCServer) GenPullSeqList(currentSeq uint32, operationID string, userID
 	log.Info(operationID, "GenPullSeqList ", seqList, "current seq", currentSeq)
 	return seqList, nil
 }
+
+func (r *RPCServer) GetSingleUserMsgForPushPlatforms(operationID string, msgData *sdk_ws.MsgData, pushToUserID string, platformIDList []int) map[int][]*sdk_ws.MsgData {
+	user2PushMsg := make(map[int][]*sdk_ws.MsgData, 0)
+	for _, v := range platformIDList {
+		user2PushMsg[v] = r.GetSingleUserMsgForPush(operationID, msgData, pushToUserID, v)
+	}
+	return user2PushMsg
+}
+
 func (r *RPCServer) GetSingleUserMsgForPush(operationID string, msgData *sdk_ws.MsgData, pushToUserID string, platformID int) []*sdk_ws.MsgData {
 	userConn := ws.getUserConn(pushToUserID, platformID)
 	if userConn == nil {