diff --git a/server/backtask/service/spec_transfer.go b/server/backtask/service/spec_transfer.go index 938f9d0b..3841526d 100644 --- a/server/backtask/service/spec_transfer.go +++ b/server/backtask/service/spec_transfer.go @@ -110,6 +110,59 @@ func ReturnGoldBullion(accountId string, netId int32, tokenId string) bool { return false } + { + var dbErr error + returned := false + f5.GetGoStyleDb().OrmSelectOne( + constant.GAME_DB, + "t_gold_bullion_return", + [][]string { + {"net_id", q5.ToString(netId)}, + {"token_id", tokenId}, + }, + func (err error, ds *f5.DataSet) { + dbErr = err + if err != nil { + return + } + if ds.Next() { + returned = true + } + }) + if dbErr != nil { + return false + } + if returned { + return true + } + } + { + var dbErr error + nowTime := f5.GetApp().GetRealSeconds() + f5.GetGoStyleDb().Upsert( + constant.GAME_DB, + "t_gold_bullion_return", + [][]string { + {"token_id", tokenId}, + }, + [][]string {}, + [][]string { + {"account_id", accountId}, + {"token_id", tokenId}, + {"net_id", q5.ToString(netId)}, + {"item_id", q5.ToString(itemId)}, + {"gold", q5.ToString(goldNum)}, + {"createtime", q5.ToString(nowTime)}, + {"modifytime", q5.ToString(nowTime)}, + }, + func (err error, lastInsertId int64, rowsAffected int64) { + dbErr = err + }) + if dbErr != nil { + return false + } + } + return true { var dbErr error nowTime := f5.GetApp().GetRealSeconds() diff --git a/server/backtask/task/gold_bullion_return.go b/server/backtask/task/gold_bullion_return.go index 217956d3..d9624eef 100644 --- a/server/backtask/task/gold_bullion_return.go +++ b/server/backtask/task/gold_bullion_return.go @@ -7,7 +7,7 @@ import ( "jccommon" "fmt" "main/constant" - //"main/service" + "main/service" ) type goldBullionReturn struct { @@ -105,6 +105,6 @@ func (this* goldBullionReturn) returnGold(ds *f5.DataSet) bool { } } + service.ReturnGoldBullion(accountId, netId, tokenId) return true - //return service.ReturnGoldBullion(accountId, netId, tokenId) }