From 772d3d6f33075c4493ea04687990e21978b7a70c Mon Sep 17 00:00:00 2001 From: meixiongfeng <766881921@qq.com> Date: Tue, 2 Jan 2024 19:18:57 +0800 Subject: [PATCH] gm --- comm/imodule.go | 1 + modules/buried/module.go | 2 +- modules/dragon/api_train.go | 2 +- modules/gm/module.go | 14 ++++++++++++++ modules/moonlv/module.go | 7 +++++++ 5 files changed, 24 insertions(+), 2 deletions(-) diff --git a/comm/imodule.go b/comm/imodule.go index 2ed95cc0b..237be4408 100644 --- a/comm/imodule.go +++ b/comm/imodule.go @@ -707,6 +707,7 @@ type ( } IMoonlv interface { IBuriedUpdateNotify + GMCreateMoonlv(session IUserSession, lv int32) } //捉虫子 ICatchBugs interface { diff --git a/modules/buried/module.go b/modules/buried/module.go index 54a4a4488..82ee0f474 100644 --- a/modules/buried/module.go +++ b/modules/buried/module.go @@ -548,7 +548,7 @@ func (this *Buried) TriggerBuried(session comm.IUserSession, burieds ...*pb.Buri this.Error("远程触发埋点错误!", log.Field{Key: "uid", Value: session.GetUserId()}, log.Field{Key: "err", Value: err.Error()}) return } - if _, err = this.service.AcrossClusterRpcGo( + if err = this.service.AcrossClusterRpcCall( context.Background(), stag, comm.Service_Worker, diff --git a/modules/dragon/api_train.go b/modules/dragon/api_train.go index 8c00f01c5..b649bc04d 100644 --- a/modules/dragon/api_train.go +++ b/modules/dragon/api_train.go @@ -136,7 +136,7 @@ func (this *apiComp) Train(session comm.IUserSession, req *pb.DragonTrainReq) (e rsp.Reward = atno } if curType != preType { // 坐骑升阶 增加属性 - if c, err := this.module.configure.GetDragonMount(dragon.Dragonid, curType); err != nil { + if c, err := this.module.configure.GetDragonMount(dragon.Dragonid, curType); err == nil { dragon.Property = make(map[string]int32) dragon.Property["stime"] = c.Stime dragon.Property["etime"] = c.Etime diff --git a/modules/gm/module.go b/modules/gm/module.go index e4d7f3563..c2c57ffd5 100644 --- a/modules/gm/module.go +++ b/modules/gm/module.go @@ -824,6 +824,20 @@ func (this *GM) CreateCmd(session comm.IUserSession, cmd string) (errdata *pb.Er log.Field{Key: "0", Value: datas[0]}, ) + } else if len(datas) == 2 && (datas[0] == "moonlv") { // 等级 + module1, err := this.service.GetModule(comm.ModuleMoonlv) + if err != nil { + return + } + if lv, err := strconv.Atoi(datas[1]); err == nil { + module1.(comm.IMoonlv).GMCreateMoonlv(session, int32(lv)) + + this.Debug("使用bingo命令", + log.Field{Key: "uid", Value: session.GetUserId()}, + log.Field{Key: "0", Value: datas[1]}, + ) + } + } } } diff --git a/modules/moonlv/module.go b/modules/moonlv/module.go index c5a185fc5..3d8fbf264 100644 --- a/modules/moonlv/module.go +++ b/modules/moonlv/module.go @@ -113,3 +113,10 @@ func (this *Moonlv) BuriedsNotify(session comm.IUserSession, conds []*pb.ConIPro } } } + +func (this *Moonlv) GMCreateMoonlv(session comm.IUserSession, lv int32) { + if lv <= 0 { + return + } + this.modelMoonlv.modifyMoonlvList(session.GetUserId(), map[string]interface{}{"lv": lv}) +}