blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-04-23 18:00:32 +08:00
Code Issues Packages Projects Releases Wiki Activity

conversation unread modify

Browse Source
This commit is contained in:
Gordon 2022-09-05 19:07:16 +08:00
parent 6af9d3129e
commit 6c8b115479
4 changed files with 333 additions and 321 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/rpc/conversation/conversaion.go
View File

@ -117,7 +117,7 @@ func (rpc *rpcConversation) ModifyConversationField(c context.Context, req *pbCo
if err = rocksCache.DelConversationFromCache(v, req.Conversation.ConversationID); err != nil { if err = rocksCache.DelConversationFromCache(v, req.Conversation.ConversationID); err != nil {
log.NewError(req.OperationID, utils.GetSelfFuncName(), v, req.Conversation.ConversationID, err.Error()) log.NewError(req.OperationID, utils.GetSelfFuncName(), v, req.Conversation.ConversationID, err.Error())
} }
chat.ConversationUnreadChangeNotification(req.OperationID, v, req.Conversation.ConversationID) chat.ConversationUnreadChangeNotification(req.OperationID, v, req.Conversation.ConversationID, conversation.UpdateUnreadCountTime)
} }
} }

3
internal/rpc/msg/conversation_notification.go
View File

@ -70,11 +70,12 @@ func ConversationChangeNotification(operationID, userID string) {
} }
//会话未读数同步 //会话未读数同步
func ConversationUnreadChangeNotification(operationID, userID, conversationID string) { func ConversationUnreadChangeNotification(operationID, userID, conversationID string, updateUnreadCountTime int64) {
log.NewInfo(operationID, utils.GetSelfFuncName()) log.NewInfo(operationID, utils.GetSelfFuncName())
ConversationChangedTips := &open_im_sdk.ConversationUpdateTips{ ConversationChangedTips := &open_im_sdk.ConversationUpdateTips{
UserID: userID, UserID: userID,
ConversationIDList: []string{conversationID}, ConversationIDList: []string{conversationID},
UpdateUnreadCountTime: updateUnreadCountTime,
} }
var tips open_im_sdk.TipsComm var tips open_im_sdk.TipsComm
tips.DefaultTips = config.Config.Notification.ConversationOptUpdate.DefaultTips.Tips tips.DefaultTips = config.Config.Notification.ConversationOptUpdate.DefaultTips.Tips

632
pkg/proto/sdk_ws/ws.pb.go
View File

File diff suppressed because it is too large Load Diff

3
pkg/proto/sdk_ws/ws.proto
View File

@ -494,6 +494,9 @@ message UserInfoUpdatedTips{
message ConversationUpdateTips{ message ConversationUpdateTips{
string UserID = 1; string UserID = 1;
repeated string conversationIDList = 2; repeated string conversationIDList = 2;
int64 updateUnreadCountTime = 3;
} }
message ConversationSetPrivateTips{ message ConversationSetPrivateTips{