Compare commits

...

5 Commits

Author SHA1 Message Date
aozhiwei
97a27d2ef6 1 2024-11-01 15:51:55 +08:00
aozhiwei
49347f8203 1 2024-10-28 21:23:05 +08:00
aozhiwei
a4367ab4db 1 2024-10-28 17:22:44 +08:00
aozhiwei
3f8b508182 1 2024-10-28 17:17:38 +08:00
aozhiwei
ffe69ce97a 1 2024-09-27 14:42:03 +08:00
6 changed files with 106 additions and 32 deletions

View File

@ -5,6 +5,7 @@ import (
"fmt"
"main/constant"
"main/service"
"main/mt"
"q5"
"strings"
@ -38,7 +39,7 @@ func (cta *ContriApi) HistoryQuery(c *gin.Context) {
rspObj.CP = fmt.Sprintf("%.2f", mycp)
q5.NewSlice(&rspObj.Rows, 0, 10)
if mycp > 0.000001 {
if mycp > 0.000001 && !mt.Table.Config.HideContributionPoint() {
sql := `SELECT * FROM t_staking_daily_settlement WHERE idx > 0 and account_address = ?`
f5.GetGoStyleDb().RawQuery(
constant.BCNFT_DB,

View File

@ -67,15 +67,17 @@ token_type <> ? AND last_lock_address = ? AND last_lock_time <= ? AND owner_addr
return
}
nfts := []*jccommon.NftStacking{}
for ds.Next() {
p := new(jccommon.NftStacking)
p.NetId = q5.ToInt32(ds.GetByName("net_id"))
p.ContractAddress = ds.GetByName("contract_address")
p.TokenType = q5.ToInt32(ds.GetByName("token_type"))
p.TokenId = ds.GetByName("token_id")
p.ItemId = q5.ToInt32(ds.GetByName("item_id"))
p.Quality = q5.ToInt32(ds.GetByName("quality"))
q5.AppendSlice(&nfts, p)
if !mt.Table.Config.HideContributionPoint() {
for ds.Next() {
p := new(jccommon.NftStacking)
p.NetId = q5.ToInt32(ds.GetByName("net_id"))
p.ContractAddress = ds.GetByName("contract_address")
p.TokenType = q5.ToInt32(ds.GetByName("token_type"))
p.TokenId = ds.GetByName("token_id")
p.ItemId = q5.ToInt32(ds.GetByName("item_id"))
p.Quality = q5.ToInt32(ds.GetByName("quality"))
q5.AppendSlice(&nfts, p)
}
}
rspObj.ContributionPoint = fmt.Sprintf("%.2f", (jccommon.CalcContributionScore(nfts)))
c.JSON(200, rspObj)
@ -100,28 +102,30 @@ func (sa *StackingApi) ContributionQuery(c *gin.Context) {
accountAddress,
}
f5.GetGoStyleDb().RawQuery(
constant.BCNFT_DB,
sql,
params,
func(err error, ds *f5.DataSet) {
if err != nil {
c.JSON(200, rspObj)
return
}
obj := struct {
Date int32 `json:"date"`
ContributionPoint string `json:"contribution_point"`
}{}
for ds.Next() {
contributionPoint := q5.ToFloat64(ds.GetByName("contribution"))
if contributionPoint > 0.00001 {
obj.Date = q5.SafeToInt32(ds.GetByName("settle_date"))
obj.ContributionPoint = ds.GetByName("contribution")
rspObj.Rows = append(rspObj.Rows, obj)
if !mt.Table.Config.HideContributionPoint() {
f5.GetGoStyleDb().RawQuery(
constant.BCNFT_DB,
sql,
params,
func(err error, ds *f5.DataSet) {
if err != nil {
c.JSON(200, rspObj)
return
}
}
})
obj := struct {
Date int32 `json:"date"`
ContributionPoint string `json:"contribution_point"`
}{}
for ds.Next() {
contributionPoint := q5.ToFloat64(ds.GetByName("contribution"))
if contributionPoint > 0.00001 {
obj.Date = q5.SafeToInt32(ds.GetByName("settle_date"))
obj.ContributionPoint = ds.GetByName("contribution")
rspObj.Rows = append(rspObj.Rows, obj)
}
}
})
}
}
c.JSON(200, rspObj)
}

View File

@ -227,3 +227,59 @@ func (this *InGameApi) newHeroMint(c *gin.Context) {
}
})
}
func (this *InGameApi) GetCircuitRanking(c *gin.Context) {
accountAddress := c.DefaultQuery("address", "")
params := map[string]string{
"c": "OutAppCircuit",
"a": "getCircuitRanking",
"address": accountAddress,
}
rspObj := &struct {
ErrCode interface{} `json:"errcode"`
ErrMsg string `json:"errmsg"`
}{}
f5.GetHttpCliMgr().SendGoStyleRequest(
mt.Table.Config.GetGameApiUrl()+"/webapp/index.php",
params,
func(rsp f5.HttpCliResponse) {
if rsp.GetErr() != nil {
rspObj.ErrCode = 500
rspObj.ErrMsg = "server internal error1"
c.JSON(200, rspObj)
return
}
data := map[string]interface{}{}
f5.GetSysLog().Info(rsp.GetRawData())
q5.DecodeJson(rsp.GetRawData(), &data)
c.JSON(200, data)
})
}
func (this *InGameApi) GetCircuitPhaseRanking(c *gin.Context) {
accountAddress := c.DefaultQuery("address", "")
params := map[string]string{
"c": "OutAppCircuit",
"a": "getCircuitPhaseRanking",
"address": accountAddress,
}
rspObj := &struct {
ErrCode interface{} `json:"errcode"`
ErrMsg string `json:"errmsg"`
}{}
f5.GetHttpCliMgr().SendGoStyleRequest(
mt.Table.Config.GetGameApiUrl()+"/webapp/index.php",
params,
func(rsp f5.HttpCliResponse) {
if rsp.GetErr() != nil {
rspObj.ErrCode = 500
rspObj.ErrMsg = "server internal error1"
c.JSON(200, rspObj)
return
}
data := map[string]interface{}{}
f5.GetSysLog().Info(rsp.GetRawData())
q5.DecodeJson(rsp.GetRawData(), &data)
c.JSON(200, data)
})
}

View File

@ -5,6 +5,7 @@ import (
"fmt"
"main/constant"
"main/service"
"main/mt"
"q5"
"strings"
@ -127,7 +128,9 @@ func (this *UserApi) Info(c *gin.Context) {
return
}
}
rspObj.ContributionPoint = fmt.Sprintf("%.2f", contributionPoint)
if !mt.Table.Config.HideContributionPoint() {
rspObj.ContributionPoint = fmt.Sprintf("%.2f", contributionPoint)
}
rspObj.Gold = fmt.Sprintf("%.2f", gold)
rspObj.Diamond = fmt.Sprintf("%.2f", diamond)
c.JSON(200, rspObj)

View File

@ -22,6 +22,10 @@ func (this *ConfigTable) GetJwksUri() string {
return this.selfConf.GetJwksUri()
}
func (this *ConfigTable) HideContributionPoint() bool {
return true
}
/*
func (this *ConfigTable) GetEmailBuyerPassportAddress() string {
return this.selfConf.GetEmailBuyerPassportAddress()

View File

@ -16,4 +16,10 @@ func (this *IngameRouter) InitRouter() {
f5.GetApp().GetGinEngine().POST("/api/ingame/asset/hero/mint",
middleware.JwtAuth,
api.InGameApi.HeroMint)
f5.GetApp().GetGinEngine().GET("/api/circuit_ranking",
middleware.MaybeJwtAuth,
api.InGameApi.GetCircuitRanking)
f5.GetApp().GetGinEngine().GET("/api/circuit_phase_ranking",
middleware.MaybeJwtAuth,
api.InGameApi.GetCircuitPhaseRanking)
}