From 5fd91e808a88d5c6e9e0647890b4950fca3127d7 Mon Sep 17 00:00:00 2001
From: skiffer-git <44203734@qq.com>
Date: Thu, 9 Jun 2022 14:07:09 +0800
Subject: [PATCH] batch push

---
 internal/msg_gateway/gate/batch_push.go | 28 +++++++++++--------------
 1 file changed, 12 insertions(+), 16 deletions(-)

diff --git a/internal/msg_gateway/gate/batch_push.go b/internal/msg_gateway/gate/batch_push.go
index c373fa996..6a7e7886f 100644
--- a/internal/msg_gateway/gate/batch_push.go
+++ b/internal/msg_gateway/gate/batch_push.go
@@ -1,31 +1,27 @@
 package gate
 
 import (
-	"Open_IM/pkg/common/config"
-	"Open_IM/pkg/grpc-etcdv3/getcdv3"
-	pbChat "Open_IM/pkg/proto/chat"
 	sdk_ws "Open_IM/pkg/proto/sdk_ws"
-	"strings"
 )
 
 var MaxPullMsgNum = 100
 
 func (r *RPCServer) GenPullSeqList(currentSeq uint32, operationID string, userID string) ([]uint32, error) {
-
+	return nil, nil
 }
 
 func (r *RPCServer) GetSingleMsgForPush(operationID string, msgData *sdk_ws.MsgData, pushToUserID string, platformID string) []*sdk_ws.MsgData {
-	seqList, err := r.GenPullSeqList(msgData.Seq, operationID, pushToUserID)
-	if err != nil {
-		return nil
-	}
-	rpcReq := sdk_ws.PullMessageBySeqListReq{}
-	rpcReq.SeqList = seqList
-	rpcReq.UserID = pushToUserID
-	rpcReq.OperationID = operationID
-	grpcConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImOfflineMessageName)
-	msgClient := pbChat.NewChatClient(grpcConn)
-	reply, err := msgClient.PullMessageBySeqList(context.Background(), &rpcReq)
+	//seqList, err := r.GenPullSeqList(msgData.Seq, operationID, pushToUserID)
+	//if err != nil {
+	//	return nil
+	//}
+	//rpcReq := sdk_ws.PullMessageBySeqListReq{}
+	//rpcReq.SeqList = seqList
+	//rpcReq.UserID = pushToUserID
+	//rpcReq.OperationID = operationID
+	//grpcConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImOfflineMessageName)
+	//msgClient := pbChat.NewChatClient(grpcConn)
+	//reply, err := msgClient.PullMessageBySeqList(context.Background(), &rpcReq)
 
 	return nil
 }