上传

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 (

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) {