Skip to content

黄成意 / go_sku_server

Go to a project
Commit 70482c93 by 杨树贤
Options

temp

parent a31bb4d0
Inline Side-by-side
Showing with 57 additions and 11 deletions
.cursorignore 0 → 100644
/go.sum
/.idea/
gowatch.yml
*.exe
*.exe~
cmd.exe~
/cmd/logs/
/cmd/*.exe~
/cmd/logs
/bat/logs/
/conf/prod/*.ini
/go.mod
/logs
/mylogs
/doc/test
/vm.sh
/cmd/http
/doc/spuTest
/doc/test3
/.history
/.vscode
controller/sku_controller.go
...@@ -59,6 +59,10 @@ func CommonController(ctx *gin.Context) map[string]interface{} { ...@@ -59,6 +59,10 @@ func CommonController(ctx *gin.Context) map[string]interface{} {
zyGoodsId := make([]string, 0, goodsSliceCount) zyGoodsId := make([]string, 0, goodsSliceCount)
lyGoodsId := make([]string, 0, goodsSliceCount) lyGoodsId := make([]string, 0, goodsSliceCount)
for _, goodsId := range goodsIdArr { for _, goodsId := range goodsIdArr {
//if len(goodsIdArr) > 100 {
// common.Output(ctx, 1001, "查询型号ID不得超过100个", "")
// return nil
//}
if goodsId == "" { if goodsId == "" {
continue continue
} }
......
pkg/gredis/redis.go
...@@ -2,9 +2,10 @@ package gredis ...@@ -2,9 +2,10 @@ package gredis
import ( import (
"fmt" "fmt"
"github.com/gomodule/redigo/redis"
"go_sku_server/pkg/config" "go_sku_server/pkg/config"
"time" "time"
"github.com/gomodule/redigo/redis"
) )
type ichuntRedis struct { type ichuntRedis struct {
...@@ -32,7 +33,7 @@ func Setup() (err error) { ...@@ -32,7 +33,7 @@ func Setup() (err error) {
return nil return nil
} }
//格式化成字符串 // 格式化成字符串
func String(a interface{}, err error) (string, error) { func String(a interface{}, err error) (string, error) {
return redis.String(a, err) return redis.String(a, err)
} }
...@@ -44,7 +45,10 @@ func getConn(writeHost, password string, maxIdle, maxActive int) (pool *redis.Po ...@@ -44,7 +45,10 @@ func getConn(writeHost, password string, maxIdle, maxActive int) (pool *redis.Po
MaxIdle: maxIdle, MaxIdle: maxIdle,
MaxActive: maxActive, MaxActive: maxActive,
Dial: func() (redis.Conn, error) { Dial: func() (redis.Conn, error) {
c, err := redis.Dial("tcp", writeHost) c, err := redis.Dial("tcp", writeHost,
redis.DialConnectTimeout(2*time.Second),
redis.DialReadTimeout(2*time.Second),
redis.DialWriteTimeout(2*time.Second))
if err != nil { if err != nil {
return nil, err return nil, err
} }
...@@ -70,6 +74,7 @@ func getConn(writeHost, password string, maxIdle, maxActive int) (pool *redis.Po ...@@ -70,6 +74,7 @@ func getConn(writeHost, password string, maxIdle, maxActive int) (pool *redis.Po
@param hkey string 集合键值，如sku @param hkey string 集合键值，如sku
@param targetIds string 查询的id 切片 @param targetIds string 查询的id 切片
eg: eg:
redisConn := gredis.Conn("search_r") redisConn := gredis.Conn("search_r")
skuArr := gredis.HgetPi(&redisConn,"Self_SelfGoods",[]string{"1001","10005"}) skuArr := gredis.HgetPi(&redisConn,"Self_SelfGoods",[]string{"1001","10005"})
*/ */
...@@ -86,7 +91,8 @@ func Hmget(redisCon string, hkey string, targetIds []string) map[string]string { ...@@ -86,7 +91,8 @@ func Hmget(redisCon string, hkey string, targetIds []string) map[string]string {
goods_id := targetIds[0] goods_id := targetIds[0]
info, err := String(redisConn.Do("HGET", hkey, goods_id)) info, err := String(redisConn.Do("HGET", hkey, goods_id))
if err != nil && err != redis.ErrNil { if err != nil && err != redis.ErrNil {
fmt.Print("连接redis错误991：", err) fmt.Printf("redis HGET error for key %s, field %s: %v\n", hkey, goods_id, err)
return nil
} }
if info == "" { if info == "" {
skuArr[goods_id] = "" skuArr[goods_id] = ""
...@@ -102,9 +108,14 @@ func Hmget(redisCon string, hkey string, targetIds []string) map[string]string { ...@@ -102,9 +108,14 @@ func Hmget(redisCon string, hkey string, targetIds []string) map[string]string {
} }
res1, err1 := redisConn.Do("hmget", param...) res1, err1 := redisConn.Do("hmget", param...)
reply, _ := redis.Strings(res1, err1)
if err1 != nil { if err1 != nil {
fmt.Println(err1) fmt.Printf("redis HMGET error for key %s: %v\n", hkey, err1)
return nil
}
reply, err := redis.Strings(res1, err1)
if err != nil {
fmt.Printf("redis Strings conversion error after HMGET for key %s: %v\n", hkey, err)
return nil
} }
for k, goodsInfo := range reply { for k, goodsInfo := range reply {
...@@ -120,6 +131,7 @@ func Hmget(redisCon string, hkey string, targetIds []string) map[string]string { ...@@ -120,6 +131,7 @@ func Hmget(redisCon string, hkey string, targetIds []string) map[string]string {
@param hkey string 集合键值，如sku @param hkey string 集合键值，如sku
@param targetIds string 查询的id 切片 @param targetIds string 查询的id 切片
eg: eg:
redisConn := gredis.Conn("search_r") redisConn := gredis.Conn("search_r")
skuArr := gredis.HgetPi(&redisConn,"Self_SelfGoods",[]string{"1001","10005"}) skuArr := gredis.HgetPi(&redisConn,"Self_SelfGoods",[]string{"1001","10005"})
*/ */
...@@ -131,8 +143,9 @@ func HgetPi(redisCon string, hkey string, targetIds []string) map[string]string ...@@ -131,8 +143,9 @@ func HgetPi(redisCon string, hkey string, targetIds []string) map[string]string
if len(targetIds) == 1 { if len(targetIds) == 1 {
oneId := targetIds[0] oneId := targetIds[0]
info, err := String(redisConn.Do("HGET", hkey, oneId)) info, err := String(redisConn.Do("HGET", hkey, oneId))
if err != nil { if err != nil && err != redis.ErrNil {
fmt.Print(err) fmt.Printf("redis HGET error for key %s, field %s: %v\n", hkey, oneId, err)
return nil
} }
if info == "" { if info == "" {
skuArr[oneId] = "" skuArr[oneId] = ""
...@@ -148,7 +161,11 @@ func HgetPi(redisCon string, hkey string, targetIds []string) map[string]string ...@@ -148,7 +161,11 @@ func HgetPi(redisCon string, hkey string, targetIds []string) map[string]string
redisConn.Flush() redisConn.Flush()
for _, goods_id := range targetIds { for _, goods_id := range targetIds {
info, _ := redisConn.Receive() info, err := redisConn.Receive()
if err != nil {
fmt.Printf("redis Receive error for key %s: %v\n", hkey, err)
return nil
}
if info == nil { if info == nil {
skuArr[goods_id] = "" skuArr[goods_id] = ""
continue continue
...@@ -164,6 +181,7 @@ func HgetPi(redisCon string, hkey string, targetIds []string) map[string]string ...@@ -164,6 +181,7 @@ func HgetPi(redisCon string, hkey string, targetIds []string) map[string]string
@param hkey string 集合键值，如sku @param hkey string 集合键值，如sku
@param targetIds string 查询的id 切片 @param targetIds string 查询的id 切片
eg: eg:
redisConn := gredis.Conn("search_r") redisConn := gredis.Conn("search_r")
skuArr := gredis.HgetPi(&redisConn,"Self_SelfGoods",[]string{"1001","10005"}) skuArr := gredis.HgetPi(&redisConn,"Self_SelfGoods",[]string{"1001","10005"})
*/ */
...@@ -174,8 +192,9 @@ func HgetPi2(redisCon string, hkey string, targetIds []string) map[string]string ...@@ -174,8 +192,9 @@ func HgetPi2(redisCon string, hkey string, targetIds []string) map[string]string
skuArr := make(map[string]string, 0) skuArr := make(map[string]string, 0)
for _, goods_id := range targetIds { for _, goods_id := range targetIds {
info, err := String(redisConn.Do("HGET", hkey, goods_id)) info, err := String(redisConn.Do("HGET", hkey, goods_id))
if err != nil { if err != nil && err != redis.ErrNil {
fmt.Print("连接redis错误991：", err) fmt.Printf("redis HGET error in HgetPi2 for key %s, field %s: %v\n", hkey, goods_id, err)
return nil
} }
if info == "" { if info == "" {
skuArr[goods_id] = "" skuArr[goods_id] = ""
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment