From 0936223d7f67aab9ae98e37744b93e369451c506 Mon Sep 17 00:00:00 2001
From: meixiongfeng <766881921@qq.com>
Date: Mon, 9 Oct 2023 17:38:09 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B7=A8=E6=9C=8D=E5=A4=84=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 modules/mail/module.go | 16 +++++-----------
 1 file changed, 5 insertions(+), 11 deletions(-)

diff --git a/modules/mail/module.go b/modules/mail/module.go
index c3cc45c59..91b36d8d8 100644
--- a/modules/mail/module.go
+++ b/modules/mail/module.go
@@ -143,20 +143,14 @@ func (this *Mail) Reddot(session comm.IUserSession, rid ...comm.ReddotType) (red
 func (this *Mail) Rpc_Mail(ctx context.Context, args *pb.DBMailData, reply *pb.EmptyResp) (err error) {
 	this.Debug("Rpc_Mail", log.Field{Key: "args", Value: args.String()})
 	var (
-		conn    *db.DBConn
 		session comm.IUserSession
 		online  bool
 	)
-	tag, _, b := utils.UIdSplit(args.Uid)
-	if b {
-		if conn, err = db.ServerDBConn(tag); err == nil {
-			dbModel := db.NewDBModel(comm.TableMail, conn)
-			_, err = dbModel.DB.InsertOne(comm.TableMail, args)
-			if err != nil {
-				this.Error("Create Rpc_Mail failed", log.Field{Key: "uid", Value: args.Uid}, log.Field{Key: "err", Value: err.Error()})
-				return
-			}
-		}
+
+	_, err = this.modelMail.DB.InsertOne(comm.TableMail, args)
+	if err != nil {
+		this.Error("Create Rpc_Mail failed", log.Field{Key: "uid", Value: args.Uid}, log.Field{Key: "err", Value: err.Error()})
+		return
 	}
 	defer func() {
 		this.PutUserSession(session)