From e09b1f18f6e93e25e127374fa055659a653df7aa Mon Sep 17 00:00:00 2001
From: yangduo <yangduo@kingsome.cn>
Date: Thu, 19 Sep 2024 16:36:36 +0800
Subject: [PATCH] vip bind & vipuser

---
 server/adminserver/api/v1/system/player.go    | 110 +++++++++++++++++-
 .../adminserver/router/system/sys_player.go   |   2 +
 2 files changed, 107 insertions(+), 5 deletions(-)

diff --git a/server/adminserver/api/v1/system/player.go b/server/adminserver/api/v1/system/player.go
index 12e1c711..6267c8e1 100644
--- a/server/adminserver/api/v1/system/player.go
+++ b/server/adminserver/api/v1/system/player.go
@@ -210,7 +210,7 @@ func (pai *PlayerApi) HeroesQuery(c *gin.Context) {
 					sql += "'" + addr + "',"
 				}
 				sql = sql[:len(sql)-1]
-				sql+="))"
+				sql += "))"
 			}
 			sql += ")"
 			f5.GetSysLog().Debug("tokenid sql:%s", sql)
@@ -358,10 +358,7 @@ func (pai *PlayerApi) RechargeQuery(c *gin.Context) {
 	}
 
 	if len(reqJson.Identity) > 0xFF {
-		c.JSON(http.StatusOK, gin.H{
-			"code":    1,
-			"message": "输入过长",
-		})
+		f5.RspErr2(c, 1, "输入过长")
 		return
 	}
 
@@ -379,3 +376,106 @@ func (pai *PlayerApi) RechargeQuery(c *gin.Context) {
 		return p
 	})
 }
+
+func (pai *PlayerApi) VipBindQuery(c *gin.Context) {
+	type VipBindQueryForm struct {
+		Identity string `binding:"required" json:"identity"`
+	}
+
+	reqJson := VipBindQueryForm{}
+	if !checkparam(&reqJson, c) {
+		return
+	}
+
+	if len(reqJson.Identity) > 0xFF {
+		f5.RspErr2(c, 1, "输入过长")
+		return
+	}
+
+	rsp := []struct {
+		Account  string `gorm:"column:account_address" json:"account_address"`
+		Passport string `gorm:"column:passport_address" json:"passport_address"`
+		Email    string `gorm:"column:lower_case_email" json:"lower_case_email"`
+	}{}
+
+	sql := `SELECT * FROM t_vip_bind WHERE idx > 0 AND (account_address = ? OR passport_address = ?)`
+	f5.GetGoStyleDb().RawQuery(
+		constant.BCNFT_DB,
+		sql,
+		[]string{
+			reqJson.Identity,
+			reqJson.Identity,
+		},
+		func(err error, ds *f5.DataSet) {
+			if err != nil {
+				f5.RspErr2(c, 500, "server internal error")
+				return
+			}
+
+			for ds.Next() {
+				p := q5.NewSliceElement(&rsp)
+				f5.UnmarshalModel(ds, p)
+			}
+
+			c.JSON(http.StatusOK, gin.H{
+				"code":    0,
+				"message": "",
+				"data":    rsp,
+			})
+		})
+
+}
+
+func (pai *PlayerApi) VipUserQuery(c *gin.Context) {
+	type VipUserQueryForm struct {
+		Account string `binding:"required" json:"account_address"`
+	}
+
+	reqJson := VipUserQueryForm{}
+	if !checkparam(&reqJson, c) {
+		return
+	}
+
+	if len(reqJson.Account) > 0xFF {
+		f5.RspErr2(c, 1, "输入过长")
+		return
+	}
+
+	rsp := []struct {
+		Account      string `gorm:"column:account_address" json:"account_address"`
+		Level        int64  `gorm:"column:vip_lv" json:"vip_lv"`
+		Balance      string `gorm:"column:escec_balance" json:"escec_balance"`
+		Stacking     string `gorm:"column:escec_stacking" json:"escec_stacking"`
+		Convert      string `gorm:"column:escec_convert" json:"escec_convert"`
+		Total        string `gorm:"column:escec_total" json:"escec_total"`
+		StackingLast int64  `gorm:"column:stacking_last_src_idx" json:"stacking_last_src_idx"`
+		TransferLast int64  `gorm:"column:escec_transfer_last_src_idx" json:"escec_transfer_last_src_idx"`
+		DepositLast  int64  `gorm:"column:vester_deposit_last_src_idx" json:"vester_deposit_last_src_idx"`
+		WithdrawLast int64  `gorm:"column:vester_withdraw_last_src_idx" json:"vester_withdraw_last_src_idx"`
+	}{}
+
+	sql := `SELECT * FROM t_vip_user WHERE idx > 0 AND account_address = ?`
+	f5.GetGoStyleDb().RawQuery(
+		constant.BCNFT_DB,
+		sql,
+		[]string{
+			reqJson.Account,
+		},
+		func(err error, ds *f5.DataSet) {
+			if err != nil {
+				f5.RspErr2(c, 500, "server internal error")
+				return
+			}
+
+			for ds.Next() {
+				p := q5.NewSliceElement(&rsp)
+				f5.UnmarshalModel(ds, p)
+			}
+
+			c.JSON(http.StatusOK, gin.H{
+				"code":    0,
+				"message": "",
+				"data":    rsp,
+			})
+		})
+}
diff --git a/server/adminserver/router/system/sys_player.go b/server/adminserver/router/system/sys_player.go
index 8ec419ef..443fd875 100644
--- a/server/adminserver/router/system/sys_player.go
+++ b/server/adminserver/router/system/sys_player.go
@@ -20,5 +20,7 @@ func (pr *PlayerRouter) InitPlayerRouter(priRouter *gin.RouterGroup) {
 		group.POST("ticketconsumequery", middleware.Permission("api/v1/player/ticketconsumequery", api.TicketConsumeQuery))
 		group.POST("gamemallquery", middleware.Permission("api/v1/player/gamemallquery", api.GameMallQuery))
 		group.POST("rechargequery", middleware.Permission("api/v1/player/rechargequery", api.RechargeQuery))
+		group.POST("vipbindquery", middleware.Permission("api/v1/player/vipbindquery", api.VipBindQuery))
+		group.POST("vipuserquery", middleware.Permission("api/v1/player/vipuserquery", api.VipUserQuery))
 	}
 }