From 9a2fbeacb896ca22e30f4885e337fa120a57e103 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com> Date: Wed, 30 Dec 2020 15:26:14 +0800 Subject: [PATCH] a --- business/jxstore/event/event.go | 24 ++++++++++++++++++------ 1 file changed, 18 insertions(+), 6 deletions(-) diff --git a/business/jxstore/event/event.go b/business/jxstore/event/event.go index f9923aa6c..017b1b024 100644 --- a/business/jxstore/event/event.go +++ b/business/jxstore/event/event.go @@ -426,12 +426,24 @@ func GetMessageGroupByUser(ctx *jxcontext.Context, userID string) (messageGroupR v.Name = user.Name } } - //最后一条记录和时间和人 - var imMessageRecord *model.ImMessageRecord - sql := ` - SELECT * FROM im_message_record WHERE group_id = ? ORDER BY created_at DESC LIMIT 1 - ` - sqlParams := []interface{}{v.GroupID} + var ( + imMessageRecord *model.ImMessageRecord + sql string + sqlParams = []interface{}{} + ) + if v.GroupID != model.SysGroupID { + //最后一条记录和时间和人 + sql = ` + SELECT * FROM im_message_record WHERE group_id = ? ORDER BY created_at DESC LIMIT 1 + ` + sqlParams = append(sqlParams, v.GroupID) + } else { + //最后一条记录和时间和人 + sql = ` + SELECT * FROM im_message_record WHERE group_id = ? AND to_user_id = ? ORDER BY created_at DESC LIMIT 1 + ` + sqlParams = append(sqlParams, v.GroupID, v.UserID) + } if err = dao.GetRow(db, &imMessageRecord, sql, sqlParams); err == nil { v.LastTime = imMessageRecord.CreatedAt v.LastContent = imMessageRecord.Content