package svc

import (
	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
	"code.fnuoos.com/EggPlanet/egg_models.git/src/implement"
	"code.fnuoos.com/EggPlanet/egg_system_rules.git/enum"
	zhios_order_relate_logx "code.fnuoos.com/EggPlanet/egg_system_rules.git/utils/logx"
	"fmt"
	"github.com/gomodule/redigo/redis"
	"strings"
	"xorm.io/xorm"
)

// ImageBucket is 获取域名
func ImageBucket(engine *xorm.Engine, conn redis.Conn) (string, string) {
	sysCfgDb := implement.NewSysCfgDb(engine, conn)
	defer func(sysCfgDb dao.SysCfgDao) {
		err := sysCfgDb.Close()
		if err != nil {
			zhios_order_relate_logx.Error("redis close err:" + err.Error()) // 记录错误信息
		}
	}(sysCfgDb)
	res := sysCfgDb.SysCfgFindWithDb(enum.AliyunOssBucketScheme, enum.AliyunOssDomain)
	return res[enum.AliyunOssBucketScheme], res[enum.AliyunOssDomain]
}

// ImageFormatWithBucket is 格式化成oss 域名
func ImageFormatWithBucket(scheme, domain, name string) string {
	if strings.Contains(name, "http") || name == "" {
		return name
	}
	return fmt.Sprintf("%s://%s/%s", scheme, domain, name)
}

// ImageFormatWithBucketNew is 格式化成oss 域名
func ImageFormatWithBucketNew(scheme, domain, name string) string {
	if strings.Contains(name, "http") {
		return name
	}

	name = strings.ReplaceAll(name, "{{tempHost}}", "")
	return fmt.Sprintf("%s://%s/%s", scheme, domain, name)
}

// ImageFormatWithBucketForDataInfo is 格式化成oss 域名 (只格式化内容中的 url)
func ImageFormatWithBucketForDataInfo(scheme, domain, name string) string {
	prefix := fmt.Sprintf("%s://%s/", scheme, domain)
	name = strings.ReplaceAll(name, "{{tempHost}}", prefix)
	return name
}