shkong/go-cqhttp
1
0
Fork 0
mirror of https://github.com/Mrs4s/go-cqhttp.git synced 2025-05-05 03:23:49 +08:00
Code Issues Projects Releases Wiki Activity

fix #10

Browse Source
This commit is contained in:
Mrs4s 2020-08-03 13:27:18 +08:00
parent e754bd36ed
commit d5bff2ad8b
1 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
coolq/bot.go
View File

@ -136,16 +136,18 @@ func (bot *CQBot) InsertGroupMessage(m *message.GroupMessage) int32 {
"message": ToStringMessage(m.Elements, m.GroupCode, true), "message": ToStringMessage(m.Elements, m.GroupCode, true),
} }
id := ToGlobalId(m.GroupCode, m.Id) id := ToGlobalId(m.GroupCode, m.Id)
err := bot.db.Update(func(tx *nutsdb.Tx) error { if bot.db != nil {
buf := new(bytes.Buffer) err := bot.db.Update(func(tx *nutsdb.Tx) error {
if err := gob.NewEncoder(buf).Encode(val); err != nil { buf := new(bytes.Buffer)
return err if err := gob.NewEncoder(buf).Encode(val); err != nil {
return err
}
return tx.Put("group-messages", binary.ToBytes(id), binary.GZipCompress(buf.Bytes()), 0)
})
if err != nil {
log.Warnf("记录聊天数据时出现错误: %v", err)
return -1
} }
return tx.Put("group-messages", binary.ToBytes(id), binary.GZipCompress(buf.Bytes()), 0)
})
if err != nil {
log.Warnf("记录聊天数据时出现错误: %v", err)
return -1
} }
return id return id
} }