调用mcp-测试通过-搜索店铺档案表

config/config.go

@@ -23,6 +23,7 @@ type IConfig interface {
 	// 多数据库支持
 	GetDatabaseConfig() *subconfigs.DatabaseConfig               // 获取默认数据库（向后兼容）
 	GetDbsConfig(name string) (*subconfigs.DatabaseConfig, bool) // 获取指定数据库连接
+	GetDbsConfigs() *subconfigs.DbsConfig                        //获取所有配置
 
 	//服务支持
 	GetServiceConfig() *subconfigs.ServiceConfig       //获取默认微服务配置
@@ -70,6 +71,13 @@ func (c *Config) GetDatabaseConfig() *subconfigs.DatabaseConfig {
 	return nil
 }
 
+func (c *Config) GetDbsConfigs() *subconfigs.DbsConfig {
+	if config := core.GetRegisteredConfig("dbs"); config != nil {
+		return config.(*subconfigs.DbsConfig)
+	}
+	return nil
+}
+
 // GetDbsConfig 按名称获取数据库配置
 func (c *Config) GetDbsConfig(name string) (*subconfigs.DatabaseConfig, bool) {
 	// 获取 dbs 配置
@@ -239,6 +247,14 @@ func GetDbsConfig(name string) (*subconfigs.DatabaseConfig, bool) {
 	return cfgInstance.GetDbsConfig(name)
 }
 
+// GetDbsConfigs 包级便捷函数 - 按名称获取数据库配置
+func GetDbsConfigs() *subconfigs.DbsConfig {
+	if cfgInstance == nil {
+		return nil
+	}
+	return cfgInstance.GetDbsConfigs()
+}
+
 // GetRedis 包级便捷函数 - 获取Redis配置
 func GetRedisConfig() *subconfigs.RedisConfig {
 	if cfgInstance == nil {

config/subconfigs/dbs_config.go

@@ -70,6 +70,11 @@ func (c *DbsConfig) Default() *DbConfig {
 	return nil
 }
 
+func (c *DbsConfig) GetDbsConfig() map[string]*DbConfig {
+
+	return c.Databases
+}
+
 func init() {
 	core.Register("dbs", &DbsConfig{})
 }

go.mod

@@ -34,6 +34,7 @@ require (
 	github.com/mitchellh/mapstructure v1.3.3 // indirect
 	github.com/rogpeppe/go-internal v1.14.1 // indirect
 	github.com/stretchr/testify v1.11.1 // indirect
+	github.com/traefik/yaegi v0.16.1 // indirect
 	go.opentelemetry.io/otel v1.28.0 // indirect
 	go.opentelemetry.io/otel/metric v1.28.0 // indirect
 	go.opentelemetry.io/otel/trace v1.28.0 // indirect

go.sum

@@ -134,6 +134,8 @@ github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UV
 github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
 github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
 github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
+github.com/traefik/yaegi v0.16.1 h1:f1De3DVJqIDKmnasUF6MwmWv1dSEEat0wcpXhD2On3E=
+github.com/traefik/yaegi v0.16.1/go.mod h1:4eVhbPb3LnD2VigQjhYbEJ69vDRFdT2HQNrXx8eEwUY=
 go.mongodb.org/mongo-driver v1.17.6 h1:87JUG1wZfWsr6rIz3ZmpH90rL5tea7O3IHuSwHUpsss=
 go.mongodb.org/mongo-driver v1.17.6/go.mod h1:Hy04i7O2kC4RS06ZrhPRqj/u4DTYkFDAAccj+rVKqgQ=
 go.opentelemetry.io/otel v1.28.0 h1:/SqNcYk+idO0CxKEUOtKQClMK/MimZihKYMruSMViUo=

test/test.go

@@ -2,27 +2,108 @@ package main
 
 import (
 	"fmt"
+	"strings"
 
-	"git.x2erp.com/qdy/go-base/config"
+	"github.com/traefik/yaegi/interp"
+	"github.com/traefik/yaegi/stdlib"
 )
 
 func main() {
-	// 获取配置实例
-	cfg := config.GetConfig()
-
-	// 使用配置
-	if cfg.IsDatabaseConfigured() {
-		dbConfig := cfg.GetDatabaseConfig()
-		fmt.Printf("Host: %s\n", dbConfig.Host)
-		fmt.Printf("Port: %d\n", dbConfig.Port)
-		fmt.Printf("Database: %s\n", dbConfig.Database)
+
+	calculateSimple("(2+3)*5")
+	calculateSimple("15/5")
+	// 测试多行代码（使用专门的多行函数）
+	code := `x := 10
+if x > 5 {
+    return "大于5"
+} else {
+    return "小于等于5"
+}`
+
+	calculateMultiLine(code)
+	// // 获取配置实例
+	// cfg := config.GetConfig()
+
+	// // 使用配置
+	// if cfg.IsDatabaseConfigured() {
+	// 	dbConfig := cfg.GetDatabaseConfig()
+	// 	fmt.Printf("Host: %s\n", dbConfig.Host)
+	// 	fmt.Printf("Port: %d\n", dbConfig.Port)
+	// 	fmt.Printf("Database: %s\n", dbConfig.Database)
+	// }
+
+	// //authConfig := cfg.GetAuth()
+	// //fmt.Printf("token: %s\n", authConfig.Token)
+
+	// serviceConfig := cfg.GetServiceConfig()
+	// fmt.Printf("ReadTimeout: %d秒\n", serviceConfig.ReadTimeout)
+	// fmt.Printf("WriteTimeout: %d秒\n", serviceConfig.WriteTimeout)
+	// fmt.Printf("IdleTimeout: %d秒\n", serviceConfig.IdleTimeout)
+
+}
+
+func calculateSimple(expression string) (string, error) {
+	i := interp.New(interp.Options{})
+	i.Use(stdlib.Symbols)
+
+	// 包装成匿名函数立即调用，既简洁又安全
+	code := fmt.Sprintf("(func() interface{} { return %s })()", expression)
+
+	v, err := i.Eval(code)
+	if err != nil {
+		fmt.Printf("calculateSimple: err v:%v \n", err)
+		return "", err
 	}
 
-	//authConfig := cfg.GetAuth()
-	//fmt.Printf("token: %s\n", authConfig.Token)
+	fmt.Printf("calculateSimple: %s v:%v \n", expression, v)
+	return fmt.Sprintf("%v", v), nil
+}
+
+// 专门处理多行代码（if/for/变量声明等）
+func calculateMultiLine(code string) (string, error) {
+	i := interp.New(interp.Options{})
+	i.Use(stdlib.Symbols)
 
-	serviceConfig := cfg.GetServiceConfig()
-	fmt.Printf("ReadTimeout: %d秒\n", serviceConfig.ReadTimeout)
-	fmt.Printf("WriteTimeout: %d秒\n", serviceConfig.WriteTimeout)
-	fmt.Printf("IdleTimeout: %d秒\n", serviceConfig.IdleTimeout)
+	// 关键：整个代码块作为函数体，最后一行作为返回值
+	wrappedCode := fmt.Sprintf(`
+(func() interface{} {
+	%s
+})()`, code)
+
+	v, err := i.Eval(wrappedCode)
+	if err != nil {
+		fmt.Printf("calculateMultiLine 错误: %v\n代码: %s\n", err, code)
+		return "", err
+	}
+
+	fmt.Printf("calculateMultiLine 成功: %v\n", v)
+	return fmt.Sprintf("%v", v), nil
+}
+
+// 更智能的版本：自动判断使用哪种处理方式
+func calculateAuto(expression string) (string, error) {
+	// 如果是纯数学表达式（只有数字和运算符）
+	if isPureMath(expression) {
+		return calculateSimple(expression)
+	}
+
+	// 否则当做多行代码处理
+	return calculateMultiLine(expression)
+}
+
+func isPureMath(expr string) bool {
+	// 移除非空格的空白字符
+	cleaned := strings.ReplaceAll(expr, "\n", "")
+	cleaned = strings.ReplaceAll(cleaned, "\t", "")
+	cleaned = strings.ReplaceAll(cleaned, " ", "")
+
+	// 检查是否只包含数字、运算符、括号和小数点
+	for _, ch := range cleaned {
+		if !((ch >= '0' && ch <= '9') ||
+			ch == '+' || ch == '-' || ch == '*' || ch == '/' ||
+			ch == '(' || ch == ')' || ch == '.') {
+			return false
+		}
+	}
+	return len(cleaned) > 0
 }