up

pkg/config/redis.go

@@ -13,42 +13,17 @@ type RedisDatabase struct {
 //多数据库配置
 //多数据库配置
 func BuildRedisConfgs() (RedisDatabaseMap map[string]RedisDatabase) {
 func BuildRedisConfgs() (RedisDatabaseMap map[string]RedisDatabase) {
 	return map[string]RedisDatabase{
 	return map[string]RedisDatabase{
-		"search_read": {
+		"search_r": {
 			Host: Get("default_redis_read.host").String(),
 			Host: Get("default_redis_read.host").String(),
 			Password: Get("default_redis_read.password").String(),
 			Password: Get("default_redis_read.password").String(),
 			MaxIdle: Get("default_redis_read.max_idle").String(),
 			MaxIdle: Get("default_redis_read.max_idle").String(),
 			MaxActive: Get("default_redis_read.max_active").String(),
 			MaxActive: Get("default_redis_read.max_active").String(),
 		},
 		},
-		"search_write": {
+		"search_w": {
 			Host: Get("default_redis_write.host").String(),
 			Host: Get("default_redis_write.host").String(),
 			Password: Get("default_redis_write.password").String(),
 			Password: Get("default_redis_write.password").String(),
 			MaxIdle: Get("default_redis_read.max_idle").String(),
 			MaxIdle: Get("default_redis_read.max_idle").String(),
 			MaxActive: Get("default_redis_read.max_active").String(),
 			MaxActive: Get("default_redis_read.max_active").String(),
 		},
 		},
-		"spu_read": {
-			Host: Get("default_redis_read.host").String(),
-			Password: Get("default_redis_read.password").String(),
-			MaxIdle: Get("default_redis_read.max_idle").String(),
-			MaxActive: Get("default_redis_read.max_active").String(),
-		},
-		"spu_write": {
-			Host: Get("default_redis_write.host").String(),
-			Password: Get("default_redis_write.password").String(),
-			MaxIdle: Get("default_redis_read.max_idle").String(),
-			MaxActive: Get("default_redis_read.max_active").String(),
-		},
-		"api_read": {
-			Host: Get("api_redis_read.host").String(),
-			Password: Get("api_redis_read.password").String(),
-			MaxIdle: Get("api_redis_read.max_idle").String(),
-			MaxActive: Get("api_redis_read.max_active").String(),
-		},
-		"api_write": {
-			Host: Get("api_redis_write.host").String(),
-			Password: Get("api_redis_write.password").String(),
-			MaxIdle: Get("api_redis_write.max_idle").String(),
-			MaxActive: Get("api_redis_write.max_active").String(),
-		},
-
 	}
 	}
 }
 }

routes/router.go

@@ -14,7 +14,7 @@ func InitRouter() *gin.Engine {
 	//路由
 	//路由
 	r.POST("/search/bom/autospu", controller.AutoSpu)
 	r.POST("/search/bom/autospu", controller.AutoSpu)
 	r.POST("/search/bom/recommend", controller.Recommend)
 	r.POST("/search/bom/recommend", controller.Recommend)
-	//r.POST("search/ZiYing/zyh", controller.Zyh)
+	r.POST("search/ZiYing/zyh", controller.Zyh)
 
 
 	//快手平台相关
 	//快手平台相关
 	//r.GET("/search/quote", controller.QuoteIndex)
 	//r.GET("/search/quote", controller.QuoteIndex)

service/ziyin_service.go

@@ -6,6 +6,7 @@ import (
 	"reflect"
 	"reflect"
 	"search_server/model"
 	"search_server/model"
 	"search_server/pkg/config"
 	"search_server/pkg/config"
+	"search_server/pkg/gredis"
 )
 )
 
 
 type ZyServiceImpl struct{}
 type ZyServiceImpl struct{}
@@ -59,5 +60,12 @@ func zy(ctx *gin.Context, req *model.ZyhRequest,_type byte,isCheck byte) (rsp *m
 	fmt.Printf("%+v",req)
 	fmt.Printf("%+v",req)
 	fmt.Println(reflect.TypeOf(req.ClassIdcondition))
 	fmt.Println(reflect.TypeOf(req.ClassIdcondition))
 	fmt.Println(req.ClassIdcondition)
 	fmt.Println(req.ClassIdcondition)
+	redis_s_r :=gredis.Conn("search_r")
+	defer func(){
+		redis_s_r.Close()
+	}()
+
+
+
 	return nil
 	return nil
 }
 }