bl/logic/controller/getserver.go

package controller

import (
	"blazing/common/rpc"
	"blazing/common/socket/errorcode"
	"blazing/logic/service/user"

	"golang.org/x/sync/singleflight"

	"github.com/panjf2000/gnet/v2"
)

var sg singleflight.Group

var ServerList []rpc.ServerInfo

func fetchData() (any, error) {
	ServerList = rpc.GetServerInfoList() //todo 待修改增加缓存
	return ServerList, nil
}

// 处理命令: 105
func (h *Controller) COMMEND_ONLINE(data *user.SidInfo, c gnet.Conn) (result *rpc.CommendSvrInfo, err errorcode.ErrorCode) { //这个时候player应该是空的
	result = rpc.NewInInfo()

	if data.Head.UserID < 100000 {
		result.IsVip = 1
	}
	v, _, _ := sg.Do("GetServerInfoList", fetchData)

	result.ServerList = v.([]rpc.ServerInfo) //todo 待修改增加缓存

	return

	//return //TODO 这里待实现改成接口调用Ret方法
}