From 8bbfdd62c45d7f51b5c4583c772a40f17af0183b Mon Sep 17 00:00:00 2001 From: yangduo Date: Mon, 5 Aug 2024 10:57:00 +0800 Subject: [PATCH 01/21] =?UTF-8?q?=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../marketserver/api/v1/recharge/recharge.go | 28 ++++++++++--------- server/marketserver/api/v1/user/user.go | 4 +-- 2 files changed, 17 insertions(+), 15 deletions(-) diff --git a/server/marketserver/api/v1/recharge/recharge.go b/server/marketserver/api/v1/recharge/recharge.go index b2177c9c..f8db3e24 100644 --- a/server/marketserver/api/v1/recharge/recharge.go +++ b/server/marketserver/api/v1/recharge/recharge.go @@ -163,8 +163,8 @@ func (ea *RechargeApi) RechargeQuery(c *gin.Context) { cursor := q5.SafeToInt64(reqJson.Cursor) sql := fmt.Sprintf(` - SELECT * FROM t_recharge - WHERE idx > %d AND net_id = %d AND passport = ?`, + SELECT * FROM t_recharge_order + WHERE idx > %d AND net_id = %d AND passport_address = ? AND pay_status = 1`, cursor, netId) params := []string{account} @@ -177,19 +177,20 @@ func (ea *RechargeApi) RechargeQuery(c *gin.Context) { ErrMsg string `json:"errmsg"` Page common.StreamPagination `json:"page"` Rows []struct { - OrderID string `json:"order_id"` - TxHash string `json:"txhash"` - NetID int64 `json:"net_id"` - Currency string `json:"currency"` - Amount string `json:"amount"` - Diamond string `json:"diamond"` - Date int32 `json:"createtime"` + OrderID string `json:"order_id"` + TxHash string `json:"txhash"` + NetID int64 `json:"net_id"` + Currency string `json:"currency"` + CurrencyName string `json:"currency_name"` + Amount string `json:"amount"` + Diamond string `json:"diamond"` + Date int32 `json:"createtime"` } `json:"rows"` }{} q5.NewSlice(&rspObj.Rows, 0, 10) f5.GetGoStyleDb().StreamPageQuery( - constant.BCEVENT_DB, + constant.BCNFT_DB, pageSize, cursor, sql, @@ -203,10 +204,11 @@ func (ea *RechargeApi) RechargeQuery(c *gin.Context) { p := q5.NewSliceElement(&rspObj.Rows) p.TxHash = ds.GetByName("txhash") - p.NetID = q5.SafeToInt64(ds.GetByName("net_id")) + p.NetID = netId p.OrderID = ds.GetByName("order_id") - p.Currency = ds.GetByName("currency") - p.Amount = ds.GetByName("amount") + p.Currency = ds.GetByName("currency_address") + p.CurrencyName = ds.GetByName("currency_name") + p.Amount = ds.GetByName("price") p.Diamond = ds.GetByName("diamond") p.Date = q5.SafeToInt32(ds.GetByName("createtime")) }) diff --git a/server/marketserver/api/v1/user/user.go b/server/marketserver/api/v1/user/user.go index 0d07ef8e..54342a0e 100644 --- a/server/marketserver/api/v1/user/user.go +++ b/server/marketserver/api/v1/user/user.go @@ -98,12 +98,12 @@ func (this *UserApi) Info(c *gin.Context) { } { var dbErr error - sql := "SELECT SUM(diamond) FROM t_recharge WHERE passport = ? AND status = 0" + sql := "SELECT SUM(diamond) FROM t_recharge_order WHERE passport = ? AND pay_status = 1 AND delivery_status = 0;" params := []string{ accountAddress, } f5.GetGoStyleDb().RawQuery( - constant.BCEVENT_DB, + constant.BCNFT_DB, sql, params, func(err error, ds *f5.DataSet) { From f5cc26c9c2781046753fd783dbe9b3986536e203 Mon Sep 17 00:00:00 2001 From: yangduo Date: Mon, 5 Aug 2024 11:06:21 +0800 Subject: [PATCH 02/21] =?UTF-8?q?=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/marketserver/api/v1/recharge/recharge.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/server/marketserver/api/v1/recharge/recharge.go b/server/marketserver/api/v1/recharge/recharge.go index f8db3e24..b4a5dc38 100644 --- a/server/marketserver/api/v1/recharge/recharge.go +++ b/server/marketserver/api/v1/recharge/recharge.go @@ -178,6 +178,7 @@ func (ea *RechargeApi) RechargeQuery(c *gin.Context) { Page common.StreamPagination `json:"page"` Rows []struct { OrderID string `json:"order_id"` + ShortOrderID string `json:"short_order_id"` TxHash string `json:"txhash"` NetID int64 `json:"net_id"` Currency string `json:"currency"` @@ -206,6 +207,7 @@ func (ea *RechargeApi) RechargeQuery(c *gin.Context) { p.TxHash = ds.GetByName("txhash") p.NetID = netId p.OrderID = ds.GetByName("order_id") + p.ShortOrderID = ds.GetByName("short_order_id") p.Currency = ds.GetByName("currency_address") p.CurrencyName = ds.GetByName("currency_name") p.Amount = ds.GetByName("price") From f650fb85ec8121b0f64144d3330c84ed4b6f1fc2 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Mon, 5 Aug 2024 11:42:38 +0800 Subject: [PATCH 03/21] 1 --- server/light_backtask/task/recharge.go | 44 ++++++++++++++++++++++++++ 1 file changed, 44 insertions(+) diff --git a/server/light_backtask/task/recharge.go b/server/light_backtask/task/recharge.go index 60093544..7e39621b 100644 --- a/server/light_backtask/task/recharge.go +++ b/server/light_backtask/task/recharge.go @@ -84,6 +84,14 @@ func (this *recharge) saveToDb(ds *f5.DataSet) bool { p := new(itemSoldOut) if q5.DecodeJson(returnValues, p) == nil { decodeJsonOk = true + orderExists := false + if this.updateOrderStatus(txhash, p.OrderId, q5.ToInt32(createTime), &orderExists) != nil { + return false + } + status := 0 + if orderExists { + status = 1 + } var dbErr error f5.GetGoStyleDb().Upsert( constant.BCEVENT_DB, @@ -106,6 +114,7 @@ func (this *recharge) saveToDb(ds *f5.DataSet) bool { {"order_id", p.OrderId}, {"currency", p.Currency}, {"amount", p.Amount}, + {"status", q5.ToString(status)}, {"createtime", createTime}, {"modifytime", modifyTime}, }, @@ -128,3 +137,38 @@ func (this *recharge) saveToDb(ds *f5.DataSet) bool { } return true } + +func (this *recharge) updateOrderStatus(txhash string, orderId string, payTime int32, orderExists *bool) error { + *orderExists = false + var resultErr error + f5.GetGoStyleDb().OrmSelectOne( + constant.BCNFT_DB, + "t_recharge_order", + [][]string{ + {"order_id", orderId}, + }, + func (err error, ds *f5.DataSet) { + resultErr = err + if err != nil { + return + } + *orderExists = ds.Next() + }) + if resultErr == nil && *orderExists { + f5.GetGoStyleDb().Update( + constant.BCNFT_DB, + "t_recharge_order", + [][]string{ + {"order_id", orderId}, + }, + [][]string{ + {"txhash", txhash}, + {"pay_status", q5.ToString(1)}, + {"pay_time", q5.ToString(payTime)}, + }, + func (err error, lastInsertId int64, rowsAffected int64) { + resultErr = err + }) + } + return resultErr +} From 2d721e214e40f1ce99013a18e628fd4202a64a57 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Mon, 5 Aug 2024 11:55:40 +0800 Subject: [PATCH 04/21] 1 --- server/marketserver/api/v1/recharge/recharge.go | 5 ++++- server/marketserver/service/recharge.go | 6 ++++-- 2 files changed, 8 insertions(+), 3 deletions(-) diff --git a/server/marketserver/api/v1/recharge/recharge.go b/server/marketserver/api/v1/recharge/recharge.go index b4a5dc38..d14ab3e6 100644 --- a/server/marketserver/api/v1/recharge/recharge.go +++ b/server/marketserver/api/v1/recharge/recharge.go @@ -47,6 +47,7 @@ func (this *RechargeApi) Buy(c *gin.Context) { reqJson := struct { NetId int32 `json:"net_id"` GoodsId int32 `json:"goods_id"` + Num int32 `json:"num"` AccountAddress string `json:"account_address"` }{} if err := c.ShouldBindJSON(&reqJson); err != nil { @@ -125,13 +126,15 @@ func (this *RechargeApi) Buy(c *gin.Context) { accountId, orderId, q5.ToString(shortOrderId), + reqJson.NetId, reqJson.AccountAddress, passportAddress, currencyMeta.GetName(), currencyMeta.GetAddress(), goodsMeta.GetId(), 1, - price) { + price, + 1) { f5.RspErr(c, 500, "server internal error") return } diff --git a/server/marketserver/service/recharge.go b/server/marketserver/service/recharge.go index 0481c46f..f0bf39f0 100644 --- a/server/marketserver/service/recharge.go +++ b/server/marketserver/service/recharge.go @@ -7,9 +7,9 @@ import ( ) func AddRechargeOrder(accountId string, orderId string, shortOrderId string, - accountAddress string, passportAddress string, + netId int32, accountAddress string, passportAddress string, currencyAddress string, currencyName string, itemId int32, itemNum int64, - price string) bool { + price string, diamond int64) bool { ok := false nowTime := f5.GetApp().GetRealSeconds() f5.GetGoStyleDb().UpsertEx( @@ -24,6 +24,7 @@ func AddRechargeOrder(accountId string, orderId string, shortOrderId string, {"account_id", accountId}, {"order_id", orderId}, {"short_order_id", shortOrderId}, + {"net_id", q5.ToString(netId)}, {"account_address", accountAddress}, {"passport_address", passportAddress}, {"currency_name", currencyName}, @@ -31,6 +32,7 @@ func AddRechargeOrder(accountId string, orderId string, shortOrderId string, {"item_id", q5.ToString(itemId)}, {"item_num", q5.ToString(itemNum)}, {"price", price}, + {"diamond", q5.ToString(diamond)}, {"createtime", q5.ToString(nowTime)}, {"modifytime", q5.ToString(nowTime)}, }, From f9a569a36626a988f92c109d6b50d8d921c65e89 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Mon, 5 Aug 2024 11:57:17 +0800 Subject: [PATCH 05/21] 1 --- server/marketserver/api/v1/recharge/recharge.go | 6 ++++-- server/marketserver/service/recharge.go | 2 +- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/server/marketserver/api/v1/recharge/recharge.go b/server/marketserver/api/v1/recharge/recharge.go index d14ab3e6..1422237a 100644 --- a/server/marketserver/api/v1/recharge/recharge.go +++ b/server/marketserver/api/v1/recharge/recharge.go @@ -105,6 +105,8 @@ func (this *RechargeApi) Buy(c *gin.Context) { ErrMsg string `json:"errmsg"` Calls []jccommon.ContractCall `json:"calls"` }{} + var itemNum int32 = 1 + var diamond int64 = 1 url := fmt.Sprintf("%s/webapp/index.php", mt.Table.Web3SignCluster.RandElement().GetUrl()) f5.GetHttpCliMgr().SendGoStyleRequest( url, @@ -132,9 +134,9 @@ func (this *RechargeApi) Buy(c *gin.Context) { currencyMeta.GetName(), currencyMeta.GetAddress(), goodsMeta.GetId(), - 1, + itemNum, price, - 1) { + diamond) { f5.RspErr(c, 500, "server internal error") return } diff --git a/server/marketserver/service/recharge.go b/server/marketserver/service/recharge.go index f0bf39f0..1e94c79e 100644 --- a/server/marketserver/service/recharge.go +++ b/server/marketserver/service/recharge.go @@ -8,7 +8,7 @@ import ( func AddRechargeOrder(accountId string, orderId string, shortOrderId string, netId int32, accountAddress string, passportAddress string, - currencyAddress string, currencyName string, itemId int32, itemNum int64, + currencyAddress string, currencyName string, itemId int32, itemNum int32, price string, diamond int64) bool { ok := false nowTime := f5.GetApp().GetRealSeconds() From 8e071847da0f482006dc9aa0fd698704d398ee37 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Mon, 5 Aug 2024 13:17:49 +0800 Subject: [PATCH 06/21] 1 --- server/backtask/task/recharge.go | 42 ++++++++++++-------------------- server/jccommon/constant.go | 9 ++++--- 2 files changed, 21 insertions(+), 30 deletions(-) diff --git a/server/backtask/task/recharge.go b/server/backtask/task/recharge.go index 24c4a5ab..c65a7756 100644 --- a/server/backtask/task/recharge.go +++ b/server/backtask/task/recharge.go @@ -4,6 +4,7 @@ import ( "q5" "f5" "main/constant" + "main/service" "fmt" //"main/mt" //"strings" @@ -22,19 +23,20 @@ func (this *recharge) unInit() { func (this *recharge) process() { f5.GetGoStyleDb().LoopLoadNew( - constant.BCEVENT_DB, + constant.BCNFT_DB, "recharge", - "t_recharge", + "t_recharge_order", 0, func (lastIdx int64, maxIdx int64) (string, []string) { sql := fmt.Sprintf(` -SELECT * FROM t_recharge -WHERE idx > %d AND idx <= %d AND status = %d +SELECT * FROM t_recharge_order +WHERE idx > %d AND idx <= %d AND pay_status = %d AND delivery_status = %d ORDER BY idx LIMIT 1000 `, lastIdx, maxIdx, - jccommon.RECHARGE_STATUS_PENDING) + jccommon.RECHARGE_ORDER_PAY_STATUS_OK, + jccommon.RECHARGE_ORDER_DELIVERY_STATUS_PENDING) params := []string{ } return sql, params @@ -44,34 +46,20 @@ ORDER BY idx LIMIT 1000 func (this *recharge) deliverGoods(ds *f5.DataSet) bool { var result = false - orderId := ds.GetByName("order_id") - f5.GetGoStyleDb().OrmSelectOne( - constant.GAME_DB, - "t_recharge_order", - [][]string{ - {"order_id", orderId}, - }, - func (err error, ds *f5.DataSet) { - if err != nil { - result = false - return - } - idx := q5.ToInt64(ds.GetByName("idx")) - status := q5.ToInt32(ds.GetByName("stauts")) - if status != 0 { - result = this.markStatus(idx, jccommon.RECHARGE_STATUS_SENT) == nil - return - } - result = this.markStatus(idx, jccommon.RECHARGE_STATUS_SENT) == nil - }) + //orderId := ds.GetByName("order_id") + passportAddress := ds.GetByName("passport_address") + accountId := service.GetAccountIdByAddress(passportAddress) + if accountId == "" { + return false + } return result } func (this *recharge) markStatus(idx int64, status int32) error { var resultErr error f5.GetGoStyleDb().Update( - constant.BCEVENT_DB, - "t_recharge", + constant.BCNFT_DB, + "t_recharge_order", [][]string{ {"idx", q5.ToString(idx)}, }, diff --git a/server/jccommon/constant.go b/server/jccommon/constant.go index db04a150..74c12488 100644 --- a/server/jccommon/constant.go +++ b/server/jccommon/constant.go @@ -105,13 +105,16 @@ const ( ) const ( - RECHARGE_ORDER_STATUS_PENDING = 0 - RECHARGE_ORDER_STATUS_SENT =1 + RECHARGE_ORDER_PAY_STATUS_PENDING = 0 + RECHARGE_ORDER_PAY_STATUS_OK = 1 + + RECHARGE_ORDER_DELIVERY_STATUS_PENDING =0 + RECHARGE_ORDER_DELIVERY_STATUS_OK = 1 ) const ( RECHARGE_STATUS_PENDING = 0 - RECHARGE_STATUS_SENT =1 + RECHARGE_STATUS_SENT = 1 ) const ( From d05123ebb3b3b13dcbcc3389ee3d65ee40209706 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Mon, 5 Aug 2024 13:19:23 +0800 Subject: [PATCH 07/21] 1 --- server/backtask/task/recharge.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/backtask/task/recharge.go b/server/backtask/task/recharge.go index c65a7756..d402ec37 100644 --- a/server/backtask/task/recharge.go +++ b/server/backtask/task/recharge.go @@ -24,7 +24,7 @@ func (this *recharge) unInit() { func (this *recharge) process() { f5.GetGoStyleDb().LoopLoadNew( constant.BCNFT_DB, - "recharge", + "recharge_order", "t_recharge_order", 0, func (lastIdx int64, maxIdx int64) (string, []string) { From fb6260c774ad93025b675ad6814ced153f143743 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Mon, 5 Aug 2024 13:32:27 +0800 Subject: [PATCH 08/21] 1 --- server/backtask/service/user.go | 10 +++++----- server/backtask/task/recharge.go | 21 ++++++++++++++------- 2 files changed, 19 insertions(+), 12 deletions(-) diff --git a/server/backtask/service/user.go b/server/backtask/service/user.go index 96bfebe4..b0c011ba 100644 --- a/server/backtask/service/user.go +++ b/server/backtask/service/user.go @@ -128,7 +128,7 @@ func AddGameLog(accountId string, logType string, subType string, }) } -func UserAddDiamond(accountId string, diamondNum int32, netId int32, tokenId string, reason int32) bool { +func UserAddDiamond(accountId string, diamondNum int64, netId int32, orderId string) bool { var oldDiamond float64 { f5.GetGoStyleDb().OrmSelectOne( @@ -144,8 +144,8 @@ func UserAddDiamond(accountId string, diamondNum int32, netId int32, tokenId str if ds.Next() { oldDiamond = q5.ToFloat64(ds.GetByName("diamond")) AddGameLog(accountId, jccommon.GAME_LOG_TYPE_BACKTASK_USER_ADD_DIAMOND_START, - q5.ToString(reason), - q5.ToString(netId), tokenId, q5.ToString(oldDiamond), q5.ToString(diamondNum)) + "", + q5.ToString(netId), orderId, q5.ToString(oldDiamond), q5.ToString(diamondNum)) } }) } @@ -181,8 +181,8 @@ func UserAddDiamond(accountId string, diamondNum int32, netId int32, tokenId str if ds.Next() { newDiamond := q5.ToFloat64(ds.GetByName("diamond")) AddGameLog(accountId, jccommon.GAME_LOG_TYPE_BACKTASK_USER_ADD_DIAMOND_END, - q5.ToString(reason), - q5.ToString(netId), tokenId, q5.ToString(oldDiamond), q5.ToString(newDiamond)) + "", + q5.ToString(netId), orderId, q5.ToString(oldDiamond), q5.ToString(newDiamond)) } }) } diff --git a/server/backtask/task/recharge.go b/server/backtask/task/recharge.go index d402ec37..e778bb0e 100644 --- a/server/backtask/task/recharge.go +++ b/server/backtask/task/recharge.go @@ -6,8 +6,6 @@ import ( "main/constant" "main/service" "fmt" - //"main/mt" - //"strings" "jccommon" ) @@ -45,17 +43,24 @@ ORDER BY idx LIMIT 1000 } func (this *recharge) deliverGoods(ds *f5.DataSet) bool { - var result = false - //orderId := ds.GetByName("order_id") + idx := q5.ToInt64(ds.GetByName("idx")) + orderId := ds.GetByName("order_id") passportAddress := ds.GetByName("passport_address") + diamond := q5.ToInt64(ds.GetByName("diamond")) + netId := q5.ToInt32(ds.GetByName("net_id")) accountId := service.GetAccountIdByAddress(passportAddress) if accountId == "" { return false } - return result + if this.markOk(idx, accountId) != nil { + return false + + } + ret := service.UserAddDiamond(accountId, diamond, netId, orderId) + return ret } -func (this *recharge) markStatus(idx int64, status int32) error { +func (this *recharge) markOk(idx int64, deliveryAccountId string) error { var resultErr error f5.GetGoStyleDb().Update( constant.BCNFT_DB, @@ -64,7 +69,9 @@ func (this *recharge) markStatus(idx int64, status int32) error { {"idx", q5.ToString(idx)}, }, [][]string{ - {"status", q5.ToString(status)}, + {"delivery_status", q5.ToString(jccommon.RECHARGE_ORDER_DELIVERY_STATUS_OK)}, + {"delivery_time", q5.ToString(f5.GetApp().GetRealSeconds())}, + {"receiver_account_id", deliveryAccountId}, }, func (err error, lastInsertId int64, rowsAffected int64) { resultErr = err From ef70986256592356aff2f5e3c95b028d5509052b Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Mon, 5 Aug 2024 13:54:57 +0800 Subject: [PATCH 09/21] 1 --- server/backtask/task/recharge.go | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/server/backtask/task/recharge.go b/server/backtask/task/recharge.go index e778bb0e..7e3e53b7 100644 --- a/server/backtask/task/recharge.go +++ b/server/backtask/task/recharge.go @@ -50,14 +50,13 @@ func (this *recharge) deliverGoods(ds *f5.DataSet) bool { netId := q5.ToInt32(ds.GetByName("net_id")) accountId := service.GetAccountIdByAddress(passportAddress) if accountId == "" { - return false + return true } if this.markOk(idx, accountId) != nil { - return false - + return true } - ret := service.UserAddDiamond(accountId, diamond, netId, orderId) - return ret + service.UserAddDiamond(accountId, diamond, netId, orderId) + return true } func (this *recharge) markOk(idx int64, deliveryAccountId string) error { From f693eee5829af021af67cf4101909c66ff83e521 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Mon, 5 Aug 2024 14:08:23 +0800 Subject: [PATCH 10/21] 1 --- server/marketserver/api/v1/recharge/recharge.go | 2 -- server/marketserver/service/recharge.go | 3 +-- 2 files changed, 1 insertion(+), 4 deletions(-) diff --git a/server/marketserver/api/v1/recharge/recharge.go b/server/marketserver/api/v1/recharge/recharge.go index 1422237a..5e27d3b5 100644 --- a/server/marketserver/api/v1/recharge/recharge.go +++ b/server/marketserver/api/v1/recharge/recharge.go @@ -42,7 +42,6 @@ func (ea *RechargeApi) RechargeList(c *gin.Context) { } func (this *RechargeApi) Buy(c *gin.Context) { - accountId := c.MustGet("open_id").(string) passportAddress := c.MustGet("account_address").(string) reqJson := struct { NetId int32 `json:"net_id"` @@ -125,7 +124,6 @@ func (this *RechargeApi) Buy(c *gin.Context) { return } if !service.AddRechargeOrder( - accountId, orderId, q5.ToString(shortOrderId), reqJson.NetId, diff --git a/server/marketserver/service/recharge.go b/server/marketserver/service/recharge.go index 1e94c79e..82ce0e3e 100644 --- a/server/marketserver/service/recharge.go +++ b/server/marketserver/service/recharge.go @@ -6,7 +6,7 @@ import ( "main/constant" ) -func AddRechargeOrder(accountId string, orderId string, shortOrderId string, +func AddRechargeOrder(orderId string, shortOrderId string, netId int32, accountAddress string, passportAddress string, currencyAddress string, currencyName string, itemId int32, itemNum int32, price string, diamond int64) bool { @@ -21,7 +21,6 @@ func AddRechargeOrder(accountId string, orderId string, shortOrderId string, [][]string{ }, [][]string{ - {"account_id", accountId}, {"order_id", orderId}, {"short_order_id", shortOrderId}, {"net_id", q5.ToString(netId)}, From e37b646ed3d87df097719db26a2b9893ae60fbe8 Mon Sep 17 00:00:00 2001 From: yangduo Date: Mon, 5 Aug 2024 14:21:29 +0800 Subject: [PATCH 11/21] =?UTF-8?q?=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/marketserver/api/v1/user/user.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/marketserver/api/v1/user/user.go b/server/marketserver/api/v1/user/user.go index 54342a0e..30128a06 100644 --- a/server/marketserver/api/v1/user/user.go +++ b/server/marketserver/api/v1/user/user.go @@ -98,7 +98,7 @@ func (this *UserApi) Info(c *gin.Context) { } { var dbErr error - sql := "SELECT SUM(diamond) FROM t_recharge_order WHERE passport = ? AND pay_status = 1 AND delivery_status = 0;" + sql := "SELECT SUM(diamond) FROM t_recharge_order WHERE passport_address = ? AND pay_status = 1 AND delivery_status = 0;" params := []string{ accountAddress, } From 19c062423addc2cb4653bcc6b6ed73a1040c12d9 Mon Sep 17 00:00:00 2001 From: yangduo Date: Mon, 5 Aug 2024 17:24:20 +0800 Subject: [PATCH 12/21] =?UTF-8?q?=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../marketserver/api/v1/activity/stacking.go | 49 +++++++++++++++---- 1 file changed, 40 insertions(+), 9 deletions(-) diff --git a/server/marketserver/api/v1/activity/stacking.go b/server/marketserver/api/v1/activity/stacking.go index 1177039c..386f906c 100644 --- a/server/marketserver/api/v1/activity/stacking.go +++ b/server/marketserver/api/v1/activity/stacking.go @@ -128,10 +128,15 @@ func (sa *StackingApi) ContributionQuery(c *gin.Context) { func (sa *StackingApi) DiamondRecordQuery(c *gin.Context) { accountAddress := strings.ToLower(c.Param("account_address")) + type Record struct { + Date int32 `json:"date"` + Amount string `json:"amount"` + Type int32 `json:"type"` + } rspObj := struct { - ErrCode int32 `json:"errcode"` - ErrMsg string `json:"errmsg"` - Rows []interface{} `json:"rows"` + ErrCode int32 `json:"errcode"` + ErrMsg string `json:"errmsg"` + Rows []*Record `json:"rows"` }{} { @@ -150,20 +155,46 @@ func (sa *StackingApi) DiamondRecordQuery(c *gin.Context) { return } - obj := struct { - Date int32 `json:"date"` - Amount string `json:"amount"` - Type int32 `json:"type"` - }{} + obj := new(Record) for ds.Next() { obj.Date = q5.SafeToInt32(ds.GetByName("createtime")) obj.Amount = ds.GetByName("amount") - obj.Type = q5.SafeToInt32(ds.GetByName("type")) + obj.Type = 1 rspObj.Rows = append(rspObj.Rows, obj) } }) } + { + sql := `SELECT * FROM t_recharge_order WHERE passport_address = ? AND pay_status = 1 ORDER BY createtime DESC` + params := []string{ + accountAddress, + } + + f5.GetGoStyleDb().RawQuery( + constant.BCNFT_DB, + sql, + params, + func(err error, ds *f5.DataSet) { + if err != nil { + return + } + + obj := new(Record) + + for ds.Next() { + obj.Date = q5.SafeToInt32(ds.GetByName("pay_time")) + obj.Amount = ds.GetByName("diamond") + obj.Type = 0 + rspObj.Rows = append(rspObj.Rows, obj) + } + }) + } + + q5.Sort(rspObj.Rows, func(a *Record, b *Record) bool { + return a.Date > b.Date + }) + c.JSON(200, rspObj) } From 601191a04a74ed443ff06b6c2e0d6273ee2a2da6 Mon Sep 17 00:00:00 2001 From: yangduo Date: Mon, 5 Aug 2024 17:30:23 +0800 Subject: [PATCH 13/21] fix --- server/marketserver/api/v1/activity/stacking.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/server/marketserver/api/v1/activity/stacking.go b/server/marketserver/api/v1/activity/stacking.go index 386f906c..bdff93d7 100644 --- a/server/marketserver/api/v1/activity/stacking.go +++ b/server/marketserver/api/v1/activity/stacking.go @@ -155,9 +155,9 @@ func (sa *StackingApi) DiamondRecordQuery(c *gin.Context) { return } - obj := new(Record) - for ds.Next() { + obj := new(Record) + obj.Date = q5.SafeToInt32(ds.GetByName("createtime")) obj.Amount = ds.GetByName("amount") obj.Type = 1 @@ -181,9 +181,9 @@ func (sa *StackingApi) DiamondRecordQuery(c *gin.Context) { return } - obj := new(Record) - for ds.Next() { + obj := new(Record) + obj.Date = q5.SafeToInt32(ds.GetByName("pay_time")) obj.Amount = ds.GetByName("diamond") obj.Type = 0 From 76cc87f7a26c544e2a20bcb90dff320dc731a7a5 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Mon, 5 Aug 2024 17:57:48 +0800 Subject: [PATCH 14/21] 1 --- database/admindb.sql | 64 +++++++++++++++++++++++++++++++++++--------- 1 file changed, 51 insertions(+), 13 deletions(-) diff --git a/database/admindb.sql b/database/admindb.sql index 3e2575c5..9484fa9b 100644 --- a/database/admindb.sql +++ b/database/admindb.sql @@ -1,24 +1,62 @@ +-- MySQL dump 10.14 Distrib 5.5.41-MariaDB, for Linux (x86_64) +-- +-- Host: localhost Database: admindb +-- ------------------------------------------------------ +-- Server version 5.5.41-MariaDB + +/*!40101 SET @OLD_CHARACTER_SET_CLIENT=@@CHARACTER_SET_CLIENT */; +/*!40101 SET @OLD_CHARACTER_SET_RESULTS=@@CHARACTER_SET_RESULTS */; +/*!40101 SET @OLD_COLLATION_CONNECTION=@@COLLATION_CONNECTION */; +/*!40101 SET NAMES utf8 */; +/*!40103 SET @OLD_TIME_ZONE=@@TIME_ZONE */; +/*!40103 SET TIME_ZONE='+00:00' */; +/*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0 */; +/*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0 */; +/*!40101 SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE='NO_AUTO_VALUE_ON_ZERO' */; +/*!40111 SET @OLD_SQL_NOTES=@@SQL_NOTES, SQL_NOTES=0 */; + +-- +-- Table structure for table `version` +-- + DROP TABLE IF EXISTS `version`; /*!40101 SET @saved_cs_client = @@character_set_client */; /*!40101 SET character_set_client = utf8 */; CREATE TABLE `version` ( -`idx` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '自增id', -`version` int(11) NOT NULL DEFAULT '0' COMMENT '版本号', -PRIMARY KEY (`idx`), -UNIQUE KEY `version` (`version`) + `idx` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '自增id', + `version` int(11) NOT NULL DEFAULT '0' COMMENT '版本号', + PRIMARY KEY (`idx`), + UNIQUE KEY `version` (`version`) ) ENGINE=InnoDB AUTO_INCREMENT=10001 DEFAULT CHARSET=utf8 COLLATE=utf8_bin; /*!40101 SET character_set_client = @saved_cs_client */; +-- +-- Table structure for table `t_op_log` +-- -DROP TABLE IF EXISTS `t_user`; +DROP TABLE IF EXISTS `t_op_log`; /*!40101 SET @saved_cs_client = @@character_set_client */; /*!40101 SET character_set_client = utf8 */; -CREATE TABLE `t_user` ( -`idx` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '自增id', -`username` varchar(32) NOT NULL DEFAULT '0' COMMENT '用户名', -`nickname` varchar(32) NOT NULL DEFAULT '0' COMMENT '别名', -`password` varchar(64) NOT NULL DEFAULT '0' COMMENT '密码', -PRIMARY KEY (`idx`), -UNIQUE KEY `username` (`username`) -) ENGINE=InnoDB AUTO_INCREMENT=10001 DEFAULT CHARSET=utf8 COLLATE=utf8_bin; +CREATE TABLE `t_op_log` ( + `idx` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '自增id', + `account_address` varchar(60) NOT NULL COMMENT '钱包地址', + `url` text NOT NULL DEFAULT '' COMMENT 'url<64kb', + `params` text NOT NULL DEFAULT '' COMMENT 'params<64kb', + `postdata` mediumtext NOT NULL DEFAULT '' COMMENT 'postdata<16mb', + `createtime` int(11) NOT NULL DEFAULT '0' COMMENT '创建时间', + `modifytime` int(11) NOT NULL DEFAULT '0' COMMENT '修改时间', + KEY `idx_account_address` (`account_address`), + PRIMARY KEY (`idx`) +) ENGINE=InnoDB AUTO_INCREMENT=10000 DEFAULT CHARSET=utf8 COLLATE=utf8_bin; /*!40101 SET character_set_client = @saved_cs_client */; +/*!40103 SET TIME_ZONE=@OLD_TIME_ZONE */; + +/*!40101 SET SQL_MODE=@OLD_SQL_MODE */; +/*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */; +/*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */; +/*!40101 SET CHARACTER_SET_CLIENT=@OLD_CHARACTER_SET_CLIENT */; +/*!40101 SET CHARACTER_SET_RESULTS=@OLD_CHARACTER_SET_RESULTS */; +/*!40101 SET COLLATION_CONNECTION=@OLD_COLLATION_CONNECTION */; +/*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */; + +-- Dump completed on 2015-08-19 18:52:06 From 453e37bb7e99271c62200857f6ad5eed72131b89 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Mon, 5 Aug 2024 18:02:31 +0800 Subject: [PATCH 15/21] 1 --- database/admindb.sql | 1 + 1 file changed, 1 insertion(+) diff --git a/database/admindb.sql b/database/admindb.sql index 9484fa9b..3adbb9e2 100644 --- a/database/admindb.sql +++ b/database/admindb.sql @@ -40,6 +40,7 @@ DROP TABLE IF EXISTS `t_op_log`; CREATE TABLE `t_op_log` ( `idx` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '自增id', `account_address` varchar(60) NOT NULL COMMENT '钱包地址', + `http_method` varchar(10) NOT NULL COMMENT 'http method<10byte', `url` text NOT NULL DEFAULT '' COMMENT 'url<64kb', `params` text NOT NULL DEFAULT '' COMMENT 'params<64kb', `postdata` mediumtext NOT NULL DEFAULT '' COMMENT 'postdata<16mb', From d024d8bd7dfecda8bccdc1632873d7344b14fa1d Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Mon, 5 Aug 2024 19:34:28 +0800 Subject: [PATCH 16/21] 1 --- server/adminserver/api/v1/system/mail.go | 7 ++++++- server/adminserver/model/system/mail.go | 2 ++ server/jccommon/constant.go | 3 +++ 3 files changed, 11 insertions(+), 1 deletion(-) diff --git a/server/adminserver/api/v1/system/mail.go b/server/adminserver/api/v1/system/mail.go index a0f87220..d4c16d76 100644 --- a/server/adminserver/api/v1/system/mail.go +++ b/server/adminserver/api/v1/system/mail.go @@ -26,6 +26,7 @@ func (this *MailApi) ListMail(c *gin.Context) { func (this *MailApi) AddMail(c *gin.Context) { reqJson := struct { + UniKey string `json:"unikey"` MailType int32 `binding:"required" json:"mailtype"` SendTime int32 `json:"sendtime"` ExpireTime int32 `json:"expiretime"` @@ -62,9 +63,13 @@ func (this *MailApi) AddMail(c *gin.Context) { mail.Content = reqJson.Content mail.Attachments = reqJson.Attachments mail.Recipients = reqJson.Recipients + mail.Tag1 = jccommon.MAIL_TAG1_CUSTOM + mail.Tag2 = jccommon.MAIL_TAG2_CUSTOM_NORMAL mail.CreateTime = nowDaySeconds mail.ModifyTime = nowDaySeconds - f5.GetApp().GetOrmDb(constant.MAIL_DB).Create(mail) + if f5.GetApp().GetOrmDb(constant.MAIL_DB).Create(mail).Error == nil { + + } { e := new(jccommon.MailEvent) e.EventName = jccommon.EVENT_MAIL_UPDATE diff --git a/server/adminserver/model/system/mail.go b/server/adminserver/model/system/mail.go index d192ef7a..e9911256 100644 --- a/server/adminserver/model/system/mail.go +++ b/server/adminserver/model/system/mail.go @@ -33,6 +33,8 @@ type Mail struct { SendTime int32 `gorm:"column:sendtime" json:"sendtime"` UserRegStartTime int32 `gorm:"column:user_reg_start_time" json:"user_reg_start_time"` UserRegEndTime int32 `gorm:"column:user_reg_end_time" json:"user_reg_end_time"` + Tag1 int32 `gorm:"column:tag1" json:"tag1"` + Tag2 int32 `gorm:"column:tag2;<-:create" json:"tag2"` ExpireTime int32 `gorm:"column:expiretime" json:"expiretime"` CreateTime int32 `gorm:"column:createtime;<-:create" json:"createtime"` ModifyTime int32 `gorm:"column:modifytime" json:"modifytime"` diff --git a/server/jccommon/constant.go b/server/jccommon/constant.go index 74c12488..948730ab 100644 --- a/server/jccommon/constant.go +++ b/server/jccommon/constant.go @@ -37,11 +37,14 @@ const ( ) const ( + MAIL_TAG1_CUSTOM = 1 MAIL_TAG1_HERO = 100 MAIL_TAG1_GOLD_BULLION = 101 ) const ( + MAIL_TAG2_CUSTOM_NORMAL = 1 + MAIL_TAG2_HERO_MINT = 1 MAIL_TAG2_HERO_LOCK = 2 MAIL_TAG2_HERO_UNLOCK = 3 From a23da03bfd7b1a4a0fc510b58d9b38fcf2f49991 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Tue, 6 Aug 2024 10:16:17 +0800 Subject: [PATCH 17/21] 1 --- README.md | 5 +++++ bin/adminserver/config/permission.json | 2 ++ bin/adminserver/config/users.json | 12 ++++++++++++ 3 files changed, 19 insertions(+) diff --git a/README.md b/README.md index 794f3e89..4768a950 100644 --- a/README.md +++ b/README.md @@ -1,3 +1,8 @@ +# 本地host文件修改 +192.144.140.87 mysql-test.kingsome.cn +192.144.140.87 mysql-redis.kingsome.cn +192.144.200.110 polyservice-test.kingsome.cn + # 数据库规范 所有的表都必须有一下字段 diff --git a/bin/adminserver/config/permission.json b/bin/adminserver/config/permission.json index a011202a..84434e0b 100644 --- a/bin/adminserver/config/permission.json +++ b/bin/adminserver/config/permission.json @@ -1,9 +1,11 @@ { "api": [ + "*", "api/v1/mail/add", "api/v1/mail/edit", "api/v1/mail/list" ], "ui": [ + "*" ] } diff --git a/bin/adminserver/config/users.json b/bin/adminserver/config/users.json index 6b91c199..9ce704e2 100644 --- a/bin/adminserver/config/users.json +++ b/bin/adminserver/config/users.json @@ -9,5 +9,17 @@ "api": ["xxx", "-xxx"], "ui": ["addannouncement", "editannouncement", "addaudit", "editaudit"] } + }, + { + "account_address": "0xAd2DeA1977055Db01C66e6E53309C4604AB869b8", + "__doc__": "az", + "roles": [ + "admin", + "customer_service" + ], + "special": { + "api": ["xxx", "-xxx"], + "ui": ["addannouncement", "editannouncement", "addaudit", "editaudit"] + } } ] From a3722c9b3e47325efe5e1ac0eaef1f867e8dd0e0 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Tue, 6 Aug 2024 10:17:27 +0800 Subject: [PATCH 18/21] 1 --- README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/README.md b/README.md index 4768a950..5081a28e 100644 --- a/README.md +++ b/README.md @@ -1,6 +1,6 @@ # 本地host文件修改 192.144.140.87 mysql-test.kingsome.cn -192.144.140.87 mysql-redis.kingsome.cn +192.144.140.87 redis-test.kingsome.cn 192.144.200.110 polyservice-test.kingsome.cn # 数据库规范 From eb1ab5512ba829aabf6c96240333cc098cdb912c Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Tue, 6 Aug 2024 10:18:16 +0800 Subject: [PATCH 19/21] 1 --- bin/adminserver/config/web3service.cluster.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/bin/adminserver/config/web3service.cluster.json b/bin/adminserver/config/web3service.cluster.json index 66935ae5..2b19939a 100644 --- a/bin/adminserver/config/web3service.cluster.json +++ b/bin/adminserver/config/web3service.cluster.json @@ -1,5 +1,5 @@ [ { - "url": "http://192.144.200.110:7682" + "url": "http://polyservice-test.kingsome.cn:7682" } ] From b8908835b40d8194f4dd7840b7508edfb6a71212 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Tue, 6 Aug 2024 11:51:39 +0800 Subject: [PATCH 20/21] 1 --- server/adminserver/app/app.go | 37 ------------------------- server/adminserver/model/system/mail.go | 2 +- third_party/f5 | 2 +- 3 files changed, 2 insertions(+), 39 deletions(-) diff --git a/server/adminserver/app/app.go b/server/adminserver/app/app.go index aadc7989..ff05c9c4 100644 --- a/server/adminserver/app/app.go +++ b/server/adminserver/app/app.go @@ -47,26 +47,6 @@ func (this *app) Update() { } func (this *app) registerDataSources() { - f5.GetJsStyleDb().RegisterDataSource( - constant.GAME_DB, - mt.Table.GameDb.GetById(0).GetHost(), - mt.Table.GameDb.GetById(0).GetPort(), - mt.Table.GameDb.GetById(0).GetUser(), - mt.Table.GameDb.GetById(0).GetPasswd(), - mt.Table.GameDb.GetById(0).GetDatabase(), - 1, - mt.Table.GameDb.GetById(0).GetMaxOpenConns(), - mt.Table.GameDb.GetById(0).GetMaxIdleConns()) - f5.GetJsStyleDb().RegisterDataSource( - constant.FRIEND_DB, - mt.Table.FriendDb.GetById(0).GetHost(), - mt.Table.FriendDb.GetById(0).GetPort(), - mt.Table.FriendDb.GetById(0).GetUser(), - mt.Table.FriendDb.GetById(0).GetPasswd(), - mt.Table.FriendDb.GetById(0).GetDatabase(), - 1, - mt.Table.FriendDb.GetById(0).GetMaxOpenConns(), - mt.Table.FriendDb.GetById(0).GetMaxIdleConns()) f5.GetApp().RegisterOrmDb( constant.ADMIN_DB, mt.Table.AdminDb.GetById(0).GetHost(), @@ -141,23 +121,6 @@ func (this *app) registerDataSources() { mt.Table.ConfDb.GetById(0).GetMaxIdleConns()) } -func (this *app) AddSession(accountId string) string { - /* - this.sessionLock.Lock() - defer this.sessionLock.Unlock() - uuid := f5.GetApp().NewGlobalUuid() - str := fmt.Sprintf("%s%d%s%d", accountId, uuid, randStringBytes(12), time.Now().Unix()) - md5New := md5.New() - strByte := []byte(str) - md5New.Write(strByte) - md5String := hex.EncodeToString(md5New.Sum(nil)) - token := accountId + "|" + md5String - this.sessionHash[accountId] = token - return token - */ - return "" -} - func (this *app) HasTask() bool { return false } diff --git a/server/adminserver/model/system/mail.go b/server/adminserver/model/system/mail.go index e9911256..0af7b3fc 100644 --- a/server/adminserver/model/system/mail.go +++ b/server/adminserver/model/system/mail.go @@ -34,7 +34,7 @@ type Mail struct { UserRegStartTime int32 `gorm:"column:user_reg_start_time" json:"user_reg_start_time"` UserRegEndTime int32 `gorm:"column:user_reg_end_time" json:"user_reg_end_time"` Tag1 int32 `gorm:"column:tag1" json:"tag1"` - Tag2 int32 `gorm:"column:tag2;<-:create" json:"tag2"` + Tag2 int32 `gorm:"column:tag2;" json:"tag2"` ExpireTime int32 `gorm:"column:expiretime" json:"expiretime"` CreateTime int32 `gorm:"column:createtime;<-:create" json:"createtime"` ModifyTime int32 `gorm:"column:modifytime" json:"modifytime"` diff --git a/third_party/f5 b/third_party/f5 index c3814ee3..cf0959d4 160000 --- a/third_party/f5 +++ b/third_party/f5 @@ -1 +1 @@ -Subproject commit c3814ee3afc6ef21c0e7683192044571f561009f +Subproject commit cf0959d4bd0cee6e8cad378defe82fd478851368 From e518a45f3c7f92ed5140f4da2d126db04268963c Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Tue, 6 Aug 2024 13:45:00 +0800 Subject: [PATCH 21/21] 1 --- server/adminserver/api/v1/system/mail.go | 25 ++++++++++++++++++++++-- third_party/f5 | 2 +- 2 files changed, 24 insertions(+), 3 deletions(-) diff --git a/server/adminserver/api/v1/system/mail.go b/server/adminserver/api/v1/system/mail.go index d4c16d76..dc9cb868 100644 --- a/server/adminserver/api/v1/system/mail.go +++ b/server/adminserver/api/v1/system/mail.go @@ -15,8 +15,29 @@ type MailApi struct { } func (this *MailApi) ListMail(c *gin.Context) { - mails := []system.Mail{} - f5.GetApp().GetOrmDb(constant.MAIL_DB).Find(&mails) + var pageSize int32 = 100 + var cursor int64 = 0 + orderBy := "" + sql := "SELECT * FROM t_mail" + subFilters := []f5.DbQueryFilter{} + mails := []*system.Mail{} + f5.GetGoStyleDb().StreamPageQuery( + constant.MAIL_DB, + pageSize, + cursor, + sql, + []string{ + }, + f5.GetDbFilter().Comp(subFilters...), + orderBy, + func (err error, pagination *f5.StreamPagination) { + //rspObj.Page.FillPage(pagination) + }, + func (ds *f5.DataSet) { + p := new(system.Mail) + f5.UnmarshalModel(ds, p) + q5.AppendSlice(&mails, p) + }) c.JSON(http.StatusOK, gin.H{ "code": 0, "message": "", diff --git a/third_party/f5 b/third_party/f5 index cf0959d4..26d8a019 160000 --- a/third_party/f5 +++ b/third_party/f5 @@ -1 +1 @@ -Subproject commit cf0959d4bd0cee6e8cad378defe82fd478851368 +Subproject commit 26d8a01994efda115ee81d570075f00ebd05eb21