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

package model

import (
	"rocommon"
	"rocommon/service"
	"rocommon/util"
	"roserver/baseserver"
	"roserver/baseserver/model"
	"runtime/debug"
	"sync"
)

var (
	updateList []interface{}

	httpParamMutex sync.RWMutex
	HttpNodeParam  *baseserver.ServiceParam
	mailUpdateMag  *MailUpdateMag
	chatUpdateMag  *ChatUpdateMag
)

type GiftContent struct {
	ItemId    string `json:"typeId"`
	ItemCount string `json:"amount"`
}

type GiftSt struct {
	Error   int           `json:"error"`
	Msg     string        `json:"msg"`
	Content []GiftContent `json:"content"`
}

type WebGMUpdate struct {
	rocommon.UpdateModule //eventqueue.go
}

func (this *WebGMUpdate) Init() {

	mailUpdateMag = newMailUpdateMag()
	chatUpdateMag = newChatUpdateMag()
	updateList = append(updateList, mailUpdateMag)
	updateList = append(updateList, chatUpdateMag)
}

func (this *WebGMUpdate) Update(ms uint64) {
	//对管理器进行更新操作
	for _, data := range updateList {
		data.(rocommon.UpdateLogic).Update(ms)
	}
}

func GetMailUpdateMag() *MailUpdateMag {
	return mailUpdateMag
}
func GetChatUpdateMag() *ChatUpdateMag {
	return chatUpdateMag
}

func GetHttpNodeParam() baseserver.ServiceParam {
	httpParamMutex.RLock()
	defer httpParamMutex.RUnlock()

	return *HttpNodeParam
}
func SetHttpNodeParam(param *baseserver.ServiceParam) {
	httpParamMutex.Lock()
	defer httpParamMutex.Unlock()

	HttpNodeParam = param
}

func ConfigInit() {
	defer func() {
		if err := recover(); err != nil {
			util.InfoF("Stack---::%v\n%s\n", err, string(debug.Stack()))
			panic(nil)
		}
	}()

	sConfig := service.GetServiceConfig()
	model.BaseConfigInit(sConfig)

	util.InfoF("config load success!!!")
}