|
|
@ -176,20 +176,15 @@ func (och *OnlineHistoryRedisConsumerHandler) getPushStorageMsgList(
|
|
|
|
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,
|
|
|
|
v.message.Options = msgprocessor.WithOptions(
|
|
|
|
msgprocessor.WithOfflinePush(options.IsOfflinePush()),
|
|
|
|
v.message.Options,
|
|
|
|
msgprocessor.WithUnreadCount(options.IsUnreadCount()),
|
|
|
|
msgprocessor.WithOfflinePush(false),
|
|
|
|
|
|
|
|
)
|
|
|
|
)
|
|
|
|
msg.Options = msgprocessor.WithOptions(msg.Options, msgprocessor.WithOfflinePush(true))
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
if options.IsUnreadCount() {
|
|
|
|
|
|
|
|
v.message.Options = msgprocessor.WithOptions(
|
|
|
|
v.message.Options = msgprocessor.WithOptions(
|
|
|
|
v.message.Options,
|
|
|
|
v.message.Options,
|
|
|
|
|
|
|
|
msgprocessor.WithOfflinePush(false),
|
|
|
|
msgprocessor.WithUnreadCount(false),
|
|
|
|
msgprocessor.WithUnreadCount(false),
|
|
|
|
)
|
|
|
|
)
|
|
|
|
msg.Options = msgprocessor.WithOptions(msg.Options, msgprocessor.WithUnreadCount(true))
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
storageMsgList = append(storageMsgList, msg)
|
|
|
|
storageMsgList = append(storageMsgList, msg)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if isStorage(v.message) {
|
|
|
|
if isStorage(v.message) {
|
|
|
|