From 0319de74be0924065e6215a998d8daac6b8e30f7 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=AE=B7=E5=8B=87?= <shyinyong@outlook.com>
Date: Wed, 25 Oct 2023 16:04:02 +0800
Subject: [PATCH] save

---
 server/mailserver/api/mail.go           |  8 ++---
 server/mailserver/player/player.go      | 40 ++++++++++++-------------
 server/mailserver/player/playerdbmgr.go | 29 ++++++++++++++++++
 server/mailserver/player/playermgr.go   | 10 +++++--
 4 files changed, 60 insertions(+), 27 deletions(-)
 create mode 100644 server/mailserver/player/playerdbmgr.go

diff --git a/server/mailserver/api/mail.go b/server/mailserver/api/mail.go
index af13e2ce..f1fa524c 100644
--- a/server/mailserver/api/mail.go
+++ b/server/mailserver/api/mail.go
@@ -84,13 +84,13 @@ func (api *MailApi) GetUnreadMailCount(c *gin.Context) {
 }
 
 // 领取邮件附件
-type GetMailAttachmentReq struct {
+type getMailAttachmentReq struct {
 	SessionId string `form:"session_id" binding:"required"`
 	AccountId string `form:"account_id" binding:"required"`
 }
 
 func (api *MailApi) GetMailAttachment(c *gin.Context) {
-	var req GetMailAttachmentReq
+	var req getMailAttachmentReq
 	if err := c.ShouldBindQuery(&req); err != nil {
 		c.JSON(http.StatusBadRequest, errorResponse(400, err))
 		return
@@ -103,14 +103,14 @@ func (api *MailApi) GetMailAttachment(c *gin.Context) {
 }
 
 // 删除邮件
-type DeleteMailsReq struct {
+type deleteMailsReq struct {
 	SessionId string `form:"session_id" binding:"required"`
 	AccountId string `form:"account_id" binding:"required"`
 	MailIds   string `form:"mail_ids" binding:"required"`
 }
 
 func (api *MailApi) DeleteMails(c *gin.Context) {
-	var req DeleteMailsReq
+	var req deleteMailsReq
 	if err := c.ShouldBindQuery(&req); err != nil {
 		c.JSON(http.StatusBadRequest, errorResponse(400, err))
 		return
diff --git a/server/mailserver/player/player.go b/server/mailserver/player/player.go
index 05acce7e..6be14d2b 100644
--- a/server/mailserver/player/player.go
+++ b/server/mailserver/player/player.go
@@ -3,38 +3,38 @@ package player
 import "main/mail"
 import "main/ss"
 
-type player struct {
-	accountId       string
-	sessionId       string
-	registerTime    int
-	readMailHash    map[int64]*mail.Mail
-	deletedMailHash map[int64]*mail.Mail
+type Player struct {
+	AccountId       string
+	SessionId       string
+	RegisterTime    int
+	ReadMailHash    map[int64]*mail.Mail
+	DeletedMailHash map[int64]*mail.Mail
 }
 
-func (p *player) init() {
-	p.readMailHash = make(map[int64]*mail.Mail)
-	p.deletedMailHash = make(map[int64]*mail.Mail)
+func (p *Player) init() {
+	p.ReadMailHash = make(map[int64]*mail.Mail)
+	p.DeletedMailHash = make(map[int64]*mail.Mail)
 }
 
-func (p *player) IsUnreadMail(mailId int64) bool {
-	m := p.readMailHash[mailId]
+func (p *Player) IsUnreadMail(mailId int64) bool {
+	m := p.ReadMailHash[mailId]
 	return m == nil
 }
 
-func (p *player) IsDeletedMail(mailId int64) bool {
-	m := p.deletedMailHash[mailId]
+func (p *Player) IsDeletedMail(mailId int64) bool {
+	m := p.DeletedMailHash[mailId]
 	return m != nil
 }
 
-func (p *player) MarkMail(mailIds string)      {}
-func (p *player) DeleteMails(mailIds string)   {}
-func (p *player) AddToReadList(mailIds string) {}
-func (p *player) GetAttachment(mailIds string) {}
+func (p *Player) MarkMail(mailIds string)      {}
+func (p *Player) DeleteMails(mailIds string)   {}
+func (p *Player) AddToReadList(mailIds string) {}
+func (p *Player) GetAttachment(mailIds string) {}
 
-func (p *player) Deserialize(accountPB ss.MFAccountData) {}
+func (p *Player) Deserialize(accountPB ss.MFAccountData) {}
 
-func (p *player) Serialize(accountPB ss.MFAccountData) {
+func (p *Player) Serialize(accountPB ss.MFAccountData) {
 
 }
 
-func (p *player) SaveToDB() {}
+func (p *Player) SaveToDB() {}
diff --git a/server/mailserver/player/playerdbmgr.go b/server/mailserver/player/playerdbmgr.go
new file mode 100644
index 00000000..16c6f7ca
--- /dev/null
+++ b/server/mailserver/player/playerdbmgr.go
@@ -0,0 +1,29 @@
+package player
+
+import (
+	"f5"
+	"fmt"
+	"mailsever/constant"
+	"q5"
+)
+
+func (pm *playerMgr) LoadPlayer(accountId string) {
+	sql := fmt.Sprintf("SELECT accountid, blobdata FROM account_data WHERE accountid='%s'", accountId)
+	f5.GetGoStyleDb().SyncSelectCustomQuery(
+		constant.MAIL_DB,
+		sql,
+		func(err error, rows *f5.DataSet) {
+			if err != nil {
+				f5.GetSysLog().Info("loadPlayer err:%v \n", err)
+				panic(err)
+			}
+			if rows.Next() {
+				aId := q5.ToString(*rows.GetByName("account_id"))
+				profile := &Player{
+					AccountId: aId,
+				}
+				pm.AddPlayer(profile)
+			}
+		},
+	)
+}
diff --git a/server/mailserver/player/playermgr.go b/server/mailserver/player/playermgr.go
index a08f34bf..925c200d 100644
--- a/server/mailserver/player/playermgr.go
+++ b/server/mailserver/player/playermgr.go
@@ -1,17 +1,21 @@
 package player
 
 type playerMgr struct {
-	accountIdHash map[string]*player
+	accountIdHash map[string]*Player
 }
 
 func (pm *playerMgr) Init() {
-	pm.accountIdHash = make(map[string]*player)
+	pm.accountIdHash = make(map[string]*Player)
 }
 
 func (pm *playerMgr) UnInit() {
 }
 
-func (pm *playerMgr) GetPlayer(accountId string) *player {
+func (pm *playerMgr) AddPlayer(p *Player) {
+	pm.accountIdHash[p.AccountId] = p
+}
+
+func (pm *playerMgr) GetPlayer(accountId string) *Player {
 	if p, exists := pm.accountIdHash[accountId]; exists {
 		return p
 	}