server/game/game_cluster/internal/data/area_server_config.go

package data

import (
	mhayaError "github.com/mhaya/error"
	mhayaLogger "github.com/mhaya/logger"
)

type (
	AreaServerRow struct {
		ServerId   int32  `json:"serverId"`   // 游戏服id
		ServerName string `json:"serverName"` // 游戏服名称
		AreaId     int32  `json:"areaId"`     // 游戏服所属的区id
		Status     int32  `json:"status"`     // 游戏服状态
	}

	// 游戏区分组
	areaServerConfig struct {
		maps map[int32]*AreaServerRow
	}
)

// Name 根据名称读取 ./config/data/areaServerConfig.json文件
func (p *areaServerConfig) Name() string {
	return "areaServerConfig"
}

func (p *areaServerConfig) Init() {
	p.maps = make(map[int32]*AreaServerRow)
}

func (p *areaServerConfig) OnLoad(maps interface{}, _ bool) (int, error) {
	list, ok := maps.([]interface{})
	if !ok {
		return 0, mhayaError.Error("maps convert to []interface{} error.")
	}

	loadMaps := make(map[int32]*AreaServerRow)
	for index, data := range list {
		loadConfig := &AreaServerRow{}
		err := DecodeData(data, loadConfig)
		if err != nil {
			mhayaLogger.Warnf("decode error. [row = %d, %v], err = %s", index+1, loadConfig, err)
			continue
		}

		loadMaps[loadConfig.ServerId] = loadConfig
	}

	p.maps = loadMaps

	return len(list), nil
}

func (p *areaServerConfig) OnAfterLoad(_ bool) {
}

func (p *areaServerConfig) Get(pk int32) (*AreaServerRow, bool) {
	i, found := p.maps[pk]
	return i, found
}

func (p *areaServerConfig) Contain(pk int32) bool {
	_, found := p.Get(pk)
	return found
}

func (p *areaServerConfig) ListWithAreaId(areaId int32) []*AreaServerRow {
	var list []*AreaServerRow

	for _, row := range p.maps {
		if row.AreaId == areaId {
			list = append(list, row)
		}
	}

	return list
}