go_dreamfactory/modules/caravan/comp_configure.go

package caravan

import (
	"go_dreamfactory/comm"
	"go_dreamfactory/lego/core"
	"go_dreamfactory/lego/sys/log"
	"go_dreamfactory/modules"
	"go_dreamfactory/sys/configure"
	cfg "go_dreamfactory/sys/configure/structs"
	"sync"
)

var moduleName = "caravan"

const (
	game_caravan        = "game_caravancity.json"
	game_caravan_lv     = "game_caravanlv.json"
	game_caravan_reward = "game_caravanreward.json"
	game_caravan_thing  = "game_caravanthing.json"
	game_caravan_event  = "game_caravanevent.json"
	game_caravan_rank   = "game_caravanrank.json"
)

///配置管理基础组件
type configureComp struct {
	modules.MCompConfigure
	module *Caravan
	lock   sync.RWMutex
	event  map[int32][]*cfg.GameCaravanEventData
}

//组件初始化接口
func (this *configureComp) Init(service core.IService, module core.IModule, comp core.IModuleComp, options core.IModuleOptions) (err error) {
	err = this.MCompConfigure.Init(service, module, comp, options)
	this.module = module.(*Caravan)
	this.LoadConfigure(game_caravan, cfg.NewGameCaravanCity)
	this.LoadConfigure(game_caravan_lv, cfg.NewGameCaravanLv)
	this.LoadConfigure(game_caravan_reward, cfg.NewGameCaravanReward)
	this.LoadConfigure(game_caravan_thing, cfg.NewGameCaravanThing)
	this.LoadConfigure(game_caravan_event, cfg.NewGameCaravanEvent)
	this.LoadConfigure(game_caravan_rank, cfg.NewGameCaravanRank)
	configure.RegisterConfigure(game_caravan_event, cfg.NewGameCaravanRank, func() {
		this.lock.Lock()
		if v, err := this.GetConfigure(game_caravan_event); err != nil {
			this.module.Errorf("err:%v", err)
			return
		} else {
			this.event = make(map[int32][]*cfg.GameCaravanEventData, 0)
			for _, v := range v.(*cfg.GameCaravanEvent).GetDataList() {
				this.event[v.Eventgroup] = append(this.event[v.Eventgroup], v)
			}
		}
		this.lock.Unlock()
	})
	return
}

//加载多个配置文件
func (this *configureComp) LoadMultiConfigure(confs map[string]interface{}) (err error) {
	for k, v := range confs {
		err = configure.RegisterConfigure(k, v, nil)
		if err != nil {
			log.Errorf("配置文件:%s解析失败!", k)
			break
		}
	}
	return
}

//读取配置数据
func (this *configureComp) GetConfigure(name string) (v interface{}, err error) {
	return configure.GetConfigure(name)
}

// 获取列车货物信息
func (this *configureComp) GetCaravanCity(cityId int32) (data *cfg.GameCaravanCityData, err error) {
	var (
		v interface{}
	)
	if v, err = this.GetConfigure(game_caravan); err == nil {
		if configure, ok := v.(*cfg.GameCaravanCity); ok {
			if data = configure.Get(cityId); data == nil {
				err = comm.NewNotFoundConfErr(moduleName, game_caravan, cityId)
				this.module.Errorln(err)
			}
			return
		}
	}
	err = comm.NewNotFoundConfErr(moduleName, game_caravan, cityId)
	return
}

// 获取货物基本信息
func (this *configureComp) GetCaravanLv(lv int32) (data *cfg.GameCaravanLvData, err error) {
	var (
		v interface{}
	)
	if v, err = this.GetConfigure(game_caravan_lv); err == nil {
		if configure, ok := v.(*cfg.GameCaravanLv); ok {
			if data = configure.Get(lv); data == nil {
				err = comm.NewNotFoundConfErr(moduleName, game_caravan_lv, lv)
				this.module.Errorln(err)
			}
			return
		}
	}
	err = comm.NewNotFoundConfErr(moduleName, game_caravan_lv, lv)
	return
}

func (this *configureComp) GetCaravanGoods(itemId string) (data *cfg.GameCaravanThingData, err error) {
	var (
		v interface{}
	)
	if v, err = this.GetConfigure(game_caravan_thing); err == nil {
		if configure, ok := v.(*cfg.GameCaravanThing); ok {
			if data = configure.Get(itemId); data == nil {
				err = comm.NewNotFoundConfErr(moduleName, game_caravan_thing, itemId)
				this.module.Errorln(err)
			}
			return
		}
	}
	err = comm.NewNotFoundConfErr(moduleName, game_caravan_thing, itemId)
	return
}

func (this *configureComp) GetAllCaravanCity() (data []*cfg.GameCaravanCityData) {

	if v, err := this.GetConfigure(game_caravan); err == nil {
		if configure, ok := v.(*cfg.GameCaravanCity); ok {
			for _, v := range configure.GetDataList() {
				data = append(data, v)
			}
			return
		}
	} else {
		log.Errorf("get GetAllCaravanCity conf err:%v", err)
	}
	return
}
func (this *configureComp) GetAllCaravanItem() (data []*cfg.GameCaravanThingData) {

	if v, err := this.GetConfigure(game_caravan_thing); err == nil {
		if configure, ok := v.(*cfg.GameCaravanThing); ok {
			for _, v := range configure.GetDataList() {
				data = append(data, v)
			}
			return
		}
	} else {
		log.Errorf("get GetAllCaravanItem conf err:%v", err)
	}
	return
}

// 获取随机事件
func (this *configureComp) GetCaravanEventByGroup(eventgroup int32) (data []*cfg.GameCaravanEventData, err error) {
	var (
		ok bool
	)
	if data, ok = this.event[eventgroup]; !ok {
		err = comm.NewNotFoundConfErr(moduleName, game_caravan_event, eventgroup)
	}

	return
}

// 初始城市取配置表第一条数据
func (this *configureComp) GetCaravanInitCity() (initcity int32) {
	if v, err := this.GetConfigure(game_caravan); err == nil {
		if configure, ok := v.(*cfg.GameCaravanCity); ok {
			for _, v := range configure.GetDataList() {
				return v.Id
			}

		}
	} else {
		log.Errorf("get GetCaravanInitCity conf err:%v", err)
	}
	return
}

// 获取商店刷新时间
func (this *configureComp) GetCityRefreshTime() int32 {
	if v, err := this.GetConfigure(game_caravan); err == nil {
		if configure, ok := v.(*cfg.GameCaravanCity); ok {
			for _, v := range configure.GetDataList() {
				return v.Checktime
			}

		}
	} else {
		log.Errorf("get GetCaravanInitCity conf err:%v", err)
	}
	return 0
}

// 赛季结束获得奖励
func (this *configureComp) GetCaravanReward() (reward []*cfg.GameCaravanRewardData) {
	if v, err := this.GetConfigure(game_caravan_reward); err == nil {
		if configure, ok := v.(*cfg.GameCaravanReward); ok {
			reward = configure.GetDataList()
		}
	} else {
		log.Errorf("get GetCaravanInitCity conf err:%v", err)
	}
	return
}

func (this *configureComp) GetCaravanRank(index int32) (reward *cfg.GameCaravanRankData, err error) {
	var (
		v interface{}
	)
	if v, err = this.GetConfigure(game_caravan_rank); err == nil {
		if configure, ok := v.(*cfg.GameCaravanRank); ok {
			if reward = configure.Get(index); reward == nil {
				err = comm.NewNotFoundConfErr(moduleName, game_caravan_rank, index)
				this.module.Errorln(err)
			}
			return
		}
	}
	err = comm.NewNotFoundConfErr(moduleName, game_caravan_rank, index)
	return
}
func (this *configureComp) GetCaravanEventById(id int32) (data *cfg.GameCaravanEventData, err error) {
	var (
		v interface{}
	)
	if v, err = this.GetConfigure(game_caravan_event); err == nil {
		if configure, ok := v.(*cfg.GameCaravanEvent); ok {
			if data = configure.Get(id); data == nil {
				err = comm.NewNotFoundConfErr(moduleName, game_caravan_event, id)
				this.module.Errorln(err)
			}
			return
		}
	}
	err = comm.NewNotFoundConfErr(moduleName, game_caravan_event, id)
	return
}