server/game2006go
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

diamond info

Browse Source
This commit is contained in:
yangduo 2024-08-02 17:43:57 +08:00
parent 7db2da0f85
commit c160b213ce
2 changed files with 46 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/marketserver/api/v1/activity/stacking.go
View File

@ -135,13 +135,14 @@ func (sa *StackingApi) DiamondRecordQuery(c *gin.Context) {
}{} }{}
{ {
sql := `SELECT * FROM t_diamond WHERE account_address = ? ORDER BY createtime DESC` sql := `SELECT * FROM t_diamond_consume_product WHERE account_id = ? OR passport_address = ? ORDER BY createtime DESC`
params := []string{ params := []string{
accountAddress, accountAddress,
accountAddress,
} }
f5.GetGoStyleDb().RawQuery( f5.GetGoStyleDb().RawQuery(
constant.BCNFT_DB, constant.GAME_DB,
sql, sql,
params, params,
func(err error, ds *f5.DataSet) { func(err error, ds *f5.DataSet) {

60
server/marketserver/api/v1/user/user.go
View File

@ -1,47 +1,48 @@
package user package user
import ( import (
"q5"
"f5" "f5"
"main/constant"
"strings"
"github.com/gin-gonic/gin"
"fmt" "fmt"
"main/constant"
"q5"
"strings"
"github.com/gin-gonic/gin"
) )
type UserApi struct { type UserApi struct {
} }
func (this *UserApi) Info(c *gin.Context) { func (this *UserApi) Info(c *gin.Context) {
accountAddress := strings.ToLower(c.Param("account_address")) accountAddress := strings.ToLower(c.Param("account_address"))
rspObj := struct { rspObj := struct {
ErrCode int32 `json:"errcode"` ErrCode int32 `json:"errcode"`
ErrMsg string `json:"errmsg"` ErrMsg string `json:"errmsg"`
NickName string `json:"nickname"` NickName string `json:"nickname"`
Email string `json:"email"` Email string `json:"email"`
ContributionPoint string `json:"contribution_point"` ContributionPoint string `json:"contribution_point"`
Gold string `json:"gold"` Gold string `json:"gold"`
Diamond string `json:"diamond"` Diamond string `json:"diamond"`
}{ }{}
}
var contributionPoint float64 var contributionPoint float64
var gold float64 var gold float64
var diamond float64
{ {
var dbErr error var dbErr error
f5.GetGoStyleDb().OrmSelectOne( f5.GetGoStyleDb().OrmSelectOne(
constant.GAME_DB, constant.GAME_DB,
"t_user", "t_user",
[][]string{ [][]string{
{"address", accountAddress}, {"account_id", accountAddress},
}, },
func (err error, ds *f5.DataSet) { func(err error, ds *f5.DataSet) {
dbErr = err dbErr = err
if err != nil { if err != nil {
return return
} }
if ds.Next() { if ds.Next() {
gold = q5.ToFloat64(ds.GetByName("gold")) gold = q5.ToFloat64(ds.GetByName("gold"))
diamond = q5.ToFloat64(ds.GetByName("diamond"))
} }
}) })
if dbErr != nil { if dbErr != nil {
@ -57,7 +58,7 @@ func (this *UserApi) Info(c *gin.Context) {
[][]string{ [][]string{
{"account_address", accountAddress}, {"account_address", accountAddress},
}, },
func (err error, ds *f5.DataSet) { func(err error, ds *f5.DataSet) {
dbErr = err dbErr = err
if err != nil { if err != nil {
return return
@ -81,7 +82,7 @@ func (this *UserApi) Info(c *gin.Context) {
constant.BCNFT_DB, constant.BCNFT_DB,
sql, sql,
params, params,
func (err error, ds *f5.DataSet) { func(err error, ds *f5.DataSet) {
dbErr = err dbErr = err
if err != nil { if err != nil {
return return
@ -95,7 +96,32 @@ func (this *UserApi) Info(c *gin.Context) {
return return
} }
} }
{
var dbErr error
sql := "SELECT SUM(diamond) FROM t_recharge WHERE passport = ?"
params := []string{
accountAddress,
}
f5.GetGoStyleDb().RawQuery(
constant.BCEVENT_DB,
sql,
params,
func(err error, ds *f5.DataSet) {
dbErr = err
if err != nil {
return
}
for ds.Next() {
diamond += q5.ToFloat64(ds.GetByIndex(0))
}
})
if dbErr != nil {
f5.RspErr(c, 500, "server internal error")
return
}
}
rspObj.ContributionPoint = fmt.Sprintf("%.2f", contributionPoint) rspObj.ContributionPoint = fmt.Sprintf("%.2f", contributionPoint)
rspObj.Gold = fmt.Sprintf("%.2f", gold) rspObj.Gold = fmt.Sprintf("%.2f", gold)
rspObj.Diamond = fmt.Sprintf("%.2f", diamond)
c.JSON(200, rspObj) c.JSON(200, rspObj)
} }