From 9a1bdb10c713c44a4352dc44ec1e7153be0e9885 Mon Sep 17 00:00:00 2001 From: sk <123456@qq.com> Date: Fri, 20 Sep 2024 11:23:18 +0800 Subject: [PATCH] no message --- worldsrv/transact_addcoin.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) 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 {