RoServer/RO_Server_Trunk-branch_0.1.39/roserver/gmweb/model/chat_update.go

package model

import (
	"rocommon/util"
	"roserver/serverproto"
)

type ChatUpdateItemList struct {
	ChatList []ChatUpdateItem
}
type ChatUpdateItem struct {
	UserId   string
	RoleUid  uint64
	RoleName string
	ZoneId   int32
	Content  []string
}

type ChatUpdateMag struct {
	chatContentList map[uint64]*ChatUpdateItem
	updateTimer     util.ServerTimer //更新定时器
}

func newChatUpdateMag() *ChatUpdateMag {
	mag := &ChatUpdateMag{
		chatContentList: map[uint64]*ChatUpdateItem{},
	}
	mag.updateTimer = util.NewDurationTimer(util.GetCurrentTime(), 1000)
	return mag
}

func (this *ChatUpdateMag) Update(ms uint64) {
	if this.updateTimer.IsStart() && this.updateTimer.IsExpired(ms) {
		if len(this.chatContentList) <= 0 {
			return
		}
		//send to gmweb
		//urlPath := "/chat"
		var tmpChatList ChatUpdateItemList
		for key, val := range this.chatContentList {
			tmpChatList.ChatList = append(tmpChatList.ChatList, *val)
			delete(this.chatContentList, key)
		}

		//go func() {
		//	defer func() {
		//		//打印奔溃信息
		//		if err := recover(); err != nil {
		//			util.InfoF("onError data=%v \n%s\n", err, string(debug.Stack()))
		//		}
		//	}()
		//	tmpRequest := &rocommon.HTTPRequest{}
		//	tmpRequest.ReqCodecName = "httpjson"
		//	tmpRequest.ReqMsg = tmpChatList
		//
		//	parm := GetHttpNodeParam()
		//	httpNode := baseserver.CreateHttpConnector(parm)
		//	err := httpNode.(rocommon.HTTPConnector).Request("POST", urlPath, tmpRequest)
		//	if err != nil {
		//		util.ErrorF("http Request err=%v", err)
		//		return
		//	}
		//}()
	}
}

func (this *ChatUpdateMag) AddChatMsg(msg *serverproto.SSWebGMChatMsgNtf) {
	addItem, ok := this.chatContentList[msg.Uid]
	if !ok {
		addItem = &ChatUpdateItem{
			RoleUid:  msg.Uid,
			RoleName: msg.ChatSelfName,
			ZoneId:   msg.SelectZoneId,
			Content:  []string{msg.Content.Message},
		}
		this.chatContentList[msg.Uid] = addItem
	} else {
		addItem.Content = append(addItem.Content, msg.Content.Message)
	}
}