blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-11-05 11:52:10 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: notification has counted unread counts bug fix.

Browse Source
This commit is contained in:
Gordon 2024-05-14 11:41:40 +08:00
parent 3388513b0d
commit 675fe8347c
1 changed files with 9 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
internal/msgtransfer/online_history_msg_handler.go
View File

@ -147,20 +147,15 @@ func (och *OnlineHistoryRedisConsumerHandler) categorizeMessageLists(totalMsgs [
if v.message.Options != nil { if v.message.Options != nil {
msg.Options = msgprocessor.NewMsgOptions() msg.Options = msgprocessor.NewMsgOptions()
} }
if options.IsOfflinePush() { msg.Options = msgprocessor.WithOptions(msg.Options,
msgprocessor.WithOfflinePush(options.IsOfflinePush()),
msgprocessor.WithUnreadCount(options.IsUnreadCount()),
)
v.message.Options = msgprocessor.WithOptions( v.message.Options = msgprocessor.WithOptions(
v.message.Options, v.message.Options,
msgprocessor.WithOfflinePush(false), msgprocessor.WithOfflinePush(false),
)
msg.Options = msgprocessor.WithOptions(msg.Options, msgprocessor.WithOfflinePush(true))
}
if options.IsUnreadCount() {
v.message.Options = msgprocessor.WithOptions(
v.message.Options,
msgprocessor.WithUnreadCount(false), msgprocessor.WithUnreadCount(false),
) )
msg.Options = msgprocessor.WithOptions(msg.Options, msgprocessor.WithUnreadCount(true))
}
ctxMsg := &ContextMsg{ ctxMsg := &ContextMsg{
message: msg, message: msg,
ctx: v.ctx, ctx: v.ctx,