package hall

import (
	"server/call"
	"server/common"
	"server/config"
	"server/db"
	edb "server/db/es"
	mdb "server/db/mysql"
	rdb "server/db/redis"
	"server/natsClient"
	"server/pb"
	"strconv"
	"time"

	"github.com/liangdas/mqant/conf"
	"github.com/liangdas/mqant/log"
	"github.com/liangdas/mqant/module"
	basemodule "github.com/liangdas/mqant/module/base"
	"github.com/liangdas/mqant/server"
)

type Hall struct {
	basemodule.BaseModule
}

var Module = func() module.Module {
	this := new(Hall)
	return this
}

func (h *Hall) GetType() string {
	//很关键,需要与配置文件中的Module配置对应
	return "hall"
}
func (h *Hall) Version() string {
	//可以在监控时了解代码版本
	return "1.0.0"
}

func (h *Hall) OnInit(app module.App, settings *conf.ModuleSettings) {
	h.BaseModule.OnInit(h, app, settings,
		server.RegisterInterval(5*time.Second),
		server.RegisterTTL(10*time.Second),
	)
	db.InitDB(&mdb.MysqlClient{}, &rdb.RedisClient{}, &edb.EsClient{})

	log.Info("[%v]module init finish, config:%+v", h.GetType(), config.GetConfig().Hall)

	// 初始化调用
	call.NewCaller(h)

	//LOGIN
	h.GetServer().RegisterGO("/"+strconv.Itoa(int(pb.ServerGateReq_GateLoginReq)), h.login)
	//LOGOUT
	//h.GetServer().RegisterGO("/"+pb.ServerGatewayCmd_name[int32(pb.ServerGatewayCmd_CMD_GATEWAY_LOGOUT_REQ)], h.logout)

	// 初始化订阅事件
	h.NewNatsImp(natsClient.TopicNewPlayer)
	initNats(h.App.Transport())
	if err := loadConfig(); err != nil {
		log.Error("err:%v", err)
		panic(err)
	}
	StartTimer()
}

func (h *Hall) Run(closeSig chan bool) {
	log.Info("[%v]module running", h.GetType())
	call.InitTimeWheel(closeSig)
	call.InitExecQueue()
	// 初始化在线人数上报
	call.InitOnline(GetOnline)
	call.WriteRealOnline("Total", GetRealOnline)

	// 加载配置
	if err := loadConfig(); err != nil {
		panic(err)
	}
	<-closeSig
	log.Info("[%v]module stop", h.GetType())
}

func (h *Hall) OnDestroy() {
	playerIdMap.Range(func(key, value interface{}) bool {
		p := value.(*player)
		p.session.Close()
		// 	db.Redis().Delkey(common.GetRedisKeyToken(p.token))
		return true
	})
	if err := db.Mysql().C().Model(&common.PlayerDBInfo{}).Where("online = 1").UpdateColumn("online", 2).Error; err != nil {
		log.Error("err:%v", err)
	}
	//一定别忘了继承
	h.BaseModule.OnDestroy()
	log.Info("[%v]module destroy", h.GetType())
}