package handler

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

func (this *InnerHandler) ServerOperate(msg *http.Message) {
	var req = new(old.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.TableServerOnlineLog, &logic.ServerOperateLog{
		BaseLog: logic.BaseLog{
			LogType: req.LogType,
			LogTime: util.Unix(),
		},
		ServerId:    req.ServerId,
		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(old.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.TableServerOnlineLog, &logic.ServerOnlineLog{
		BaseLog: logic.BaseLog{
			LogType: req.LogType,
			LogTime: util.Unix(),
		},
		ServerId:      req.ServerId,
		Create:        req.Create,
		Online:        req.Online,
		Offline:       req.Offlines,
		MaxOnline:     req.MaxOnline,
		MaxOnlineTime: req.MaxOnlineTime,
	})
	if err != nil {
		this.logger.Error("埋点执行失败, ", err)
	}
	_ = msg.Reply(err)
}