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).