上分不走消息隊列

This commit is contained in:
by 2024-09-07 10:22:55 +08:00
parent cb4b51b4aa
commit 9b5dff5f96
1 changed files with 9 additions and 8 deletions

View File

@ -71,7 +71,7 @@ func processConnMessageQueue(queue *ConnMessageQueue) {
// 移动 // 移动
func SMDollMachinePerateHandler(session *netlib.Session, packetId int, data interface{}) error { func SMDollMachinePerateHandler(session *netlib.Session, packetId int, data interface{}) error {
logger.Logger.Tracef("SMDollMachinePerateHandler %v", data) fmt.Println("SMDollMachinePerateHandler %v", data)
msg, ok := data.(*machine.SMDollMachineoPerate) msg, ok := data.(*machine.SMDollMachineoPerate)
if !ok { if !ok {
return nil return nil
@ -121,13 +121,14 @@ func SMDollMachinePerateHandler(session *netlib.Session, packetId int, data inte
Process(conn, f1, f2) Process(conn, f1, f2)
case 5: case 5:
//投币 //投币
f1 := []func(){ /* f1 := []func(){
func() { machinedoll.Coin(conn) }, func() { machinedoll.Coin(conn) },
} }
f2 := []func(){ f2 := []func(){
func() {}, func() {},
} }
Process(conn, f1, f2) Process(conn, f1, f2)*/
machinedoll.Coin(conn)
go DollMachineGrabResult(session, conn, msg.Snid, msg.GetId()) go DollMachineGrabResult(session, conn, msg.Snid, msg.GetId())
} }
return nil return nil