ecs/servers/event/handler/inner_server.go

package handler

import (
	"ecs/proto"
	"ecs/servers/event/logic"
	"github.com/oylshe1314/framework/http"
	"github.com/oylshe1314/framework/util"
)

func (this *InnerHandler) ServerOperate(msg *http.Message) {
	var req = new(proto.MsgEventServerOperateReq)
	var err = msg.Read(req)
	if err != nil {
		this.logger.Error("读取消息失败, ", err)
		_ = msg.Reply(err)
		return
	}

	this.logger.Debugf("服务操作埋点, req: %s", util.ToJsonString(req))
	err = this.eventManager.LogServerEvent(&logic.ServerOperateLog{
		EventLogger: logic.EventLogger{
			AppId:   req.AppId,
			LogType: req.LogType,
			LogTime: req.LogTime,
		},
		Operate:     req.Operate,
		Version:     req.Version,
		ProgramHash: req.ProgramHash,
		DataHash:    req.DataHash,
		ConfigHash:  req.ConfigHash,
	})
	if err != nil {
		this.logger.Error("埋点执行失败, ", err)
	}
	_ = msg.Reply(err)
}

func (this *InnerHandler) ServerOnline(msg *http.Message) {
	var req = new(proto.MsgEventServerOnlineReq)
	var err = msg.Read(req)
	if err != nil {
		this.logger.Error("读取消息失败, ", err)
		_ = msg.Reply(err)
		return
	}

	this.logger.Debugf("玩家在线埋点, req: %s", util.ToJsonString(req))
	err = this.eventManager.LogServerEvent(&logic.ServerOnlineLog{
		EventLogger: logic.EventLogger{
			AppId:   req.AppId,
			LogType: req.LogType,
			LogTime: req.LogTime,
		},
		ServerId:      req.ServerId,
		Create:        req.Create,
		Online:        req.Online,
		MaxOnline:     req.MaxOnline,
		MaxOnlineTime: req.MaxOnlineTime,
	})
	if err != nil {
		this.logger.Error("埋点执行失败, ", err)
	}
	_ = msg.Reply(err)
}