猜颜色

This commit is contained in:
liwei1dao 2023-10-19 18:38:23 +08:00
parent 2d36ac69a6
commit daffb7d975
2 changed files with 24 additions and 4 deletions

View File

@ -28,13 +28,14 @@ func (this *apiComp) Accept(session comm.IUserSession, req *pb.DColorAcceptReq)
redRecord *pb.DBDColorQiecuoRecord redRecord *pb.DBDColorQiecuoRecord
blueRecord *pb.DBDColorQiecuoRecord blueRecord *pb.DBDColorQiecuoRecord
room *Room room *Room
sessions []comm.IUserSession
keep bool keep bool
) )
if errdata = this.AcceptCheck(session, req); errdata != nil { if errdata = this.AcceptCheck(session, req); errdata != nil {
return return
} }
sessions = append(sessions, session.Clone())
//校验切磋请求是否超时 //校验切磋请求是否超时
if redRecord, err = this.module.modelQiecuo.queryQiecuo(req.Uid); err != nil { if redRecord, err = this.module.modelQiecuo.queryQiecuo(req.Uid); err != nil {
errdata = &pb.ErrorData{ errdata = &pb.ErrorData{
@ -80,6 +81,17 @@ func (this *apiComp) Accept(session comm.IUserSession, req *pb.DColorAcceptReq)
return return
} }
if redsession, ok := this.module.GetUserSession(req.Uid); !ok {
errdata = &pb.ErrorData{
Code: pb.ErrorCode_BattleUserOff,
Title: pb.ErrorCode_BattleUserOff.ToString(),
Message: "req.uid is Off!",
}
return
} else {
sessions = append(sessions, redsession)
}
//发起者 red //发起者 red
red, err := this.module.ModuleUser.GetUser(req.Uid) red, err := this.module.ModuleUser.GetUser(req.Uid)
if err != nil { if err != nil {
@ -123,7 +135,7 @@ func (this *apiComp) Accept(session comm.IUserSession, req *pb.DColorAcceptReq)
Blue: &pb.DBDColorRoomPlayer{ Blue: &pb.DBDColorRoomPlayer{
Info: comm.GetUserBaseInfo(blue), Info: comm.GetUserBaseInfo(blue),
}, },
}); err != nil { }, sessions); err != nil {
return return
} }

View File

@ -2,6 +2,7 @@ package dcolor
import ( import (
"fmt" "fmt"
"go_dreamfactory/comm"
"go_dreamfactory/lego/core" "go_dreamfactory/lego/core"
"go_dreamfactory/lego/core/cbase" "go_dreamfactory/lego/core/cbase"
"go_dreamfactory/pb" "go_dreamfactory/pb"
@ -35,7 +36,14 @@ func (this *roomsComp) queryRoom(rid string) (room *Room, err error) {
return return
} }
func (this *roomsComp) newRoom(data *pb.DBDColorRoom) (room *Room, err error) { func (this *roomsComp) newRoom(data *pb.DBDColorRoom, session []comm.IUserSession) (room *Room, err error) {
room = &Room{
module: this.module,
data: data,
sessions: session,
}
this.lock.Lock()
this.rooms[data.Rid] = room
this.lock.Unlock()
return return
} }