From 725380535bb4f0f864319b82c87dcbda7e5a0a14 Mon Sep 17 00:00:00 2001
From: "teamgram.io" <74940245+teamgramio@users.noreply.github.com>
Date: Tue, 14 Mar 2023 13:15:22 +0800
Subject: [PATCH] feat: format messages_dao.go
---
.../dal/dao/mysql_dao/messages_dao.go | 46 -------------------
.../message/internal/dal/tables/messages.xml | 42 -----------------
2 files changed, 88 deletions(-)
diff --git a/app/service/biz/message/internal/dal/dao/mysql_dao/messages_dao.go b/app/service/biz/message/internal/dal/dao/mysql_dao/messages_dao.go
index c9f9623ce..b1ee1a142 100644
--- a/app/service/biz/message/internal/dal/dao/mysql_dao/messages_dao.go
+++ b/app/service/biz/message/internal/dal/dao/mysql_dao/messages_dao.go
@@ -909,52 +909,6 @@ func (dao *MessagesDAO) SelectDialogMessageIdListWithCB(ctx context.Context, use
return
}
-// SelectPeerMessageList
-// select user_id, user_message_box_id, dialog_id1, dialog_id2, dialog_message_id, sender_user_id, peer_type, peer_id, random_id, message_filter_type, message_data, message, mentioned, media_unread, pinned, has_reaction, reaction, reaction_date, reaction_unread, date2 from messages where user_id != :user_id and dialog_message_id = :dialog_message_id and deleted = 0
-// TODO(@benqi): sqlmap
-func (dao *MessagesDAO) SelectPeerMessageList(ctx context.Context, user_id int64, dialog_message_id int64) (rList []dataobject.MessagesDO, err error) {
- var (
- query = "select user_id, user_message_box_id, dialog_id1, dialog_id2, dialog_message_id, sender_user_id, peer_type, peer_id, random_id, message_filter_type, message_data, message, mentioned, media_unread, pinned, has_reaction, reaction, reaction_date, reaction_unread, date2, ttl_period from " + dao.CalcTableName(user_id) + " where user_id != ? and dialog_message_id = ? and deleted = 0"
- values []dataobject.MessagesDO
- )
- err = dao.db.QueryRowsPartial(ctx, &values, query, user_id, dialog_message_id)
-
- if err != nil {
- logx.WithContext(ctx).Errorf("queryx in SelectPeerMessageList(_), error: %v", err)
- return
- }
-
- rList = values
-
- return
-}
-
-// SelectPeerMessageListWithCB
-// select user_id, user_message_box_id, dialog_id1, dialog_id2, dialog_message_id, sender_user_id, peer_type, peer_id, random_id, message_filter_type, message_data, message, mentioned, media_unread, pinned, has_reaction, reaction, reaction_date, reaction_unread, date2 from messages where user_id != :user_id and dialog_message_id = :dialog_message_id and deleted = 0
-// TODO(@benqi): sqlmap
-func (dao *MessagesDAO) SelectPeerMessageListWithCB(ctx context.Context, user_id int64, dialog_message_id int64, cb func(i int, v *dataobject.MessagesDO)) (rList []dataobject.MessagesDO, err error) {
- var (
- query = "select user_id, user_message_box_id, dialog_id1, dialog_id2, dialog_message_id, sender_user_id, peer_type, peer_id, random_id, message_filter_type, message_data, message, mentioned, media_unread, pinned, has_reaction, reaction, reaction_date, reaction_unread, date2, ttl_period from " + dao.CalcTableName(user_id) + " where user_id != ? and dialog_message_id = ? and deleted = 0"
- values []dataobject.MessagesDO
- )
- err = dao.db.QueryRowsPartial(ctx, &values, query, user_id, dialog_message_id)
-
- if err != nil {
- logx.WithContext(ctx).Errorf("queryx in SelectPeerMessageList(_), error: %v", err)
- return
- }
-
- rList = values
-
- if cb != nil {
- for i := 0; i < len(rList); i++ {
- cb(i, &rList[i])
- }
- }
-
- return
-}
-
// UpdateMediaUnread
// update messages set media_unread = 0 where user_id = :user_id and user_message_box_id = :user_message_box_id
// TODO(@benqi): sqlmap
diff --git a/app/service/biz/message/internal/dal/tables/messages.xml b/app/service/biz/message/internal/dal/tables/messages.xml
index 8454862e7..2a8bae84e 100644
--- a/app/service/biz/message/internal/dal/tables/messages.xml
+++ b/app/service/biz/message/internal/dal/tables/messages.xml
@@ -188,35 +188,6 @@
-
-
SELECT
@@ -295,19 +266,6 @@
-
-
-
-
-
-
UPDATE