From a65d59149c91224434f1f1cca609b19394b3abb8 Mon Sep 17 00:00:00 2001 From: "DESKTOP-L8OUL9F\\gfl0034" <1003614916@qq.com> Date: Sun, 18 Oct 2026 19:26:29 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E5=8E=86=E5=8F=B2=E5=90=8C=E6=AD=A5?= =?UTF-8?q?=E6=94=B9=E6=9F=A5=20t=5Fmessage=5Fdeletes?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 命令 12 的会话历史仍 JOIN 已改名的 message_deletes，数据库失败会被收成 50001。 Co-authored-by: Cursor --- internal/module/message/model/query.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/module/message/model/query.go b/internal/module/message/model/query.go index f57e409..528cd84 100644 --- a/internal/module/message/model/query.go +++ b/internal/module/message/model/query.go @@ -29,7 +29,7 @@ func (m *Repo) ListByConversation(ctx context.Context, conversationID, viewerID, if kind == entity.KindGroup { var rows []GroupMessage err = db.Table(table).Select(table+".*"). - Joins("LEFT JOIN message_deletes AS d ON d.msg_id = "+table+".id AND d.user_id = ?", viewerID). + Joins("LEFT JOIN t_message_deletes AS d ON d.msg_id = "+table+".id AND d.user_id = ?", viewerID). Where(table+".conversation_id = ? AND "+table+".id > ? AND "+table+".status <> ? AND d.msg_id IS NULL", conversationID, lastMsgID, entity.StatusHidden). Order(table + ".id ASC"). Limit(limit). @@ -45,7 +45,7 @@ func (m *Repo) ListByConversation(ctx context.Context, conversationID, viewerID, } var rows []PrivateMessage err = db.Table(table).Select(table+".*"). - Joins("LEFT JOIN message_deletes AS d ON d.msg_id = "+table+".id AND d.user_id = ?", viewerID). + Joins("LEFT JOIN t_message_deletes AS d ON d.msg_id = "+table+".id AND d.user_id = ?", viewerID). Where(table+".conversation_id = ? AND "+table+".id > ? AND "+table+".status <> ? AND d.msg_id IS NULL", conversationID, lastMsgID, entity.StatusHidden). Order(table + ".id ASC"). Limit(limit).