From e57ce28d2b41cc882cd62258aad441aeac039f97 Mon Sep 17 00:00:00 2001
From: skiffer-git <44203734@qq.com>
Date: Thu, 9 Jun 2022 17:04:16 +0800
Subject: [PATCH] batch push

---
 config/config.yaml                      | 1 +
 internal/msg_gateway/gate/batch_push.go | 9 +++++++++
 2 files changed, 10 insertions(+)

diff --git a/config/config.yaml b/config/config.yaml
index 29b4174d8..69ae4ed65 100644
--- a/config/config.yaml
+++ b/config/config.yaml
@@ -236,6 +236,7 @@ groupMessageHasReadReceiptEnable: false
 singleMessageHasReadReceiptEnable: false
 
 
+
 #token config
 tokenpolicy:
   accessSecret: "open_im_server" #token生成相关，默认即可
diff --git a/internal/msg_gateway/gate/batch_push.go b/internal/msg_gateway/gate/batch_push.go
index 075de0586..41c71c876 100644
--- a/internal/msg_gateway/gate/batch_push.go
+++ b/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 {