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

push content modify

Browse Source
This commit is contained in:
Gordon 2021-11-04 17:27:12 +08:00
parent 2440575093
commit cdf928d64e
2 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/common/db/mongoModel.go
View File

@ -5,7 +5,6 @@ import (
"Open_IM/src/common/constant" "Open_IM/src/common/constant"
"Open_IM/src/common/log" "Open_IM/src/common/log"
pbMsg "Open_IM/src/proto/chat" pbMsg "Open_IM/src/proto/chat"
"Open_IM/src/utils"
"errors" "errors"
"github.com/golang/protobuf/proto" "github.com/golang/protobuf/proto"
"gopkg.in/mgo.v2/bson" "gopkg.in/mgo.v2/bson"
@ -125,7 +124,7 @@ func (d *DataBases) GetMsgBySeqList(uid string, seqList []int64) (SingleMsg []*p
log.NewError("", "not find seqUid", seqUid, value, uid, seqList) log.NewError("", "not find seqUid", seqUid, value, uid, seqList)
return nil, nil, MaxSeq, MinSeq, err return nil, nil, MaxSeq, MinSeq, err
} }
if utils.IsContainInt64(pChat.RecvSeq, value) { if isContainInt64(pChat.RecvSeq, value) {
temp.SendID = pChat.SendID temp.SendID = pChat.SendID
temp.RecvID = pChat.RecvID temp.RecvID = pChat.RecvID
temp.MsgFrom = pChat.MsgFrom temp.MsgFrom = pChat.MsgFrom
@ -319,3 +318,14 @@ func getSeqUid(uid string, seq int64) string {
seqSuffix := seq / singleGocMsgNum seqSuffix := seq / singleGocMsgNum
return uid + ":" + strconv.FormatInt(seqSuffix, 10) return uid + ":" + strconv.FormatInt(seqSuffix, 10)
} }
func isContainInt64(target int64, List []int64) bool {
for _, element := range List {
if target == element {
return true
}
}
return false
}

10
src/utils/strings.go
View File

@ -37,17 +37,7 @@ func IsContain(target string, List []string) bool {
return false return false
} }
func IsContainInt64(target int64, List []int64) bool {
for _, element := range List {
if target == element {
return true
}
}
return false
}
func InterfaceArrayToStringArray(data []interface{}) (i []string) { func InterfaceArrayToStringArray(data []interface{}) (i []string) {
for _, param := range data { for _, param := range data {
i = append(i, param.(string)) i = append(i, param.(string))