|
|
@ -6,7 +6,7 @@ import (
|
|
|
|
"Open_IM/pkg/common/constant"
|
|
|
|
"Open_IM/pkg/common/constant"
|
|
|
|
"Open_IM/pkg/common/db"
|
|
|
|
"Open_IM/pkg/common/db"
|
|
|
|
imdb "Open_IM/pkg/common/db/mysql_model/im_mysql_model"
|
|
|
|
imdb "Open_IM/pkg/common/db/mysql_model/im_mysql_model"
|
|
|
|
"Open_IM/pkg/common/db/rocks_cache"
|
|
|
|
rocksCache "Open_IM/pkg/common/db/rocks_cache"
|
|
|
|
"Open_IM/pkg/common/http"
|
|
|
|
"Open_IM/pkg/common/http"
|
|
|
|
"Open_IM/pkg/common/log"
|
|
|
|
"Open_IM/pkg/common/log"
|
|
|
|
"Open_IM/pkg/common/token_verify"
|
|
|
|
"Open_IM/pkg/common/token_verify"
|
|
|
@ -19,12 +19,13 @@ import (
|
|
|
|
pbUser "Open_IM/pkg/proto/user"
|
|
|
|
pbUser "Open_IM/pkg/proto/user"
|
|
|
|
"Open_IM/pkg/utils"
|
|
|
|
"Open_IM/pkg/utils"
|
|
|
|
"context"
|
|
|
|
"context"
|
|
|
|
"google.golang.org/grpc"
|
|
|
|
|
|
|
|
"math/big"
|
|
|
|
"math/big"
|
|
|
|
"net"
|
|
|
|
"net"
|
|
|
|
"strconv"
|
|
|
|
"strconv"
|
|
|
|
"strings"
|
|
|
|
"strings"
|
|
|
|
"time"
|
|
|
|
"time"
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
"google.golang.org/grpc"
|
|
|
|
)
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
type groupServer struct {
|
|
|
|
type groupServer struct {
|
|
|
@ -381,7 +382,7 @@ func (s *groupServer) InviteUserToGroup(ctx context.Context, req *pbGroup.Invite
|
|
|
|
haveConUserID = append(haveConUserID, v.OwnerUserID)
|
|
|
|
haveConUserID = append(haveConUserID, v.OwnerUserID)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
var reqPb pbUser.SetConversationReq
|
|
|
|
var reqPb pbUser.SetConversationReq
|
|
|
|
var c pbUser.Conversation
|
|
|
|
var c pbConversation.Conversation
|
|
|
|
for _, v := range conversations {
|
|
|
|
for _, v := range conversations {
|
|
|
|
reqPb.OperationID = req.OperationID
|
|
|
|
reqPb.OperationID = req.OperationID
|
|
|
|
c.OwnerUserID = v.OwnerUserID
|
|
|
|
c.OwnerUserID = v.OwnerUserID
|
|
|
@ -634,7 +635,7 @@ func (s *groupServer) KickGroupMember(ctx context.Context, req *pbGroup.KickGrou
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
var reqPb pbUser.SetConversationReq
|
|
|
|
var reqPb pbUser.SetConversationReq
|
|
|
|
var c pbUser.Conversation
|
|
|
|
var c pbConversation.Conversation
|
|
|
|
for _, v := range okUserIDList {
|
|
|
|
for _, v := range okUserIDList {
|
|
|
|
reqPb.OperationID = req.OperationID
|
|
|
|
reqPb.OperationID = req.OperationID
|
|
|
|
c.OwnerUserID = v
|
|
|
|
c.OwnerUserID = v
|
|
|
@ -867,7 +868,7 @@ func (s *groupServer) GroupApplicationResponse(_ context.Context, req *pbGroup.G
|
|
|
|
}
|
|
|
|
}
|
|
|
|
var reqPb pbUser.SetConversationReq
|
|
|
|
var reqPb pbUser.SetConversationReq
|
|
|
|
reqPb.OperationID = req.OperationID
|
|
|
|
reqPb.OperationID = req.OperationID
|
|
|
|
var c pbUser.Conversation
|
|
|
|
var c pbConversation.Conversation
|
|
|
|
conversation, err := imdb.GetConversation(req.FromUserID, utils.GetConversationIDBySessionType(req.GroupID, constant.GroupChatType))
|
|
|
|
conversation, err := imdb.GetConversation(req.FromUserID, utils.GetConversationIDBySessionType(req.GroupID, constant.GroupChatType))
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
c.OwnerUserID = req.FromUserID
|
|
|
|
c.OwnerUserID = req.FromUserID
|
|
|
@ -1061,7 +1062,7 @@ func (s *groupServer) QuitGroup(ctx context.Context, req *pbGroup.QuitGroupReq)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
//modify quitter conversation info
|
|
|
|
//modify quitter conversation info
|
|
|
|
var reqPb pbUser.SetConversationReq
|
|
|
|
var reqPb pbUser.SetConversationReq
|
|
|
|
var c pbUser.Conversation
|
|
|
|
var c pbConversation.Conversation
|
|
|
|
reqPb.OperationID = req.OperationID
|
|
|
|
reqPb.OperationID = req.OperationID
|
|
|
|
c.OwnerUserID = req.OpUserID
|
|
|
|
c.OwnerUserID = req.OpUserID
|
|
|
|
c.ConversationID = utils.GetConversationIDBySessionType(req.GroupID, constant.GroupChatType)
|
|
|
|
c.ConversationID = utils.GetConversationIDBySessionType(req.GroupID, constant.GroupChatType)
|
|
|
@ -1515,7 +1516,7 @@ func (s *groupServer) RemoveGroupMembersCMS(_ context.Context, req *pbGroup.Remo
|
|
|
|
OpUserID: req.OpUserID,
|
|
|
|
OpUserID: req.OpUserID,
|
|
|
|
}
|
|
|
|
}
|
|
|
|
var reqPb pbUser.SetConversationReq
|
|
|
|
var reqPb pbUser.SetConversationReq
|
|
|
|
var c pbUser.Conversation
|
|
|
|
var c pbConversation.Conversation
|
|
|
|
for _, v := range resp.Success {
|
|
|
|
for _, v := range resp.Success {
|
|
|
|
reqPb.OperationID = req.OperationID
|
|
|
|
reqPb.OperationID = req.OperationID
|
|
|
|
c.OwnerUserID = v
|
|
|
|
c.OwnerUserID = v
|
|
|
@ -1700,7 +1701,7 @@ func (s *groupServer) DismissGroup(ctx context.Context, req *pbGroup.DismissGrou
|
|
|
|
}
|
|
|
|
}
|
|
|
|
//modify quitter conversation info
|
|
|
|
//modify quitter conversation info
|
|
|
|
var reqPb pbUser.SetConversationReq
|
|
|
|
var reqPb pbUser.SetConversationReq
|
|
|
|
var c pbUser.Conversation
|
|
|
|
var c pbConversation.Conversation
|
|
|
|
for _, v := range memberList {
|
|
|
|
for _, v := range memberList {
|
|
|
|
reqPb.OperationID = req.OperationID
|
|
|
|
reqPb.OperationID = req.OperationID
|
|
|
|
c.OwnerUserID = v.UserID
|
|
|
|
c.OwnerUserID = v.UserID
|
|
|
|