package guildgve import ( "fmt" "go_dreamfactory/comm" "go_dreamfactory/lego/sys/log" "go_dreamfactory/pb" "go_dreamfactory/sys/configure" cfg "go_dreamfactory/sys/configure/structs" "time" ) // 参数校验 func (this *apiComp) ChallengeFinishCheck(session comm.IUserSession, req *pb.GuildGveChallengeFinishReq) (errdata *pb.ErrorData) { return } // 获取工会boos战信息 func (this *apiComp) ChallengeFinish(session comm.IUserSession, req *pb.GuildGveChallengeFinishReq) (errdata *pb.ErrorData) { var ( user *pb.DBUser conf *cfg.GameGuildBossData member *pb.DBGuildMember score *cfg.GameGuildBossScoreData info *pb.DBGuildGve prop []*cfg.Gameatn award []*pb.UserAssets hp int32 ok bool err error ) if errdata = this.ChallengeFinishCheck(session, req); errdata != nil { return } if conf, err = this.module.configure.getguildbossByid(req.Boosid); err != nil { errdata = &pb.ErrorData{ Code: pb.ErrorCode_ConfigNoFound, Title: pb.ErrorCode_ConfigNoFound.ToString(), Message: err.Error(), } return } if errdata, _ = this.module.battle.CheckBattleReport(session, req.Report); errdata != nil { return } if score, err = this.module.configure.getguildbossscore(conf.Group, req.Report.Score); err != nil { errdata = &pb.ErrorData{ Code: pb.ErrorCode_ConfigNoFound, Title: pb.ErrorCode_ConfigNoFound.ToString(), Message: err.Error(), } return } if member, err = this.module.modelGuildMember.getGuildMember(req.Guildid, session.GetUserId()); err != nil { errdata = &pb.ErrorData{ Code: pb.ErrorCode_DBError, Title: pb.ErrorCode_DBError.ToString(), Message: err.Error(), } return } for _, v := range req.Report.Info.Redflist[0].Team { if v.Oid != "" { member.Useheros = append(member.Useheros, v.Oid) } } // if member.Boosticket <= 0 { // errdata = &pb.ErrorData{ // Code: pb.ErrorCode_ReqParameterError, // Title: pb.ErrorCode_ReqParameterError.ToString(), // Message: fmt.Sprintf("Boosticket is %d", member.Boosticket), // } // return // } if user, err = this.module.ModuleUser.GetUser(session.GetUserId()); err != nil { errdata = &pb.ErrorData{ Code: pb.ErrorCode_DBError, Title: pb.ErrorCode_DBError.ToString(), Message: err.Error(), } return } lock, _ := this.module.modelGuildGve.userlock(req.Guildid) err = lock.Lock() if err != nil { this.module.Error("公会战分布式锁 err!", log.Field{Key: "Unionid", Value: req.Guildid}, log.Field{Key: "err", Value: err.Error()}) return } defer lock.Unlock() if info, err = this.module.modelGuildGve.getGuildGve(req.Guildid); err != nil { errdata = &pb.ErrorData{ Code: pb.ErrorCode_DBError, Title: pb.ErrorCode_DBError.ToString(), Message: err.Error(), } return } for _, v := range info.Boos { if v.Boosid == req.Boosid { if v.Hp > 0 { ok = true v.Hp -= score.Hp record := &pb.DBGveRecord{ User: &pb.DBSimpleUser{ Uid: session.GetUserId(), Nickname: user.Name, Skin: user.CurSkin, Sex: user.Gender, Lv: user.Lv, }, Formation: make([]*pb.DBSimpleHero, 0), Time: configure.Now().Unix(), FightId: req.Report.Info.Id, FightTime: req.Report.Costtime, Rating: score.Id, Harm: req.Report.Harm, } member.Record[req.Boosid] = record go this.module.modelbattlerank.updateRank(req.Boosid, req.Report.Harm, record.User.Uid) for i, v := range req.Report.Info.Redflist[0].Team { if int32(i) == req.Report.Info.Redflist[0].Leadpos && v.Oid != "" { record.CaptainHeroId = v.HeroID } if v.Oid != "" { record.Formation = append(record.Formation, &pb.DBSimpleHero{ HeroId: v.HeroID, Star: v.Star, Level: v.Lv, }) } } v.Record = append(v.Record, record) go this.module.modelGuildGve.booshpchangepush(req.Guildid, info) if v.Hp <= 0 { v.Hp = 0 info.Kills++ if info.Fire == v.Boosid { info.Fire = 0 } info.Lastkilltime = configure.Now().Unix() this.module.modelRank.updateRank(info) go this.module.modelGuildGve.booskill(req.Guildid, req.Boosid, info) } hp = v.Hp } break } } if ok { member.Boosticket-- this.module.modelGuildMember.updateGuildMember(member) user, err := this.module.ModuleUser.GetUser(session.GetUserId()) if err != nil { errdata = &pb.ErrorData{ Code: pb.ErrorCode_DBError, Title: pb.ErrorCode_DBError.ToString(), Message: err.Error(), } return } if prop = this.module.ModuleTools.GetGroupDataByLottery(score.Drop, user.Vip, user.Lv); len(prop) == 0 { errdata = &pb.ErrorData{ Code: pb.ErrorCode_ConfigNoFound, Title: pb.ErrorCode_ConfigNoFound.ToString(), Message: fmt.Sprintf("掉落组未找到:%d", score.Drop), } return } if errdata = this.module.DispenseRes(session, prop, true); errdata != nil { return } award = make([]*pb.UserAssets, 0) for _, v := range prop { award = append(award, &pb.UserAssets{ A: v.A, T: v.T, N: v.N, }) } if err = this.module.modelGuildGve.updateGuildGve(info); err != nil { errdata = &pb.ErrorData{ Code: pb.ErrorCode_DBError, Title: pb.ErrorCode_DBError.ToString(), Message: err.Error(), } return } } //写入战斗记录 go this.module.battlerecord.WrietBattleRecord(session.GetUserId(), req.Report, time.Now().Add(time.Hour*24*8).Unix()) session.SendMsg(string(this.module.GetType()), "challengefinish", &pb.GuildGveChallengeFinishResp{ Guildid: req.Guildid, Boosid: req.Boosid, Hp: hp, Efficient: ok, Award: award, Score: score.Id, Boosticket: member.Boosticket, }) go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { this.module.WriteUserLog(session.GetUserId(), comm.GMResAddType, "GuildGveChallengeFinishReq", award) }) return }