From b0b25cf651df72cdc4bab95afc3919a6fb99a333 Mon Sep 17 00:00:00 2001
From: meixiongfeng <766881921@qq.com>
Date: Wed, 8 Jun 2022 14:09:50 +0800
Subject: [PATCH] =?UTF-8?q?=E8=8E=B7=E5=8F=96=E9=99=84=E4=BB=B6=E7=9A=84?=
 =?UTF-8?q?=E7=8A=B6=E6=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 sys/cache/mail.go | 23 +----------------------
 sys/db/mail.go    |  5 +++++
 2 files changed, 6 insertions(+), 22 deletions(-)

diff --git a/sys/cache/mail.go b/sys/cache/mail.go
index 1dfb8c1b8..efbdd707d 100644
--- a/sys/cache/mail.go
+++ b/sys/cache/mail.go
@@ -5,14 +5,13 @@ import (
 	"go_dreamfactory/sys/db"
 )
 
+// 邮件暂时不写redis
 const ( //Redis
 	Redis_MailCache string = "mail:%s"
 )
 
 type IMail interface {
 	QueryUserMail(uId string) (mail []*pb.DB_MailData, err error)
-	InsertUserMail(uId string) (mail []*pb.DB_MailData, err error)
-	ReadOneMail(uId string, ObjId string) (mail *pb.DB_MailData, err error)
 }
 
 // 查询玩家邮件数据
@@ -26,26 +25,6 @@ func (this *Cache) QueryUserMail(uId string) (mail []*pb.DB_MailData, err error)
 	// 		mail[i] = v.(*pb.DB_MailData)
 	// 	}
 	// }
-	// 邮件暂时不写redis
 	mail, _ = db.Defsys.QueryUserMail(uId)
-
-	// } else if err == redis.RedisNil {
-	// 	if mail, err = db.Defsys.QueryUserMail(uId); err == nil {
-	// 		this.redis.Set(fmt.Sprintf(Redis_MailCache, uId), mail, -1)
-	// 	} else if err == mgo.MongodbNil {
-	// 		err = nil
-	// 	}
-	// }
-	return
-}
-
-// 创建新的邮件
-func (this *Cache) ReadOneMail(uId string, ObjId string) (mail *pb.DB_MailData, err error) {
-
-	return
-}
-
-func (this *Cache) InsertUserMail(uId string) (mail []*pb.DB_MailData, err error) {
-
 	return
 }
diff --git a/sys/db/mail.go b/sys/db/mail.go
index 84ba6ba0f..562d93206 100644
--- a/sys/db/mail.go
+++ b/sys/db/mail.go
@@ -42,6 +42,11 @@ func (this *DB) InsertUserMail(mail *pb.DB_MailData) (err error) {
 
 	mail.ObjId = primitive.NewObjectID().Hex()
 	mail.Check = false
+	mail.Reward = false
+
+	if len(mail.GetItems()) > 0 {
+		mail.Reward = true
+	}
 	_, err = this.mgo.InsertOne(DB_MailTable, mail)
 
 	return err