go_dreamfactory/modules/mainline/api_challengeover.go

package mainline

import (
	"go_dreamfactory/comm"
	"go_dreamfactory/pb"

	cfg "go_dreamfactory/sys/configure/structs"
)

// 参数校验
func (this *apiComp) ChallengeOverCheck(session comm.IUserSession, req *pb.MainlineChallengeOverReq) (errdata *pb.ErrorData) {
	if req.Level == 0 {
		errdata = &pb.ErrorData{
			Code:  pb.ErrorCode_ReqParameterError,
			Title: pb.ErrorCode_ReqParameterError.ToString(),
		}
		return
	}
	return
}

// /挑战主线关卡
func (this *apiComp) ChallengeOver(session comm.IUserSession, req *pb.MainlineChallengeOverReq) (errdata *pb.ErrorData) {
	var (
		conf     *cfg.GameMainStageData
		info     *pb.DBMainline
		aeward   []*pb.UserAssets = make([]*pb.UserAssets, 0)
		isWin    bool
		first    bool              // 判断是否是首通
		star     int32             // 评星
		tasks    []*pb.BuriedParam = make([]*pb.BuriedParam, 0)
		err      error
		consumPs int32
		userExp  int32
	)
	if errdata = this.ChallengeOverCheck(session, req); errdata != nil {
		return // 参数校验失败直接返回
	}
	if conf, err = this.module.configure.GetMainStageConf(req.Level); err != nil { // 配置文件校验
		errdata = &pb.ErrorData{
			Code:    pb.ErrorCode_MainlineNotFindChapter,
			Title:   pb.ErrorCode_MainlineNotFindChapter.ToString(),
			Message: err.Error(),
		}
		return
	}

	if info, err = this.module.modelMline.getMainlineData(session.GetUserId()); err != nil {
		errdata = &pb.ErrorData{
			Code:    pb.ErrorCode_DBError,
			Title:   pb.ErrorCode_DBError.ToString(),
			Message: err.Error(),
		}
	}

	// 校验通过
	errdata, isWin = this.module.battle.CheckBattleReport(session, req.Report)
	if errdata != nil {
		return
	}
	if !isWin { // 战斗失败返还扣除的体力
		if errdata = this.module.DispenseRes(session, conf.PsConsume, true); errdata != nil { // 返还预扣体力
			return
		}
		session.SendMsg(string(this.module.GetType()), MlineChallengeOverResp, &pb.MainlineChallengeOverResp{
			Level: req.Level,
		}) // 数据推送
		return
	}
	// 评星规则
	if len(conf.Star) != len(conf.StarType) || len(conf.Star) != len(conf.StarValue) || len(conf.StarValue) != len(conf.StarType) {
		this.module.Errorf("配置错误, 参数数量不一致,StageId: %d", req.Level)
		errdata = &pb.ErrorData{
			Code:  pb.ErrorCode_ConfigNoFound,
			Title: pb.ErrorCode_ConfigNoFound.ToString(),
		}
		return
	}

	var szStar []int32
	szStar = append(szStar, 1<<0)
	szStar = append(szStar, 1<<1)
	szStar = append(szStar, 1<<2)
	for i, v := range conf.StarType {
		if v == comm.MainStarType1 {
			star ^= szStar[i]
		} else if v == comm.MainStarType2 {
			if req.Report.Death <= conf.StarValue[i] {
				star ^= szStar[i]
			}
		} else if v == comm.MainStarType3 {
			if req.Report.Round <= conf.StarValue[i] {
				star ^= szStar[i]
			}
		}
	}

	// 判断是不是首通
	if _, ok := info.Level[req.Level]; !ok {
		first = true
		info.Level[req.Level] = star
	}

	info.Lastlevel = req.Level
	if first { // 发奖
		if errdata = this.module.DispenseRes(session, conf.Firstaward, true); errdata != nil {
			this.module.Debugf("Mline first DispenseRes err:+%v", conf.Firstaward)
		}
		for _, v := range conf.Firstaward {
			aeward = append(aeward, &pb.UserAssets{
				A: v.A,
				T: v.T,
				N: v.N,
			})
		}
	} else {
		if errdata = this.module.DispenseRes(session, conf.Commonaward, true); errdata != nil {
			this.module.Debugf("Mline Commonaward DispenseRes err:+%v", conf.Commonaward)
		}
		for _, v := range conf.Commonaward {
			aeward = append(aeward, &pb.UserAssets{
				A: v.A,
				T: v.T,
				N: v.N,
			})
		}
	}
	user := this.module.ModuleUser.GetUser(session.GetUserId())
	if lotteryward := this.module.ModuleTools.GetGroupDataByLottery(conf.Lotteryward, user.Vip, user.Lv); len(lotteryward) > 0 {
		if errdata = this.module.DispenseRes(session, lotteryward, true); errdata != nil {
			this.module.Debugf("Mline lotteryward DispenseRes err:+%v", lotteryward)
		}
		for _, v := range lotteryward {
			aeward = append(aeward, &pb.UserAssets{
				A: v.A,
				T: v.T,
				N: v.N,
			})
		}
	}

	// 加英雄经验
	if conf.HeroExp > 0 {
		if req.Report != nil && req.Report.Info != nil && len(req.Report.Info.Redflist) > 0 {
			for _, v := range req.Report.Info.Redflist[0].Team {
				if !v.Ishelp { // 助战英雄不加经验
					this.module.ModuleHero.AddHeroExp(session, v.Oid, conf.HeroExp)
				}
			}
		}
	}
	userExp, _ = this.module.ModuleUser.ConsumePsAddExp(session, consumPs)
	session.SendMsg(string(this.module.GetType()), MlineChallengeOverResp, &pb.MainlineChallengeOverResp{
		Level:   req.Level,
		Star:    star,
		HeroExp: conf.HeroExp,
		UserExp: userExp,
	}) // 数据推送

	// // 校验功能开启
	// module, err2 := this.module.service.GetModule(comm.ModuleSys)
	// if err2 == nil {
	// 	if isys, ok := module.(comm.ISys); ok {
	// 		isys.CheckLvUpCond(session, req.Level) // 校验新功能是否开启
	// 	}
	// }
	// 主线任务统计 Rtype60
	tasks = append(tasks, comm.GetBuriedParam(comm.Rtype60, 1))
	tasks = append(tasks, comm.GetBuriedParam(comm.Rtype61, 1, int32(req.Level)))
	// var (
	// 	ChapterStar int32
	// 	allStar     int32
	// )

	// tasks = append(tasks, comm.GetBuriedParam(comm.Rtype158, ChapterStar, curChapter.ChapterId, curChapter.CType))
	// for _, v2 := range list {
	// 	for _, v1 := range v2.Star {
	// 		for _, v := range szStar {
	// 			if v1&v == v {
	// 				allStar++
	// 			}
	// 		}
	// 	}
	// }
	// this.module.ModuleRtask.SendToRtask(session, comm.Rtype160, allStar)
	// tasks = append(tasks, comm.GetBuriedParam(comm.Rtype160, allStar, conf.Chapterid))
	go this.module.ModuleBuried.TriggerBuried(session.Clone(), tasks...)
	return
}