liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

获取附件的状态

Browse Source
This commit is contained in:
meixiongfeng 2022-06-08 14:09:50 +08:00
parent e4bf884450
commit b0b25cf651
2 changed files with 6 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
sys/cache/mail.go vendored
View File

@ -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
}

5
sys/db/mail.go
View File

@ -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