up

cmd/search_http_server.go

@@ -5,7 +5,7 @@ import (
 	"github.com/gin-gonic/gin"
 	"github.com/micro/go-micro/v2/web"
 	"search_server/boot"
-	_ "search_server/controller"
+	//_ "search_server/controller"
 	"search_server/pkg/config"
 	"search_server/routes"
 )

pkg/gredis/redis.go

 package gredis
 
 import (
-	"encoding/json"
 	"github.com/gomodule/redigo/redis"
 	"search_server/pkg/config"
 	"time"
@@ -9,20 +8,18 @@ import (
 
 
 
-type IchuntRedis struct {
+type ichuntRedis struct {
 	RedisList map[string]*redis.Pool
-	Current *redis.Pool
 }
 
-func(this *IchuntRedis) Connection(connection string) (*IchuntRedis){
-	this.Current = this.RedisList[connection]
-	return this
+func(this *ichuntRedis) Conn(connection string) (*redis.Pool){
+	return this.RedisList[connection]
 }
 
 var writeConn, readConn *redis.Pool
 
 func Setup() (err error) {
-	ichuntRedis := &IchuntRedis{}
+	ichuntRedis := &ichuntRedis{}
 	ichuntRedis.RedisList = make(map[string]*redis.Pool,0)
 	RedisDatabaseMap := config.BuildRedisConfgs()
 	for redisKey,redisConfig := range RedisDatabaseMap{
@@ -63,109 +60,4 @@ func getConn(writeHost, password string) (pool *redis.Pool, err error) {
 	return
 }
 
-//最基础的键值操作
-
-func (this *IchuntRedis) Set(key string, data interface{}) error {
-	conn := this.Current.Get()
-	defer conn.Close()
-
-	value, err := json.Marshal(data)
-	if err != nil {
-		return err
-	}
-
-	_, err = conn.Do("SET", key, value)
-	if err != nil {
-		return err
-	}
-
-	return nil
-}
-
-//Redis Setnx（SET if Not eXists） 命令在指定的 key 不存在时，为 key 设置指定的值。
-func(this *IchuntRedis) Setnx(key string, data interface{}) error {
-	conn := this.Current.Get()
-	defer conn.Close()
-
-	value, err := json.Marshal(data)
-	if err != nil {
-		return err
-	}
-
-	_, err = conn.Do("SETNX", key, value)
-	if err != nil {
-		return err
-	}
-
-	return nil
-}
-
-func(this *IchuntRedis) Exists(key string) bool {
-	conn := this.Current.Get()
-	defer conn.Close()
-
-	exists, err := redis.Bool(conn.Do("EXISTS", key))
-	if err != nil {
-		return false
-	}
-
-	return exists
-}
-
-func(this *IchuntRedis) Get(key string) (interface{}, error) {
-	conn := this.Current.Get()
-	defer conn.Close()
-
-	reply, err := conn.Do("GET", key)
-	if err != nil {
-		return nil, err
-	}
-
-	return reply, nil
-}
-
-func(this *IchuntRedis) Delete(key string) (bool, error) {
-	conn := this.Current.Get()
-	defer conn.Close()
-
-	return redis.Bool(conn.Do("DEL", key))
-}
-
-//哈希操作
-
-func(this *IchuntRedis) HSet(key string, k interface{}, data interface{}) error {
-	conn := this.Current.Get()
-	defer conn.Close()
-
-	value, err := json.Marshal(data)
-	if err != nil {
-		return err
-	}
-
-	_, err = conn.Do("HSET", key, k, value)
-	if err != nil {
-		return err
-	}
-
-	return nil
-}
-
-func(this *IchuntRedis) HGet(key string, k interface{}) (interface{}, error) {
-	conn := this.Current.Get()
-	defer conn.Close()
-
-	reply, err := conn.Do("HGET", key, k)
-	if err != nil {
-		return nil, err
-	}
-
-	return reply, nil
-}
-
-func(this *IchuntRedis) HDelete(key string, k interface{}) (bool, error) {
-	conn := this.Current.Get()
-	defer conn.Close()
-
-	return redis.Bool(conn.Do("HDEL", key, k))
-}
 

routes/router.go

@@ -14,10 +14,10 @@ func InitRouter() *gin.Engine {
 	//路由
 	r.POST("/search/bom/autospu", controller.AutoSpu)
 	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)
 
 	return r
 }

test/test4.go

+package main
+
+type IchuntRedis struct {
+	Abc map[string]int
+	Current *int
+}
+
+ichuntRedis := &IchuntRedis{}
+ichuntRedis.
+
+ichuntRedis[]