mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-11-04 19:32:17 +08:00
76d9688a54
* refactor: db refactor and cache key add. * refactor: db refactor and cache key add. * refactor: go version update. * refactor: file name change.
99 lines
3.3 KiB
Go
99 lines
3.3 KiB
Go
// Copyright © 2023 OpenIM. All rights reserved.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package convert
|
|
|
|
import (
|
|
"github.com/openimsdk/open-im-server/v3/pkg/common/storage/model"
|
|
"github.com/openimsdk/protocol/constant"
|
|
"github.com/openimsdk/protocol/sdkws"
|
|
)
|
|
|
|
func MsgPb2DB(msg *sdkws.MsgData) *model.MsgDataModel {
|
|
if msg == nil {
|
|
return nil
|
|
}
|
|
var msgDataModel model.MsgDataModel
|
|
msgDataModel.SendID = msg.SendID
|
|
msgDataModel.RecvID = msg.RecvID
|
|
msgDataModel.GroupID = msg.GroupID
|
|
msgDataModel.ClientMsgID = msg.ClientMsgID
|
|
msgDataModel.ServerMsgID = msg.ServerMsgID
|
|
msgDataModel.SenderPlatformID = msg.SenderPlatformID
|
|
msgDataModel.SenderNickname = msg.SenderNickname
|
|
msgDataModel.SenderFaceURL = msg.SenderFaceURL
|
|
msgDataModel.SessionType = msg.SessionType
|
|
msgDataModel.MsgFrom = msg.MsgFrom
|
|
msgDataModel.ContentType = msg.ContentType
|
|
msgDataModel.Content = string(msg.Content)
|
|
msgDataModel.Seq = msg.Seq
|
|
msgDataModel.SendTime = msg.SendTime
|
|
msgDataModel.CreateTime = msg.CreateTime
|
|
msgDataModel.Status = msg.Status
|
|
msgDataModel.Options = msg.Options
|
|
if msg.OfflinePushInfo != nil {
|
|
msgDataModel.OfflinePush = &model.OfflinePushModel{
|
|
Title: msg.OfflinePushInfo.Title,
|
|
Desc: msg.OfflinePushInfo.Desc,
|
|
Ex: msg.OfflinePushInfo.Ex,
|
|
IOSPushSound: msg.OfflinePushInfo.IOSPushSound,
|
|
IOSBadgeCount: msg.OfflinePushInfo.IOSBadgeCount,
|
|
}
|
|
}
|
|
msgDataModel.AtUserIDList = msg.AtUserIDList
|
|
msgDataModel.AttachedInfo = msg.AttachedInfo
|
|
msgDataModel.Ex = msg.Ex
|
|
return &msgDataModel
|
|
}
|
|
|
|
func MsgDB2Pb(msgModel *model.MsgDataModel) *sdkws.MsgData {
|
|
if msgModel == nil {
|
|
return nil
|
|
}
|
|
var msg sdkws.MsgData
|
|
msg.SendID = msgModel.SendID
|
|
msg.RecvID = msgModel.RecvID
|
|
msg.GroupID = msgModel.GroupID
|
|
msg.ClientMsgID = msgModel.ClientMsgID
|
|
msg.ServerMsgID = msgModel.ServerMsgID
|
|
msg.SenderPlatformID = msgModel.SenderPlatformID
|
|
msg.SenderNickname = msgModel.SenderNickname
|
|
msg.SenderFaceURL = msgModel.SenderFaceURL
|
|
msg.SessionType = msgModel.SessionType
|
|
msg.MsgFrom = msgModel.MsgFrom
|
|
msg.ContentType = msgModel.ContentType
|
|
msg.Content = []byte(msgModel.Content)
|
|
msg.Seq = msgModel.Seq
|
|
msg.SendTime = msgModel.SendTime
|
|
msg.CreateTime = msgModel.CreateTime
|
|
msg.Status = msgModel.Status
|
|
if msgModel.SessionType == constant.SingleChatType {
|
|
msg.IsRead = msgModel.IsRead
|
|
}
|
|
msg.Options = msgModel.Options
|
|
if msgModel.OfflinePush != nil {
|
|
msg.OfflinePushInfo = &sdkws.OfflinePushInfo{
|
|
Title: msgModel.OfflinePush.Title,
|
|
Desc: msgModel.OfflinePush.Desc,
|
|
Ex: msgModel.OfflinePush.Ex,
|
|
IOSPushSound: msgModel.OfflinePush.IOSPushSound,
|
|
IOSBadgeCount: msgModel.OfflinePush.IOSBadgeCount,
|
|
}
|
|
}
|
|
msg.AtUserIDList = msgModel.AtUserIDList
|
|
msg.AttachedInfo = msgModel.AttachedInfo
|
|
msg.Ex = msgModel.Ex
|
|
return &msg
|
|
}
|