|
|
@@ -24,13 +24,14 @@ func (service *MessageService) ChangeReadStatus(data *message.ChangeReadStatusRe
|
|
|
if count > 0 {
|
|
|
return nil
|
|
|
}
|
|
|
- msg := entity.Mysql.FindOne("message_send_log", map[string]interface{}{"id": data.Id}, "group_id", "")
|
|
|
+ msg := entity.Mysql.FindOne("message_send_log", map[string]interface{}{"id": data.Id}, "group_id,msg_type", "")
|
|
|
if msg != nil && len(*msg) > 0 {
|
|
|
err := PutRedisRead(data.UserId, int(data.Id))
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
|
groupId := qutil.IntAll((*msg)["group_id"])
|
|
|
+ msgType := qutil.IntAll((*msg)["msg_type"])
|
|
|
//更新用户未读消息bitmap
|
|
|
sql := fmt.Sprintf(`alter table message_user_summary UPDATE readMsg = bitmapOr(readMsg,bitmapBuild([toUInt64(%d)])) where userId = '%s'`, data.Id, data.UserId)
|
|
|
fmt.Println(sql)
|
|
|
@@ -46,6 +47,7 @@ func (service *MessageService) ChangeReadStatus(data *message.ChangeReadStatusRe
|
|
|
if groupId == 5 || groupId == 11 {
|
|
|
redis.Del(redisModule, fmt.Sprintf(UserWorkDeskKey, data.UserId))
|
|
|
}
|
|
|
+ redis.Del(redisModule, fmt.Sprintf(MsgClassCountKey, data.UserId, msgType))
|
|
|
redis.Del(redisModule, fmt.Sprintf(UserMsgSummery, data.UserId))
|
|
|
redis.Del(redisModule, fmt.Sprintf(UserClassMapKey, data.UserId))
|
|
|
} else {
|
