package db import ( pbMsg "Open_IM/pkg/proto/chat" "Open_IM/pkg/common/config" "Open_IM/pkg/common/constant" "errors" "github.com/golang/protobuf/proto" "gopkg.in/mgo.v2/bson" "time" ) const cChat = "chat" const cGroup = "group" type MsgInfo struct { SendTime int64 Msg []byte } type UserChat struct { UID string Msg []MsgInfo } type GroupMember struct { GroupID string UIDList []string } func (d *DataBases) GetUserChat(uid string, seqBegin, seqEnd int64) (SingleMsg []*pbMsg.MsgFormat, GroupMsg []*pbMsg.MsgFormat, MaxSeq int64, MinSeq int64, err error) { count := 0 session := d.mgoSession.Clone() if session == nil { return nil, nil, MaxSeq, MinSeq, errors.New("session == nil") } defer session.Close() c := session.DB(config.Config.Mongo.DBDatabase).C(cChat) sChat := UserChat{} if err = c.Find(bson.M{"uid": uid}).One(&sChat); err != nil { return nil, nil, MaxSeq, MinSeq, err } pChat := pbMsg.MsgSvrToPushSvrChatMsg{} for i := 0; i < len(sChat.Msg); i++ { temp := new(pbMsg.MsgFormat) if err = proto.Unmarshal(sChat.Msg[i].Msg, &pChat); err != nil { return nil, nil, MaxSeq, MinSeq, err } if pChat.RecvSeq >= seqBegin && pChat.RecvSeq <= seqEnd { temp.SendID = pChat.SendID temp.RecvID = pChat.RecvID temp.MsgFrom = pChat.MsgFrom temp.Seq = pChat.RecvSeq temp.ServerMsgID = pChat.MsgID temp.SendTime = pChat.SendTime temp.Content = pChat.Content temp.ContentType = pChat.ContentType temp.SenderPlatformID = pChat.PlatformID temp.ClientMsgID = pChat.ClientMsgID temp.SenderFaceURL = pChat.SenderFaceURL temp.SenderNickName = pChat.SenderNickName if pChat.RecvSeq > MaxSeq { MaxSeq = pChat.RecvSeq } if count == 0 { MinSeq = pChat.RecvSeq } if pChat.RecvSeq < MinSeq { MinSeq = pChat.RecvSeq } if pChat.SessionType == constant.SingleChatType { SingleMsg = append(SingleMsg, temp) } else { GroupMsg = append(GroupMsg, temp) } count++ } } return SingleMsg, GroupMsg, MaxSeq, MinSeq, nil } func (d *DataBases) SaveUserChat(uid string, sendTime int64, m proto.Message) error { session := d.mgoSession.Clone() if session == nil { return errors.New("session == nil") } defer session.Close() c := session.DB(config.Config.Mongo.DBDatabase).C(cChat) n, err := c.Find(bson.M{"uid": uid}).Count() if err != nil { return err } sMsg := MsgInfo{} sMsg.SendTime = sendTime if sMsg.Msg, err = proto.Marshal(m); err != nil { return err } if n == 0 { sChat := UserChat{} sChat.UID = uid sChat.Msg = append(sChat.Msg, sMsg) err = c.Insert(&sChat) if err != nil { return err } } else { err = c.Update(bson.M{"uid": uid}, bson.M{"$push": bson.M{"msg": sMsg}}) if err != nil { return err } } return nil } func (d *DataBases) DelUserChat(uid string) error { session := d.mgoSession.Clone() if session == nil { return errors.New("session == nil") } defer session.Close() c := session.DB(config.Config.Mongo.DBDatabase).C(cChat) delTime := time.Now().Unix() - int64(config.Config.Mongo.DBRetainChatRecords)*24*3600 if err := c.Update(bson.M{"uid": uid}, bson.M{"$pull": bson.M{"msg": bson.M{"sendtime": bson.M{"$lte": delTime}}}}); err != nil { return err } return nil } func (d *DataBases) MgoUserCount() (int, error) { session := d.mgoSession.Clone() if session == nil { return 0, errors.New("session == nil") } defer session.Close() c := session.DB(config.Config.Mongo.DBDatabase).C(cChat) return c.Find(nil).Count() } func (d *DataBases) MgoSkipUID(count int) (string, error) { session := d.mgoSession.Clone() if session == nil { return "", errors.New("session == nil") } defer session.Close() c := session.DB(config.Config.Mongo.DBDatabase).C(cChat) sChat := UserChat{} c.Find(nil).Skip(count).Limit(1).One(&sChat) return sChat.UID, nil } func (d *DataBases) GetGroupMember(groupID string) []string { groupInfo := GroupMember{} groupInfo.GroupID = groupID groupInfo.UIDList = make([]string, 0) session := d.mgoSession.Clone() if session == nil { return groupInfo.UIDList } defer session.Close() c := session.DB(config.Config.Mongo.DBDatabase).C(cGroup) if err := c.Find(bson.M{"groupid": groupInfo.GroupID}).One(&groupInfo); err != nil { return groupInfo.UIDList } return groupInfo.UIDList } func (d *DataBases) AddGroupMember(groupID, uid string) error { session := d.mgoSession.Clone() if session == nil { return errors.New("session == nil") } defer session.Close() c := session.DB(config.Config.Mongo.DBDatabase).C(cGroup) n, err := c.Find(bson.M{"groupid": groupID}).Count() if err != nil { return err } if n == 0 { groupInfo := GroupMember{} groupInfo.GroupID = groupID groupInfo.UIDList = append(groupInfo.UIDList, uid) err = c.Insert(&groupInfo) if err != nil { return err } } else { err = c.Update(bson.M{"groupid": groupID}, bson.M{"$addToSet": bson.M{"uidlist": uid}}) if err != nil { return err } } return nil } func (d *DataBases) DelGroupMember(groupID, uid string) error { session := d.mgoSession.Clone() if session == nil { return errors.New("session == nil") } defer session.Close() c := session.DB(config.Config.Mongo.DBDatabase).C(cGroup) if err := c.Update(bson.M{"groupid": groupID}, bson.M{"$pull": bson.M{"uidlist": uid}}); err != nil { return err } return nil }