package pvp

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

//参数校验
func (this *apiComp) IntoCheck(session comm.IUserSession, req *pb.PvpIntoReq) (code pb.ErrorCode) {
	return
}

///设置战斗阵型
func (this *apiComp) Into(session comm.IUserSession, req *pb.PvpIntoReq) (code pb.ErrorCode, data *pb.ErrorData) {
	var (
		battle *BattleItem
		resp   *pb.BattleGetInfoResp = &pb.BattleGetInfoResp{}
		cd     pb.ErrorCode
		ok     bool
	)
	if code = this.IntoCheck(session, req); code != pb.ErrorCode_Success {
		return
	}
	this.module.lock.RLock()
	battle, ok = this.module.battles[req.Battleid]
	this.module.lock.RUnlock()
	if ok {
		if cd, resp = this.module.battle.GetBattleInfo(&pb.BattleGetInfoReq{
			Battleid: req.Battleid,
		}); cd == pb.ErrorCode_Success {
			battle.lock.Lock()
			if session.GetUserId() == battle.Red.Uid {
				battle.RedOffline = false
				battle.RedSession.SetSession(session.GetIP(), session.GetSessionId(), session.GetServiecTag(), session.GetGatewayServiceId(), session.GetUserId())
			} else {
				battle.BlueOffline = false
				battle.BlueSession.SetSession(session.GetIP(), session.GetSessionId(), session.GetServiecTag(), session.GetGatewayServiceId(), session.GetUserId())
			}
			battle.lock.Unlock()
		}
	} else {
		cd = pb.ErrorCode_BattleInCmdFailed
		return
	}
	session.SendMsg(string(this.module.GetType()), "into", &pb.PvpIntoResp{Code: cd, Battleid: req.Battleid, Info: resp.Info})
	return
}