go_dreamfactory/modules/hero/api_strengthenUplv.go

package hero

import (
	"go_dreamfactory/comm"
	"go_dreamfactory/pb"
	cfg "go_dreamfactory/sys/configure/structs"

	"google.golang.org/protobuf/proto"
)

//参数校验
func (this *apiComp) StrengthenUplvCheck(session comm.IUserSession, req *pb.HeroStrengthenUplvReq) (code pb.ErrorCode) {
	if req.HeroObjID == "" || len(req.ExpCards) == 0 {
		code = pb.ErrorCode_ReqParameterError
		return
	}
	for k, v := range req.ExpCards {
		if v <= 0 || k == "" {
			code = pb.ErrorCode_ReqParameterError
			return
		}
	}
	return
}

/// 英雄升级
func (this *apiComp) StrengthenUplv(session comm.IUserSession, req *pb.HeroStrengthenUplvReq) (code pb.ErrorCode, data proto.Message) {

	var (
		curLv     int32
		curExp    int32      // 当前英雄的经验
		addExp    int32      // 需要增加的经验
		costGold  int32      // 需要消耗的资源
		_hero     *pb.DBHero // 目标英雄
		_expHero  *pb.DBHero // 消耗英雄
		minAddExp int32
		_costHero []*pb.DBHero // 删除的英雄
		bLvUp     bool         // 是否升级
	)

	code = this.StrengthenUplvCheck(session, req) // check
	if code != pb.ErrorCode_Success {
		return
	}
	_hero, code = this.module.GetHero(session.GetUserId(), req.HeroObjID)
	if code != pb.ErrorCode_Success {
		return
	}
	// 只有英雄卡才能升级
	if _hero.CardType != comm.CardTypeHero {
		code = pb.ErrorCode_HeroTypeErr
		return
	}
	for k, v := range req.ExpCards {
		_expHero, code = this.module.GetHero(session.GetUserId(), k) // 校验需要消耗经验卡牌的对象是否存在
		if code != pb.ErrorCode_Success {
			return
		}
		if _expHero.Block { // 锁定的卡不允许被消耗
			code = pb.ErrorCode_HeroIsLock
			return
		}

		if v > _expHero.SameCount { // 校验数量
			code = pb.ErrorCode_HeroNoEnough
			return
		}
		// 查询 本次消耗会获得多少经验
		expConf := this.module.configure.GetHeroExp(_expHero.HeroID)
		if expConf != nil {
			addExp += expConf.Heroexp * v
		}
		costGold = expConf.Needgold * v // 需要消耗的金币
		if _expHero.SameCount < v {     // 消耗经验卡片数量不足
			code = pb.ErrorCode_HeroNoEnough
			return
		}
		if minAddExp == 0 {
			minAddExp = expConf.Heroexp //初始化
		} else if minAddExp > expConf.Heroexp {
			minAddExp = expConf.Heroexp // 取出最小的经验卡
		}
	}
	if addExp == 0 {
		code = pb.ErrorCode_HeroExpTypeErr
		return
	}
	curLv = _hero.Lv
	curExp = _hero.Exp // 当前英雄的经验

	// 校验当前能不能升级

	if _hero.Lv >= _hero.Star*comm.HeroStarLvRatio { // 达到最大等级
		code = pb.ErrorCode_HeroMaxLv
		return
	}

	var maxLv int32 // 校验等级达到上限
	maxLv = _hero.Star * comm.HeroStarLvRatio
	_data := this.module.configure.GetHeroLv(curLv)
	if _data != nil {
		if maxLv <= _hero.Lv && curExp >= _data.Heroexp[0].N { // 加经验之前校验是否达到最大等级
			code = pb.ErrorCode_HeroMaxLv
			return
		}
		curExp += addExp // 先把经验加上
		for {
			if maxLv <= _hero.Lv && curExp >= _data.Heroexp[0].N { // 设置最大经验和等级
				// 超过的经验值
				leftExp := curExp - _data.Heroexp[0].N
				this.module.Debugf("经验溢出%d", leftExp)
				if leftExp >= minAddExp {
					code = pb.ErrorCode_HeroAddMaxExp
					return
				}
				curLv = maxLv
				curExp = _data.Heroexp[0].N
				break
			}
			if _data.Heroexp[0].N > curExp { // 经验不够升级则不能执行升级操作
				break
			} else { // 升级操作
				curExp -= _data.Heroexp[0].N
				curLv += 1 // 经验够了 那么等级+1
				_data = this.module.configure.GetHeroLv(curLv)
				if _data == nil { // 等级加失败了 回到原来的等级
					curLv -= 1
					break
				}
				bLvUp = true
			}
		}
	} else {
		code = pb.ErrorCode_HeroNoExist
		return
	}
	if _hero == nil {
		code = pb.ErrorCode_HeroNoExist
		return
	}

	this.module.Debugf("升级后当前等级: %d,经验: %d,需要消耗的金币: %d,增加的经验: %d", curLv, curExp, costGold, addExp)
	// 消耗金币
	res := make([]*cfg.Game_atn, 0)
	_d := &cfg.Game_atn{
		A: "attr",
		T: "gold",
		N: costGold,
	}
	res = append(res, _d)
	code = this.module.ConsumeRes(session, res, true)
	if code != pb.ErrorCode_Success {
		return
	}

	// 执行升级逻辑
	code = this.module.AddCardExp(session.GetUserId(), req.HeroObjID, addExp) // 加经验
	if code != pb.ErrorCode_Success {
		// 升级失败资源回退
		code = this.module.DispenseRes(session, res, true)
		return
	}

	// 删除经验卡
	for k, v := range req.ExpCards {
		costHero, err1 := this.module.modelHero.consumeHeroCard(session.GetUserId(), k, v)
		if err1 != nil {
			code = pb.ErrorCode_HeroNoEnough
			this.module.Errorf("delete err failed err:%T!", err1)
			return
		}
		_costHero = append(_costHero, costHero)
	}
	session.SendMsg(string(this.module.GetType()), "change", &pb.HeroChangePush{List: _costHero})
	m, err1 := this.module.modelHero.PushHeroProperty(session, _hero.Id) // 推送属性变化
	if err1 != nil {
		this.module.Errorf("PushHeroProperty err!")
	}
	_hero.Lv = curLv
	_hero.Exp = curExp
	_hero.Property = m
	session.SendMsg(string(this.module.GetType()), "change", &pb.HeroChangePush{List: []*pb.DBHero{_hero}})
	session.SendMsg(string(this.module.GetType()), StrengthenUplv, &pb.HeroStrengthenUplvResp{Hero: _hero})
	if bLvUp { // 升级了 统计任务
		this.module.ModuleTask.SendToTask(session.GetUserId(), comm.TaskTypeGetHero, &pb.TaskParam{First: _hero.Lv})
	}

	return
}