diff --git a/worldsrv/transact_addcoin.go b/worldsrv/transact_addcoin.go index c67f6d4..3c18d5e 100644 --- a/worldsrv/transact_addcoin.go +++ b/worldsrv/transact_addcoin.go @@ -3,17 +3,18 @@ package main import ( "time" - "mongo.games.com/game/common" "mongo.games.com/goserver/core" "mongo.games.com/goserver/core/logger" "mongo.games.com/goserver/core/transact" "mongo.games.com/goserver/srvlib" + + "mongo.games.com/game/common" ) var TransAddCoinTimeOut = time.Second * 30 const ( - TRANSACT_ADDCOIN_CTX = iota + TransactAddCoinCTX = iota ) type AsyncAddCoinTransactContext struct { @@ -50,7 +51,7 @@ func (this *AddCoinTransactHandler) OnExcute(tNode *transact.TransNode, ud inter Tct: transact.TransactCommitPolicy_TwoPhase, } - tNode.TransEnv.SetField(TRANSACT_ADDCOIN_CTX, ud) + tNode.TransEnv.SetField(TransactAddCoinCTX, ud) tNode.StartChildTrans(tnp, pack, TransAddCoinTimeOut) } } @@ -60,7 +61,7 @@ func (this *AddCoinTransactHandler) OnExcute(tNode *transact.TransNode, ud inter func (this *AddCoinTransactHandler) OnCommit(tNode *transact.TransNode) transact.TransExeResult { logger.Logger.Trace("AddCoinTransactHandler.OnCommit ") - ud := tNode.TransEnv.GetField(TRANSACT_ADDCOIN_CTX) + ud := tNode.TransEnv.GetField(TransactAddCoinCTX) if ctx, ok := ud.(*AsyncAddCoinTransactContext); ok { p := PlayerMgrSington.GetPlayerBySnId(ctx.p.SnId) //重新获得p if p != nil { @@ -73,7 +74,7 @@ func (this *AddCoinTransactHandler) OnCommit(tNode *transact.TransNode) transact func (this *AddCoinTransactHandler) OnRollBack(tNode *transact.TransNode) transact.TransExeResult { logger.Logger.Trace("AddCoinTransactHandler.OnRollBack ") - ud := tNode.TransEnv.GetField(TRANSACT_ADDCOIN_CTX) + ud := tNode.TransEnv.GetField(TransactAddCoinCTX) if ctx, ok := ud.(*AsyncAddCoinTransactContext); ok { p := PlayerMgrSington.GetPlayerBySnId(ctx.p.SnId) //重新获得p if p != nil {