|
@@ -74,7 +74,6 @@ func (service *MessageService) CountUnread(userId string, appId string) (int64,
|
|
|
// 获取指定用户指定分类最新一条消息
|
|
|
func (service *MessageService) LastMessage(userId string, appId string, msgType int64, isRead int64) (*message.Messages, error) {
|
|
|
orm := entity.Engine.NewSession()
|
|
|
- log.Println("123")
|
|
|
defer orm.Close()
|
|
|
m1 := []*entity.Message{}
|
|
|
//m := []*message.Messages{}
|
|
@@ -132,7 +131,6 @@ func FindMessageDetail(id int64) (entity.Message, error) {
|
|
|
// 获取用户未读消息分类及数量 及分类下的最新一条消息
|
|
|
func (service *MessageService) ClassCountAndMessage(userId string, appId string) ([]*message.ResCount, error) {
|
|
|
orm := entity.Engine.NewSession()
|
|
|
- log.Println("123")
|
|
|
defer orm.Close()
|
|
|
//m := []*message.Messages{}
|
|
|
query, err := orm.QueryInterface("SELECT msg_type,COUNT(CASE WHEN isRead=0 THEN 1 END) as count FROM message where receive_userid=? and isdel=1 and appid=? GROUP BY msg_type ORDER BY FIELD(`msg_type`,\"1\",\"2\",\"3\",\"4\",\"5\",\"6\",\"7\")", userId, appId)
|
|
@@ -142,7 +140,6 @@ func (service *MessageService) ClassCountAndMessage(userId string, appId string)
|
|
|
}
|
|
|
if err != nil {
|
|
|
log.Println(err)
|
|
|
- log.Println("咋回事")
|
|
|
return nil, errors.New("查询未读消息失败")
|
|
|
}
|
|
|
typeCount := []*message.ResCount{}
|
|
@@ -161,7 +158,6 @@ func (service *MessageService) ClassCountAndMessage(userId string, appId string)
|
|
|
// 已接收到消息的分类
|
|
|
func (service *MessageService) ReceiveMsgType(userId string, appId string) ([]int64, error) {
|
|
|
orm := entity.Engine.NewSession()
|
|
|
- log.Println("123")
|
|
|
defer orm.Close()
|
|
|
m := []entity.Message{}
|
|
|
err := orm.Distinct("msg_type").Where("receive_userid=? and isdel=1 and appid=?", userId, appId).Find(&m)
|