package entertainment import ( "fmt" "go_dreamfactory/comm" "go_dreamfactory/pb" cfg "go_dreamfactory/sys/configure/structs" ) //参数校验 func (this *apiComp) CreateRoomCheck(session comm.IUserSession, req *pb.EntertainCreateRoomReq) (errdata *pb.ErrorData) { if req.Idcard == "" { errdata = &pb.ErrorData{ Code: pb.ErrorCode_ReqParameterError, Title: pb.ErrorCode_ReqParameterError.ToString(), } } return } // 房主创建房间 func (this *apiComp) CreateRoom(session comm.IUserSession, req *pb.EntertainCreateRoomReq) (errdata *pb.ErrorData) { var ( err error conf *cfg.GameConsumeHeroData user *pb.DBUser room *Room ) if errdata = this.CreateRoomCheck(session, req); err != nil { return } if conf, err = this.module.configure.GetGameConsumeHero(req.Idcard); err != nil { errdata = &pb.ErrorData{ Code: pb.ErrorCode_ConfigNoFound, Title: pb.ErrorCode_ConfigNoFound.ToString(), Message: err.Error(), } return } if conf.Type != 1 { // 校验数量够不够 if list, err := this.module.model.getEntertainmList(session.GetUserId()); err != nil { errdata = &pb.ErrorData{ Code: pb.ErrorCode_DBError, Title: pb.ErrorCode_DBError.ToString(), Message: err.Error(), } return } else { if list.Card[req.Idcard] <= 0 { // 需要购买 if errdata = this.module.ConsumeRes(session, conf.Consume, true); errdata != nil { return } go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { this.module.WriteUserLog(session.GetUserId(), comm.GMResDelType, "EntertainCreateRoomReq", conf.Consume) }) list.Card[req.Idcard] += 1 this.module.model.modifyEntertainmList(session.GetUserId(), map[string]interface{}{ "card": list.Card, }) } } } user, err = this.module.ModuleUser.GetUser(session.GetUserId()) if err != nil { return } p1 := &pb.PlayerData{ Userinfo: comm.GetUserBaseInfo(user), Cardid: req.Idcard, Consumeexp: user.Consumeexp, } if room, err = this.module.gameMgr.CreateMasterRoom(p1); err != nil { errdata = &pb.ErrorData{ Code: pb.ErrorCode_EntertainCreateFailed, Title: pb.ErrorCode_EntertainCreateFailed.ToString(), Message: err.Error(), } return } session.SendMsg(string(this.module.GetType()), "createroom", &pb.EntertainCreateRoomResp{ Roomid: room.Id, Servepath: fmt.Sprintf("%s/%s", this.module.service.GetType(), this.module.service.GetId()), }) return }