xpggame/call/reload.go

package call

import (
	"server/common"
	"server/natsClient"
	"server/pb"

	"github.com/liangdas/mqant/log"
	"github.com/nats-io/nats.go"
)

var (
	reloadFuncs = map[int][]func(*pb.ReloadGameConfig) error{}
)

func LoadConfigs(funcs map[int][]func(*pb.ReloadGameConfig) error) error {
	if funcs == nil {
		funcs = map[int][]func(*pb.ReloadGameConfig) error{}
	}
	CommonReload(funcs)
	for _, v := range funcs {
		for _, k := range v {
			if err := k(nil); err != nil {
				log.Error("err:%v", err)
				// return err
			}
		}
	}
	reloadFuncs = funcs
	return nil
}

// LoadSomeConfigs 加载特定配置
func LoadSomeConfigs(funcs map[int][]func(*pb.ReloadGameConfig) error) error {
	for _, v := range funcs {
		for _, k := range v {
			if err := k(nil); err != nil {
				log.Error("err:%v", err)
				return err
			}
		}
	}
	reloadFuncs = funcs
	return nil
}

func InitReload(conn *nats.Conn) {
	natsClient.NewReloadNats(conn, ReloadConfig)
}

func ReloadConfig(c *pb.ReloadGameConfig) {
	log.Debug("reload %v", c.Type)
	if fs, ok := reloadFuncs[int(c.Type)]; ok {
		for _, v := range fs {
			if err := v(c); err != nil {
				log.Error("err:%v", err)
				return
			}
		}
	}
}

func CommonReload(c map[int][]func(*pb.ReloadGameConfig) error) {
	if _, ok := c[common.ReloadWhiteList]; !ok {
		c[common.ReloadWhiteList] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := InitWhite(); err != nil {
				log.Error("err:%v", err)
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadChannel]; !ok {
		c[common.ReloadChannel] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadChannels(); err != nil {
				log.Error("err:%v", err)
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadPlatform]; !ok {
		c[common.ReloadPlatform] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigPlatform(); err != nil {
				log.Error("err:%v", err)
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadNotice]; !ok {
		c[common.ReloadNotice] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigNotice(); err != nil {
				log.Error("从mysql加载公告失败, error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadBroadcast]; !ok {
		c[common.ReloadBroadcast] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigBroadcast(); err != nil {
				log.Error("从mysql加载广播失败, error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigActivity]; !ok {
		c[common.ReloadConfigActivity] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigActivity(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigPayProduct]; !ok {
		c[common.ReloadConfigPayProduct] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigPayProduct(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigPayWeight]; !ok {
		c[common.ReloadConfigPayWeight] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigPayChannels(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigWithdrawWeight]; !ok {
		c[common.ReloadConfigWithdrawWeight] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigWithdrawChannels(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigVip]; !ok {
		c[common.ReloadConfigVip] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigVIP(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigTron]; !ok {
		c[common.ReloadConfigTron] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigTron(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigWithdrawProduct]; !ok {
		c[common.ReloadConfigWithdrawProduct] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigWithdrawProduct(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigGameProvider]; !ok {
		c[common.ReloadConfigGameProvider] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadGames(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigGameList]; !ok {
		c[common.ReloadConfigGameList] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadGames(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigGameTypes]; !ok {
		c[common.ReloadConfigGameTypes] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigGameTypes(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigGameMarks]; !ok {
		c[common.ReloadConfigGameMarks] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigGameMarks(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigFirstPageGames]; !ok {
		c[common.ReloadConfigFirstPageGames] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigFirstPageGames(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigRWPer]; !ok {
		c[common.ReloadConfigRWPer] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigRWPer(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigCurrencyRateUSD]; !ok {
		c[common.ReloadConfigCurrencyRateUSD] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigCurrencyRateUSD(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigServerVersion]; !ok {
		c[common.ReloadConfigServerVersion] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadServerVersions(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigGameRoom]; !ok {
		c[common.ReloadConfigGameRoom] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigGameRooms(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigRobot]; !ok {
		c[common.ReloadConfigRobot] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigRobots(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigAppSpin]; !ok {
		c[common.ReloadConfigAppSpin] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigAppSpin(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigShare]; !ok {
		c[common.ReloadConfigShare] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigShare(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigShareSys]; !ok {
		c[common.ReloadConfigShareSys] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigShareSys(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigActivityPddSpin]; !ok {
		c[common.ReloadConfigActivityPddSpin] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigActivityPddSpin(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigActivityPdd]; !ok {
		c[common.ReloadConfigActivityPdd] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigActivityPdd(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigTask]; !ok {
		c[common.ReloadConfigTask] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigTask(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigCurrencyResource]; !ok {
		c[common.ReloadConfigCurrencyResource] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigCurrencyResource(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigFirstPay]; !ok {
		c[common.ReloadConfigFirstPay] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigFirstPay(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigActivityFreeSpin]; !ok {
		c[common.ReloadConfigActivityFreeSpin] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigActivityFreeSpin(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigActivityFirstRechargeBack]; !ok {
		c[common.ReloadConfigActivityFirstRechargeBack] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigActivityFirstRechargeBack(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigBanner]; !ok {
		c[common.ReloadConfigBanner] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigBanner(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigLuckyCode]; !ok {
		c[common.ReloadConfigLuckyCode] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigActivityLuckCode(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigActivitySign]; !ok {
		c[common.ReloadConfigActivitySign] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigActivitySign(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigActivityBreakGift]; !ok {
		c[common.ReloadConfigActivityBreakGift] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigActivityBreakGift(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigShareRobot]; !ok {
		c[common.ReloadConfigShareRobot] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigShareRobot(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigActivityWeekCard]; !ok {
		c[common.ReloadConfigActivityWeekCard] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigActivityWeekCard(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigActivitySlots]; !ok {
		c[common.ReloadConfigActivitySlots] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigActivitySlots(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigActivityLuckyShop]; !ok {
		c[common.ReloadConfigActivityLuckyShop] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigActivityLuckyShop(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigServerFlag]; !ok {
		c[common.ReloadConfigServerFlag] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigServerFlag(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigActivitySevenDayBox]; !ok {
		c[common.ReloadConfigActivitySevenDayBox] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigActivitySevenDayBox(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigTgRobot]; !ok {
		c[common.ReloadConfigTgRobot] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigTgRobot(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigBetDraw]; !ok {
		c[common.ReloadConfigBetDraw] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadBetDraw(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
	if _, ok := c[common.ReloadConfigActivityPopup]; !ok {
		c[common.ReloadConfigActivityPopup] = []func(*pb.ReloadGameConfig) error{func(rgc *pb.ReloadGameConfig) error {
			if err := LoadConfigActivityPopup(); err != nil {
				log.Error("error : [%s]", err.Error())
				return err
			}
			return nil
		}}
	}
}