package models type Message struct { Model KefuId string `json:"kefu_id"` VisitorId string `json:"visitor_id"` Content string `json:"content"` MesType string `json:"mes_type"` Status string `json:"status"` } func CreateMessage(kefu_id string, visitor_id string, content string, mes_type string) { v := &Message{ KefuId: kefu_id, VisitorId: visitor_id, Content: content, MesType: mes_type, Status: "unread", } DB.Create(v) } func FindMessageByVisitorId(visitor_id string) []Message { var messages []Message DB.Where("visitor_id=?", visitor_id).Order("id asc").Find(&messages) return messages } //修改消息状态 func ReadMessageByVisitorId(visitor_id string) { message := &Message{ Status: "read", } DB.Model(&message).Where("visitor_id=?", visitor_id).Update(message) } //获取未读数 func FindUnreadMessageNumByVisitorId(visitor_id string) uint { var count uint DB.Where("visitor_id=? and status=?", visitor_id, "unread").Count(&count) return count } //查询条数 func CountMessage() uint { var count uint DB.Model(&Message{}).Count(&count) return count }