4

src/server/game/game_type.go

@@ -119,7 +119,6 @@ func init() {
 	gob.Register(&VarUserData{})
 	gob.Register(&ActivityInfo{})
 	gob.Register(&ChargeExtra{})
-	gob.Register(GameResult{})
 	gob.Register(CatnipMsg{})
 	gob.Register(&CatnipLock{})
 	gob.Register(CRank{})

src/server/game/message_mgr.go

@@ -65,6 +65,7 @@ func (m *MessageMgr) MessageMgrInit() {
 		PlayerList:  make(map[int64]int),
 	}
 	gob.Register(msg.VarData{})
+	gob.Register(GameResult{})
 	// 注册处理函数
 	m.init()
 	m.handler = make(map[int]MessageHandlerFunc)
@@ -183,14 +184,14 @@ func PlayerLogoutHandler(data *msg.Msg) (interface{}, error) {
 
 func ComsumerMsgHandler(data *msg.Msg) (interface{}, error) {
 	messageMgrData := getMessageData()
-	Message, ok := messageMgrData.MessageList[int64(data.From)]
+	Message, ok := messageMgrData.MessageList[int64(data.To)]
 	if !ok {
 		return nil, nil
 	}
 	Message.mu.Lock()
 	defer Message.mu.Unlock()
 	for i, msgItem := range Message.Messages {
-		if msgItem.Id == data.Id {
+		if msgItem.UniKey == data.UniKey {
 			// 删除消息
 			Message.Messages = append(Message.Messages[:i], Message.Messages[i+1:]...)
 			log.Debug("[Middleware] Comsume message success type: %d, player id: %v", msgItem.Type, msgItem.From)

src/server/game/var_mgr.go

@@ -37,6 +37,7 @@ const (
 
 func (f *VarMgr) Init() {
 	gob.Register(&VarGoldCard{})
+	gob.Register(&VarExpireData{})
 	f.key = VAR_MGR_KEY
 	f.data = &VarData{
 		NewVar:    map[string]*VarExpireData{},