tl_server_2
/
game_sync
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

no message

This commit is contained in:
sk 2024-09-20 11:23:18 +08:00
parent 522b284dd6
commit 9a1bdb10c7
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
worldsrv/transact_addcoin.go
View File

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