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

调整

Browse Source
This commit is contained in:
yangduo 2024-08-02 16:04:36 +08:00
parent 32a0445b1f
commit 9b7c89307e
1 changed files with 23 additions and 50 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
server/marketserver/api/v1/recharge/recharge.go
View File

@ -145,17 +145,10 @@ func (ea *RechargeApi) RechargeQuery(c *gin.Context) {
reqJson := struct { reqJson := struct {
PageSize interface{} `json:"page_size"` PageSize interface{} `json:"page_size"`
Cursor interface{} `json:"cursor"` Cursor interface{} `json:"cursor"`
Search struct { Search struct{} `json:"search"`
Name string `json:"name"` Filter struct{} `json:"filter"`
} `json:"search"`
Filter struct {
ItemIds []interface{} `json:"item_ids"`
} `json:"filter"`
Sort struct { Sort struct {
Fields []struct { Fields []struct{} `json:"fields"`
Name string `json:"name"`
Type interface{} `json:"type"`
} `json:"fields"`
} `json:"sort"` } `json:"sort"`
}{} }{}
if err := c.ShouldBindJSON(&reqJson); err != nil { if err := c.ShouldBindJSON(&reqJson); err != nil {
@ -169,38 +162,18 @@ func (ea *RechargeApi) RechargeQuery(c *gin.Context) {
pageSize := q5.AdjustRangeValue(q5.SafeToInt32(reqJson.PageSize), 1, 20) pageSize := q5.AdjustRangeValue(q5.SafeToInt32(reqJson.PageSize), 1, 20)
cursor := q5.SafeToInt64(reqJson.Cursor) cursor := q5.SafeToInt64(reqJson.Cursor)
/* sql := fmt.Sprintf(`
SELECT * FROM t_recharge_order
WHERE idx > %d AND net_id = %d AND passport_address = ?`,
cursor, netId) */
sql := fmt.Sprintf(` sql := fmt.Sprintf(`
SELECT * FROM t_recharge SELECT * FROM t_recharge_order
WHERE idx > %d AND net_id = %d AND buyer = ?`, WHERE idx > %d AND passport_address = ?`,
cursor, netId) cursor)
params := []string{account} params := []string{account}
subFilters := []f5.DbQueryFilter{} subFilters := []f5.DbQueryFilter{}
{
itemIds := map[int32]int32{}
if reqJson.Search.Name != "" {
mt.Table.Item.Search(reqJson.Search.Name, itemIds)
}
for _, val := range reqJson.Filter.ItemIds {
itemId := q5.SafeToInt32(val)
itemIds[itemId] = 1
}
if len(itemIds) > 0 {
inSub := `item_id IN (`
i := 0
for key, _ := range itemIds {
if i == 0 {
inSub += q5.ToString(key)
} else {
inSub += "," + q5.ToString(key)
}
i += 1
}
inSub += ")"
q5.AppendSlice(&subFilters, f5.GetDbFilter().Custom(inSub).And())
}
}
orderBy := " ORDER BY createtime DESC " orderBy := " ORDER BY createtime DESC "
rspObj := struct { rspObj := struct {
@ -219,7 +192,7 @@ func (ea *RechargeApi) RechargeQuery(c *gin.Context) {
q5.NewSlice(&rspObj.Rows, 0, 10) q5.NewSlice(&rspObj.Rows, 0, 10)
f5.GetGoStyleDb().StreamPageQuery( f5.GetGoStyleDb().StreamPageQuery(
constant.BCEVENT_DB, constant.BCNFT_DB,
pageSize, pageSize,
cursor, cursor,
sql, sql,
@ -233,10 +206,10 @@ func (ea *RechargeApi) RechargeQuery(c *gin.Context) {
p := q5.NewSliceElement(&rspObj.Rows) p := q5.NewSliceElement(&rspObj.Rows)
p.TxHash = ds.GetByName("txhash") p.TxHash = ds.GetByName("txhash")
p.NetID = q5.SafeToInt64(ds.GetByName("net_id")) p.NetID = netId //q5.SafeToInt64(ds.GetByName("net_id"))
p.OrderID = ds.GetByName("order_id") p.OrderID = ds.GetByName("order_id")
p.Currency = ds.GetByName("currency") p.Currency = ds.GetByName("currency_name")
p.Amount = ds.GetByName("amount") p.Amount = ds.GetByName("item_num")
p.Date = q5.SafeToInt32(ds.GetByName("createtime")) p.Date = q5.SafeToInt32(ds.GetByName("createtime"))
}) })
c.JSON(200, rspObj) c.JSON(200, rspObj)