package application

import (
	"encoding/json"
	"mayfly-go/internal/sys/domain/entity"
	"mayfly-go/internal/sys/domain/repository"
	"mayfly-go/pkg/cache"
	"mayfly-go/pkg/global"
	"mayfly-go/pkg/model"
	"mayfly-go/pkg/utils"
)

const SysConfigKeyPrefix = "sys:config:"

type Config interface {
	GetPageList(condition *entity.Config, pageParam *model.PageParam, toEntity interface{}, orderBy ...string) *model.PageResult

	Save(config *entity.Config)

	// 获取指定key的配置信息, 不会返回nil, 若不存在则值都默认值即空字符串
	GetConfig(key string) *entity.Config
}

func newConfigApp(configRepo repository.Config) Config {
	return &configAppImpl{
		configRepo: configRepo,
	}
}

type configAppImpl struct {
	configRepo repository.Config
}

func (a *configAppImpl) GetPageList(condition *entity.Config, pageParam *model.PageParam, toEntity interface{}, orderBy ...string) *model.PageResult {
	return a.configRepo.GetPageList(condition, pageParam, toEntity)
}

func (a *configAppImpl) Save(config *entity.Config) {
	if config.Id == 0 {
		a.configRepo.Insert(config)
	} else {
		a.configRepo.Update(config)
	}
	cache.Del(SysConfigKeyPrefix + config.Key)
}

func (a *configAppImpl) GetConfig(key string) *entity.Config {
	config := &entity.Config{Key: key}
	// 优先从缓存中获取
	cacheStr := cache.GetStr(SysConfigKeyPrefix + key)
	if cacheStr != "" {
		json.Unmarshal([]byte(cacheStr), &config)
		return config
	}

	if err := a.configRepo.GetConfig(config, "Id", "Key", "Value"); err != nil {
		global.Log.Warnf("不存在key = [%s] 的系统配置", key)
	} else {
		cache.SetStr(SysConfigKeyPrefix+key, utils.ToJsonStr(config))
	}
	return config
}