diff --git a/server/backtask/task/recharge.go b/server/backtask/task/recharge.go index ee34de0b..228195da 100644 --- a/server/backtask/task/recharge.go +++ b/server/backtask/task/recharge.go @@ -7,7 +7,7 @@ import ( "fmt" //"mt" //"strings" - //"jccommon" + "jccommon" ) type recharge struct { @@ -55,11 +55,29 @@ func (this *recharge) deliverGoods(ds *f5.DataSet) bool { result = false return } + idx := q5.ToInt64(ds.GetByName("idx")) status := q5.ToInt32(ds.GetByName("stauts")) if status != 0 { - result = true + result = this.markStatus(idx, jccommon.RECHARGE_ORDER_STATUS_SENT) == nil return } }) return result } + +func (this *recharge) markStatus(idx int64, status int32) error { + var resultErr error + f5.GetGoStyleDb().Update( + constant.BCEVENT_DB, + "t_recharge", + [][]string{ + {"idx", q5.ToString(idx)}, + }, + [][]string{ + {"status", q5.ToString(status)}, + }, + func (err error, lastInsertId int64, rowsAffected int64) { + resultErr = err + }) + return resultErr +} diff --git a/server/jccommon/constant.go b/server/jccommon/constant.go index 59e2e1ad..d2f5619a 100644 --- a/server/jccommon/constant.go +++ b/server/jccommon/constant.go @@ -102,6 +102,11 @@ const ( MAP_MODE_BOUNTY = 301 ) +const ( + RECHARGE_ORDER_STATUS_PENDING = 0 + RECHARGE_ORDER_STATUS_SENT =1 +) + const ( BC_CURRENCY_NAME_ETHEREUM = "Ethereum" BC_CURRENCY_NAME_USDC = "USDC"