From 203c1460495ce15188f56fbc28052894188f5c92 Mon Sep 17 00:00:00 2001 From: liwei1dao Date: Fri, 8 Sep 2023 15:11:09 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- modules/robot/modulerobot_equipment.go | 29 +++++++++++++++++++++++--- modules/robot/modulerobot_item.go | 3 +++ 2 files changed, 29 insertions(+), 3 deletions(-) diff --git a/modules/robot/modulerobot_equipment.go b/modules/robot/modulerobot_equipment.go index 41ee69588..406761b03 100644 --- a/modules/robot/modulerobot_equipment.go +++ b/modules/robot/modulerobot_equipment.go @@ -46,9 +46,7 @@ func (this *ModuleRobot_Equipment) Receive(robot IRobot, stype string, message p } return } - -//机器人执行流 -func (this *ModuleRobot_Equipment) DoPipeline(robot IRobot) (err error) { +func (this *ModuleRobot_Equipment) OncePipeline(robot IRobot) (err error) { var ( errdata *pb.ErrorData ) @@ -59,6 +57,31 @@ func (this *ModuleRobot_Equipment) DoPipeline(robot IRobot) (err error) { return } +//机器人执行流 +func (this *ModuleRobot_Equipment) DoPipeline(robot IRobot) (err error) { + var ( + errdata *pb.ErrorData + equipment *pb.DB_Equipment + lv int32 = 15 + ) + + if equipment, err = this.findcanupgrade(lv); err != nil { + return + } + if _, errdata = robot.SendMessage("equipment", "upgrade", &pb.EquipmentUpgradeReq{ + EquipmentId: equipment.Id, + }); errdata != nil { + if errdata.Code == pb.ErrorCode_EquipmentLvlimitReached { + err = nil + return + } else { + err = errors.New(fmt.Sprintf("code:%d message:%s", errdata.Code, errdata.Message)) + } + return + } + return +} + //做任务 func (this *ModuleRobot_Equipment) DoTask(robot IRobot, taskconf *cfg.GameWorldTaskData, condconf *cfg.GameBuriedCondiData) (err error) { var ( diff --git a/modules/robot/modulerobot_item.go b/modules/robot/modulerobot_item.go index 63fb85e0b..1bf2a13c5 100644 --- a/modules/robot/modulerobot_item.go +++ b/modules/robot/modulerobot_item.go @@ -38,6 +38,9 @@ func (this *ModuleRobot_Item) Receive(robot IRobot, stype string, message proto. } return } +func (this *ModuleRobot_Item) OncePipeline(robot IRobot) (err error) { + return +} //机器人执行流 func (this *ModuleRobot_Item) DoPipeline(robot IRobot) (err error) {