diff --git a/pkg/common/db/mongoModel.go b/pkg/common/db/mongoModel.go index 2234e0306..72462a898 100644 --- a/pkg/common/db/mongoModel.go +++ b/pkg/common/db/mongoModel.go @@ -264,20 +264,21 @@ func (d *DataBases) GetUserMsgListByIndex(ID string, index int64) (*UserChat, er c := d.mongoClient.Database(config.Config.Mongo.DBDatabase).Collection(cChat) regex := fmt.Sprintf("^%s", ID) findOpts := options.Find().SetLimit(1).SetSkip(index).SetSort(bson.M{"uid": 1}) - var msgs []*UserChat + var msg UserChat cursor, err := c.Find(ctx, bson.M{"uid": bson.M{"$regex": regex}}, findOpts) if err != nil { return nil, utils.Wrap(err, "") } - err = cursor.Decode(&msgs) + err = cursor.Decode(&msg) if err != nil { - return nil, utils.Wrap(err, "") - } - if len(msgs) > 0 { - return msgs[0], err - } else { - return nil, errors.New("get msg list failed") + return nil, utils.Wrap(err, fmt.Sprintf("cursor is %s", cursor.Current.String())) } + //if len(msgs) > 0 { + // return msgs[0], err + //} else { + // return nil, errors.New("get msg list failed") + //} + return &msg, nil } func (d *DataBases) DelMongoMsgs(IDList []string) error {