diff --git a/internal/logic/domain/message/repo/message_repo.go b/internal/logic/domain/message/repo/message_repo.go index 47a3a4f..fc7730b 100644 --- a/internal/logic/domain/message/repo/message_repo.go +++ b/internal/logic/domain/message/repo/message_repo.go @@ -1,7 +1,6 @@ package repo import ( - "fmt" "gim/internal/business/comm/utils" "gim/internal/logic/domain/message/model" "gim/pkg/db" @@ -16,7 +15,8 @@ type messageRepo struct{} var MessageRepo = new(messageRepo) func (*messageRepo) tableName(userId int64) string { - return fmt.Sprintf("message_%03d", userId%messageTableNum) + //return fmt.Sprintf("message_%03d", userId%messageTableNum) + return "message" } // Save 插入一条消息